integratedservices

type ClusterIsNotReadyError struct {
	ClusterID uint
}

type ClusterKubeConfigFunc func(ctx context.Context, clusterID uint) ([]byte, error)

type ClusterService interface {
	// CheckClusterReady checks whether the cluster is ready for integrated services (eg.: exists and it's running). If the cluster is not ready, a ClusterIsNotReadyError should be returned.
	CheckClusterReady(ctx context.Context, clusterID uint) error
}

type ISServiceV2 struct {
	// contains filtered or unexported fields
}

type InMemoryIntegratedServiceRepository struct {
	// contains filtered or unexported fields
}

type IntegratedService struct {
	Name   string                  `json:"name"`
	Spec   IntegratedServiceSpec   `json:"spec"`
	Output IntegratedServiceOutput `json:"output"`
	Status string                  `json:"status"`
}

type IntegratedServiceCleaner interface {
	DisableServiceInstance(ctx context.Context, clusterID uint) error
}

type IntegratedServiceManager interface {
	IntegratedServiceOutputProducer
	IntegratedServiceSpecValidator
	IntegratedServiceSpecPreparer

	// Name returns the integrated service's name.
	Name() string
}

type IntegratedServiceManagerRegistry interface {
	// GetIntegratedServiceManager retrieves an integrated service manager by name.
	GetIntegratedServiceManager(integratedServiceName string) (IntegratedServiceManager, error)
	// GetIntegratedServiceNames retrieves all known integrated services
	GetIntegratedServiceNames() []string
}

type IntegratedServiceOperationDispatcher interface {
	// DispatchApply starts applying a desired state for an integrated service asynchronously.
	DispatchApply(ctx context.Context, clusterID uint, integratedServiceName string, spec IntegratedServiceSpec) error

	// DispatchDeactivate starts deactivating an integrated service asynchronously.
	DispatchDeactivate(ctx context.Context, clusterID uint, integratedServiceName string, spec IntegratedServiceSpec) error

	// IsBeingDispatched checks whether there are any actively running workflows for the service
	IsBeingDispatched(ctx context.Context, clusterID uint, integratedServiceName string) (bool, error)
}

type IntegratedServiceOperator interface {
	// Apply applies a desired state for an integrated service on the given cluster.
	Apply(ctx context.Context, clusterID uint, spec IntegratedServiceSpec) error

	// Deactivate deactivates an integrated service on the given cluster.
	Deactivate(ctx context.Context, clusterID uint, spec IntegratedServiceSpec) error

	// Name returns the integrated service's name.
	Name() string
}

type IntegratedServiceOperatorRegistry interface {
	// GetIntegratedServiceOperator retrieves an integrated service operator by name.
	GetIntegratedServiceOperator(integratedServiceName string) (IntegratedServiceOperator, error)
}

type IntegratedServiceOutput = map[string]interface{}

type IntegratedServiceOutputProducer interface {
	// GetOutput returns an integrated service's output.
	GetOutput(ctx context.Context, clusterID uint, spec IntegratedServiceSpec) (IntegratedServiceOutput, error)
}

type IntegratedServiceRepository interface {
	// GetIntegratedServices retrieves integrated services for a given cluster.
	GetIntegratedServices(ctx context.Context, clusterID uint) ([]IntegratedService, error)

	// GetIntegratedService retrieves an integrated service.
	GetIntegratedService(ctx context.Context, clusterID uint, integratedServiceName string) (IntegratedService, error)

	// SaveIntegratedService persists an integrated service.
	SaveIntegratedService(ctx context.Context, clusterID uint, integratedServiceName string, spec IntegratedServiceSpec, status string) error

	// UpdateIntegratedServiceStatus updates the status of an integrated service.
	UpdateIntegratedServiceStatus(ctx context.Context, clusterID uint, integratedServiceName string, status string) error

	// UpdateIntegratedServiceSpec updates the spec of an integrated service.
	UpdateIntegratedServiceSpec(ctx context.Context, clusterID uint, integratedServiceName string, spec IntegratedServiceSpec) error

	// DeleteIntegratedService deletes an integrated service.
	DeleteIntegratedService(ctx context.Context, clusterID uint, integratedServiceName string) error
}

type IntegratedServiceService struct {
	// contains filtered or unexported fields
}

type IntegratedServiceSpec = map[string]interface{}

type IntegratedServiceSpecPreparer interface {
	// PrepareSpec makes certain preparations to the spec before it's sent to be applied.
	// For example it rewrites the secret ID to it's internal representation, fills in defaults, etc.
	PrepareSpec(ctx context.Context, clusterID uint, spec IntegratedServiceSpec) (IntegratedServiceSpec, error)
}

type IntegratedServiceSpecValidator interface {
	// ValidateSpec validates an integrated service specification.
	ValidateSpec(ctx context.Context, spec IntegratedServiceSpec) error
}

type IntegratedServiceStatus = string

type InvalidIntegratedServiceSpecError struct {
	IntegratedServiceName string
	Problem               string
}

type LocalIntegratedServiceOperationDispatcher struct {
	// contains filtered or unexported fields
}

type Logger = common.Logger

type MockClusterService struct {
	mock.Mock
}

type MockService struct {
	mock.Mock
}

type NoopLogger = common.NoopLogger

type NotManagedIntegratedServiceError struct {
	IntegratedServiceName string
}

type PassthroughIntegratedServiceSpecPreparer struct{}

type Service interface {
	// List lists the activated integrated services and their details.
	List(ctx context.Context, clusterID uint) (services []IntegratedService, err error)

	// Details returns the details of an activated integrated service.
	Details(ctx context.Context, clusterID uint, serviceName string) (service IntegratedService, err error)

	// Activate activates a integrated service.
	Activate(ctx context.Context, clusterID uint, serviceName string, spec map[string]interface{}) error

	// Deactivate deactivates a integrated service.
	Deactivate(ctx context.Context, clusterID uint, serviceName string) error

	// Update updates a integrated service.
	Update(ctx context.Context, clusterID uint, serviceName string, spec map[string]interface{}) error
}

type SpecConversion interface {
	// ConvertSpec converts in integrated service spec while keeping it's original structure
	ConvertSpec(ctx context.Context, instance v1alpha1.ServiceInstance) (IntegratedServiceSpec, error)
}

type UnknownIntegratedServiceError struct {
	IntegratedServiceName string
}