services

Documentation

Index

• func GetValidClusterColumns() []string
• func GetValidConnectorColumns() []string
• func GetValidConnectorTypeColumns() []string
• func GetValidDeploymentColumns() []string
• func GetValidNamespaceColumns() []string
• func NewConnectorClusterService(connectionFactory *db.ConnectionFactory, bus signalbus.SignalBus, ...) *connectorClusterService
• func NewConnectorNamespaceService(factory *db.ConnectionFactory, config *config.ConnectorsConfig, ...) *connectorNamespaceService
• func NewConnectorTypesService(connectorsConfig *config.ConnectorsConfig, ...) *connectorTypesService
• func NewConnectorsService(connectionFactory *db.ConnectionFactory, bus signalbus.SignalBus, ...) *connectorsService
• type ConnectorClusterService
• type ConnectorNamespaceService
• type ConnectorTypesService
• type ConnectorsService

Functions

func GetValidClusterColumns

func GetValidClusterColumns() []string

func GetValidConnectorColumns

func GetValidConnectorColumns() []string

func GetValidConnectorTypeColumns

func GetValidConnectorTypeColumns() []string

func GetValidDeploymentColumns

func GetValidDeploymentColumns() []string

func GetValidNamespaceColumns

func GetValidNamespaceColumns() []string

func NewConnectorClusterService

func NewConnectorClusterService(connectionFactory *db.ConnectionFactory, bus signalbus.SignalBus, vaultService vault.VaultService,
	connectorTypesService ConnectorTypesService, connectorsService ConnectorsService,
	keycloakService sso.KafkaKeycloakService, connectorNamespaceService ConnectorNamespaceService) *connectorClusterService

func NewConnectorNamespaceService

func NewConnectorNamespaceService(factory *db.ConnectionFactory, config *config.ConnectorsConfig,
	quotaConfig *config.ConnectorsQuotaConfig, bus signalbus.SignalBus) *connectorNamespaceService

func NewConnectorTypesService

func NewConnectorTypesService(connectorsConfig *config.ConnectorsConfig, connectionFactory *db.ConnectionFactory) *connectorTypesService

func NewConnectorsService

func NewConnectorsService(connectionFactory *db.ConnectionFactory, bus signalbus.SignalBus,
	vaultService vault.VaultService, connectorTypesService ConnectorTypesService) *connectorsService

Types

type ConnectorClusterService

type ConnectorClusterService interface {
	Create(ctx context.Context, resource *dbapi.ConnectorCluster) *errors.ServiceError
	Get(ctx context.Context, id string) (*dbapi.ConnectorCluster, *errors.ServiceError)
	Delete(ctx context.Context, id string) *errors.ServiceError
	List(ctx context.Context, listArgs *services.ListArguments) (dbapi.ConnectorClusterList, *api.PagingMeta, *errors.ServiceError)
	Update(ctx context.Context, resource *dbapi.ConnectorCluster) *errors.ServiceError
	UpdateConnectorClusterStatus(ctx context.Context, id string, status dbapi.ConnectorClusterStatus) *errors.ServiceError
	GetConnectorClusterStatus(ctx context.Context, id string) (dbapi.ConnectorClusterStatus, *errors.ServiceError)

	SaveDeployment(ctx context.Context, resource *dbapi.ConnectorDeployment) *errors.ServiceError
	UpdateDeployment(resource *dbapi.ConnectorDeployment) *errors.ServiceError
	ListConnectorDeployments(ctx context.Context, clusterId string, filterChannelUpdates bool, filterOperatorUpdates bool, includeDanglingDeploymentsOnly bool, listArgs *services.ListArguments, gtVersion int64) (dbapi.ConnectorDeploymentList, *api.PagingMeta, *errors.ServiceError)
	UpdateConnectorDeploymentStatus(ctx context.Context, status dbapi.ConnectorDeploymentStatus) *errors.ServiceError
	FindAvailableNamespace(owner string, orgId string, namespaceId *string) (*dbapi.ConnectorNamespace, *errors.ServiceError)
	GetDeploymentByConnectorId(ctx context.Context, connectorID string) (dbapi.ConnectorDeployment, *errors.ServiceError)
	GetDeployment(ctx context.Context, id string) (dbapi.ConnectorDeployment, *errors.ServiceError)
	CleanupDeployments() *errors.ServiceError
	ReconcileEmptyDeletingClusters(ctx context.Context, clusterIds []string) (int, []*errors.ServiceError)
	ReconcileNonEmptyDeletingClusters(ctx context.Context, clusterIds []string) (int, []*errors.ServiceError)
	GetClusterIds(query string, args ...interface{}) ([]string, error)
	GetClusterOrg(id string) (string, *errors.ServiceError)
	ResetServiceAccount(ctx context.Context, cluster *dbapi.ConnectorCluster) *errors.ServiceError
}

type ConnectorNamespaceService

type ConnectorNamespaceService interface {
	Create(ctx context.Context, request *dbapi.ConnectorNamespace) *errors.ServiceError
	Update(ctx context.Context, request *dbapi.ConnectorNamespace) *errors.ServiceError
	Get(ctx context.Context, namespaceID string) (*dbapi.ConnectorNamespace, *errors.ServiceError)
	List(ctx context.Context, clusterIDs []string, listArguments *services.ListArguments, gtVersion int64) (dbapi.ConnectorNamespaceList, *api.PagingMeta, *errors.ServiceError)
	Delete(ctx context.Context, namespaceId string) *errors.ServiceError
	SetEvalClusterId(request *dbapi.ConnectorNamespace) *errors.ServiceError
	CreateDefaultNamespace(ctx context.Context, connectorCluster *dbapi.ConnectorCluster) *errors.ServiceError
	UpdateConnectorNamespaceStatus(ctx context.Context, namespaceID string, status *dbapi.ConnectorNamespaceStatus) *errors.ServiceError
	DeleteNamespaces(ctx context.Context, dbConn *gorm.DB, query interface{}, values ...interface{}) (int64, *errors.ServiceError)
	ReconcileExpiredNamespaces(ctx context.Context) (int64, *errors.ServiceError)
	ReconcileUnusedDeletingNamespaces(ctx context.Context) (int64, *errors.ServiceError)
	ReconcileUsedDeletingNamespaces(ctx context.Context) (int64, *errors.ServiceError)
	ReconcileDeletedNamespaces(ctx context.Context) (int64, *errors.ServiceError)
	GetNamespaceTenant(namespaceId string) (*dbapi.ConnectorNamespace, *errors.ServiceError)
	CheckConnectorQuota(namespaceId string) *errors.ServiceError
	CanCreateEvalNamespace(userId string) *errors.ServiceError
	GetEmptyDeletingNamespaces(clusterId string) (dbapi.ConnectorNamespaceList, *errors.ServiceError)
}

type ConnectorTypesService

type ConnectorTypesService interface {
	Get(id string) (*dbapi.ConnectorType, *errors.ServiceError)
	List(listArgs *services.ListArguments) (dbapi.ConnectorTypeList, *api.PagingMeta, *errors.ServiceError)
	ListLabels(listArgs *services.ListArguments) (dbapi.ConnectorTypeLabelCountList, *errors.ServiceError)
	ForEachConnectorCatalogEntry(f func(id string, channel string, ccc *config.ConnectorChannelConfig) *errors.ServiceError) *errors.ServiceError

	PutConnectorShardMetadata(ctc *dbapi.ConnectorShardMetadata) (int64, *errors.ServiceError)
	GetConnectorShardMetadata(typeId, channel string, revision int64) (*dbapi.ConnectorShardMetadata, *errors.ServiceError)
	GetLatestConnectorShardMetadata(typeId, channel string) (*dbapi.ConnectorShardMetadata, *errors.ServiceError)
	CatalogEntriesReconciled() (bool, *errors.ServiceError)
	DeleteOrDeprecateRemovedTypes() *errors.ServiceError
	ListCatalogEntries(*coreService.ListArguments) ([]dbapi.ConnectorCatalogEntry, *api.PagingMeta, *errors.ServiceError)
	GetCatalogEntry(tyd string) (*dbapi.ConnectorCatalogEntry, *errors.ServiceError)
}

type ConnectorsService

type ConnectorsService interface {
	Create(ctx context.Context, resource *dbapi.Connector) *errors.ServiceError
	Get(ctx context.Context, id string) (*dbapi.ConnectorWithConditions, *errors.ServiceError)
	List(ctx context.Context, listArgs *services.ListArguments, clusterId string) (dbapi.ConnectorWithConditionsList, *api.PagingMeta, *errors.ServiceError)
	Update(ctx context.Context, resource *dbapi.Connector) *errors.ServiceError
	SaveStatus(ctx context.Context, resource dbapi.ConnectorStatus) *errors.ServiceError
	Delete(ctx context.Context, id string) *errors.ServiceError
	ForEach(f func(*dbapi.Connector) *errors.ServiceError, query string, args ...interface{}) []error
	ForceDelete(ctx context.Context, id string) *errors.ServiceError

	ResolveConnectorRefsWithBase64Secrets(resource *dbapi.Connector) (bool, *errors.ServiceError)
}