workers

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
  • func NewClusterManager(clusterService services.ConnectorClusterService, db *db.ConnectionFactory, ...) *ClusterManager
  • func (m *ClusterManager) Reconcile() []error
  • func (m *ClusterManager) Start()
  • func (m *ClusterManager) Stop()
• type ConnectorManager
  • func NewConnectorManager(connectorTypesService services.ConnectorTypesService, ...) *ConnectorManager
  • func (k *ConnectorManager) Reconcile() []error
  • func (k *ConnectorManager) ReconcileConnectorCatalogEntry(id string, channel string, ...) *serviceError.ServiceError
  • func (k *ConnectorManager) Start()
  • func (k *ConnectorManager) Stop()
• type ConnectorTypeManager
  • func NewConnectorTypeManager(connectorTypesService services.ConnectorTypesService, ...) *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
  • func NewNamespaceManager(namespaceService services.ConnectorNamespaceService, db *db.ConnectionFactory, ...) *NamespaceManager
  • func (m *NamespaceManager) Reconcile() []error
  • func (m *NamespaceManager) Start()
  • func (m *NamespaceManager) Stop()

Functions

func GetShardMetadataRevision

func GetShardMetadataRevision(connectorShardMetadata map[string]interface{}) (int64, error)

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()