Documentation ¶
Index ¶
- func GetShardMetadataRevision(connectorShardMetadata map[string]interface{}) (int64, error)
- func InDBTransaction(ctx context.Context, f func(ctx context.Context) error) (rerr *serviceError.ServiceError)
- func NewApiServerReadyCondition(cm *ConnectorTypeManager) server.ApiServerReadyCondition
- type ClusterManager
- type ConnectorManager
- type ConnectorTypeManager
- func (k *ConnectorTypeManager) HasTerminated() bool
- func (k *ConnectorTypeManager) Reconcile() []error
- func (k *ConnectorTypeManager) ReconcileConnectorCatalogEntry(id string, channel string, ...) *serviceError.ServiceError
- func (k *ConnectorTypeManager) Start()
- func (k *ConnectorTypeManager) Stop()
- type NamespaceManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InDBTransaction ¶
func InDBTransaction(ctx context.Context, f func(ctx context.Context) error) (rerr *serviceError.ServiceError)
func NewApiServerReadyCondition ¶
func NewApiServerReadyCondition(cm *ConnectorTypeManager) server.ApiServerReadyCondition
NewApiServerReadyCondition is used to inject a server.ApiServerReadyCondition into the server.ApiServer so that it waits for the ConnectorTypeManager to have completed a startup reconcile before accepting http requests.
Types ¶
type ClusterManager ¶
type ClusterManager struct { workers.BaseWorker // contains filtered or unexported fields }
func NewClusterManager ¶
func NewClusterManager(clusterService services.ConnectorClusterService, db *db.ConnectionFactory, reconciler workers.Reconciler) *ClusterManager
func (*ClusterManager) Reconcile ¶
func (m *ClusterManager) Reconcile() []error
func (*ClusterManager) Start ¶
func (m *ClusterManager) Start()
func (*ClusterManager) Stop ¶
func (m *ClusterManager) Stop()
type ConnectorManager ¶
type ConnectorManager struct { workers.BaseWorker // contains filtered or unexported fields }
ConnectorManager represents a connector manager that periodically reconciles connector requests
func NewConnectorManager ¶
func NewConnectorManager( connectorTypesService services.ConnectorTypesService, connectorService services.ConnectorsService, connectorClusterService services.ConnectorClusterService, vaultService vault.VaultService, db *db.ConnectionFactory, reconciler workers.Reconciler, ) *ConnectorManager
NewConnectorManager creates a new connector manager
func (*ConnectorManager) Reconcile ¶
func (k *ConnectorManager) Reconcile() []error
func (*ConnectorManager) ReconcileConnectorCatalogEntry ¶
func (k *ConnectorManager) ReconcileConnectorCatalogEntry(id string, channel string, connectorChannelConfig *config.ConnectorChannelConfig) *serviceError.ServiceError
func (*ConnectorManager) Start ¶
func (k *ConnectorManager) Start()
Start initializes the connector manager to reconcile connector requests
func (*ConnectorManager) Stop ¶
func (k *ConnectorManager) Stop()
Stop causes the process for reconciling connector requests to stop.
type ConnectorTypeManager ¶
type ConnectorTypeManager struct { workers.BaseWorker // contains filtered or unexported fields }
ConnectorTypeManager represents a connector manager that reconciles connector types at startup
func NewConnectorTypeManager ¶
func NewConnectorTypeManager( connectorTypesService services.ConnectorTypesService, connectorService services.ConnectorsService, connectorClusterService services.ConnectorClusterService, vaultService vault.VaultService, db *db.ConnectionFactory, reconciler workers.Reconciler, env *environments.Env, ) *ConnectorTypeManager
NewConnectorTypeManager creates a new connector type manager
func (*ConnectorTypeManager) HasTerminated ¶
func (k *ConnectorTypeManager) HasTerminated() bool
HasTerminated indicates whether the worker should be stopped and terminated
func (*ConnectorTypeManager) Reconcile ¶
func (k *ConnectorTypeManager) Reconcile() []error
func (*ConnectorTypeManager) ReconcileConnectorCatalogEntry ¶
func (k *ConnectorTypeManager) ReconcileConnectorCatalogEntry(id string, channel string, connectorChannelConfig *config.ConnectorChannelConfig) *serviceError.ServiceError
func (*ConnectorTypeManager) Start ¶
func (k *ConnectorTypeManager) Start()
Start initializes the connector manager to reconcile connector requests
func (*ConnectorTypeManager) Stop ¶
func (k *ConnectorTypeManager) Stop()
Stop causes the process for reconciling connector requests to stop.
type NamespaceManager ¶
type NamespaceManager struct { workers.BaseWorker // contains filtered or unexported fields }
func NewNamespaceManager ¶
func NewNamespaceManager(namespaceService services.ConnectorNamespaceService, db *db.ConnectionFactory, reconciler workers.Reconciler) *NamespaceManager
func (*NamespaceManager) Reconcile ¶
func (m *NamespaceManager) Reconcile() []error
func (*NamespaceManager) Start ¶
func (m *NamespaceManager) Start()
func (*NamespaceManager) Stop ¶
func (m *NamespaceManager) Stop()