gateway

type AuthenticationDetailsReader interface {
	// Read reads the authentication details to connect to the instance.
	Read(ctx context.Context, instanceID string) (accessKeyID, secretAccessKey string, err error)
}

type Gateway struct {
	Logger *slog.Logger
	// contains filtered or unexported fields
}

type ObjectReadWriteFinder interface {
	// Read reads the object.
	Read(ctx context.Context, bucketName, objectName string) (io.ReadCloser, bool, error)

	// Write writes the object.
	Write(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSizeBytes int64) error

	// Find identifies if the object can be found in the instance.
	Find(ctx context.Context, bucketName, objectName string) (bool, error)
}

type ServiceRegistryScanner interface {
	// Scan scans the "service discovery" records to find instances and return the map ID -> IP address.
	Scan(ctx context.Context, serviceLabelFilter string) (map[string]string, error)
}

type StorageConnectionFn func(endpoint, accessKeyID, secretAccessKey string) (ObjectReadWriteFinder, error)