Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AcceptedKafkaManager ¶
type AcceptedKafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
AcceptedKafkaManager represents a kafka manager that periodically reconciles accepted kafka requests.
func NewAcceptedKafkaManager ¶
func NewAcceptedKafkaManager(kafkaService services.KafkaService, clusterPlacementStrategy services.ClusterPlacementStrategy, dataPlaneClusterConfig *config.DataplaneClusterConfig, clusterService services.ClusterService, reconciler workers.Reconciler) *AcceptedKafkaManager
NewAcceptedKafkaManager creates a new kafka manager to reconcile accepted kafkas.
func (*AcceptedKafkaManager) Reconcile ¶
func (k *AcceptedKafkaManager) Reconcile() []error
func (*AcceptedKafkaManager) Start ¶
func (k *AcceptedKafkaManager) Start()
Start initializes the kafka manager to reconcile accepted kafka requests.
func (*AcceptedKafkaManager) Stop ¶
func (k *AcceptedKafkaManager) Stop()
Stop causes the process for reconciling accepted kafka requests to stop.
type DeletingKafkaManager ¶
type DeletingKafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
DeletingKafkaManager represents a kafka manager that periodically reconciles deleting and deprovision kafka requests.
func NewDeletingKafkaManager ¶
func NewDeletingKafkaManager(kafkaService services.KafkaService, keycloakConfig *keycloak.KeycloakConfig, quotaServiceFactory services.QuotaServiceFactory, reconciler workers.Reconciler) *DeletingKafkaManager
NewDeletingKafkaManager creates a new kafka manager to reconcile deleting and deprovision kafkas.
func (*DeletingKafkaManager) Reconcile ¶
func (k *DeletingKafkaManager) Reconcile() []error
func (*DeletingKafkaManager) Start ¶
func (k *DeletingKafkaManager) Start()
Start initializes the kafka manager to reconcile deleting and deprovision kafka requests.
func (*DeletingKafkaManager) Stop ¶
func (k *DeletingKafkaManager) Stop()
Stop causes the process for reconciling deleting and deprovision kafka requests to stop.
type KafkaManager ¶
type KafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
KafkaManager represents a kafka manager that periodically reconciles kafka requests
func NewKafkaManager ¶
func NewKafkaManager(kafkaService services.KafkaService, accessControlList *acl.AccessControlListConfig, kafka *config.KafkaConfig, clusters *config.DataplaneClusterConfig, providers *config.ProviderConfig, reconciler workers.Reconciler, clusterService services.ClusterService) *KafkaManager
NewKafkaManager creates a new kafka manager to reconcile kafkas
func (*KafkaManager) Reconcile ¶
func (k *KafkaManager) Reconcile() []error
func (*KafkaManager) Start ¶
func (k *KafkaManager) Start()
Start initializes the kafka manager to reconcile kafka requests
func (*KafkaManager) Stop ¶
func (k *KafkaManager) Stop()
Stop causes the process for reconciling kafka requests to stop.
type KafkaRoutesCNAMEManager ¶
type KafkaRoutesCNAMEManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
func NewKafkaCNAMEManager ¶
func NewKafkaCNAMEManager(kafkaService services.KafkaService, kafkaConfig *config.KafkaConfig, reconciler workers.Reconciler) *KafkaRoutesCNAMEManager
func (*KafkaRoutesCNAMEManager) Reconcile ¶
func (k *KafkaRoutesCNAMEManager) Reconcile() []error
func (*KafkaRoutesCNAMEManager) Start ¶
func (k *KafkaRoutesCNAMEManager) Start()
func (*KafkaRoutesCNAMEManager) Stop ¶
func (k *KafkaRoutesCNAMEManager) Stop()
type KafkasRoutesTLSCertificateManager ¶
type KafkasRoutesTLSCertificateManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
KafkasRoutesTLSCertificateManager represents a kafka manager that periodically reconciles kafka routes tls certificate.
func NewKafkasRoutesTLSCertificateManager ¶
func NewKafkasRoutesTLSCertificateManager(kafkaService services.KafkaService, reconciler workers.Reconciler) *KafkasRoutesTLSCertificateManager
NewKafkasRoutesTLSCertificateManager creates a new kafka manager to reconcile kafkas tls certificate.
func (*KafkasRoutesTLSCertificateManager) Reconcile ¶
func (k *KafkasRoutesTLSCertificateManager) Reconcile() []error
func (*KafkasRoutesTLSCertificateManager) Start ¶
func (k *KafkasRoutesTLSCertificateManager) Start()
Start initializes the kafka manager to reconcile kafka routes tls certificate.
func (*KafkasRoutesTLSCertificateManager) Stop ¶
func (k *KafkasRoutesTLSCertificateManager) Stop()
Stop causes the process for reconciling kafka routes tls certificate to stop.
type PreparingKafkaManager ¶
type PreparingKafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
PreparingKafkaManager represents a kafka manager that periodically reconciles preparing kafka requests.
func NewPreparingKafkaManager ¶
func NewPreparingKafkaManager(kafkaService services.KafkaService, reconciler workers.Reconciler) *PreparingKafkaManager
NewPreparingKafkaManager creates a new kafka manager to reconcile preparing kafkas.
func (*PreparingKafkaManager) Reconcile ¶
func (k *PreparingKafkaManager) Reconcile() []error
func (*PreparingKafkaManager) Start ¶
func (k *PreparingKafkaManager) Start()
Start initializes the kafka manager to reconcile preparing kafka requests.
func (*PreparingKafkaManager) Stop ¶
func (k *PreparingKafkaManager) Stop()
Stop causes the process for reconciling preparing kafka requests to stop.
type ProvisioningKafkaManager ¶
type ProvisioningKafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
ProvisioningKafkaManager represents a kafka manager that periodically reconciles provisioning kafka requests.
func NewProvisioningKafkaManager ¶
func NewProvisioningKafkaManager(kafkaService services.KafkaService, reconciler workers.Reconciler, clusterPlacementStrategy services.ClusterPlacementStrategy) *ProvisioningKafkaManager
NewProvisioningKafkaManager creates a new kafka manager to reconcile provisioning kafkas.
func (*ProvisioningKafkaManager) Reconcile ¶
func (k *ProvisioningKafkaManager) Reconcile() []error
func (*ProvisioningKafkaManager) Start ¶
func (k *ProvisioningKafkaManager) Start()
Start initializes the kafka manager to reconcile provisioning kafka requests.
func (*ProvisioningKafkaManager) Stop ¶
func (k *ProvisioningKafkaManager) Stop()
Stop causes the process for reconciling provisioning kafka requests to stop.
type ReadyKafkaManager ¶
type ReadyKafkaManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
ReadyKafkaManager represents a kafka manager that periodically reconciles ready kafka requests.
func NewReadyKafkaManager ¶
func NewReadyKafkaManager(kafkaService services.KafkaService, keycloakService sso.KafkaKeycloakService, keycloakConfig *keycloak.KeycloakConfig, reconciler workers.Reconciler) *ReadyKafkaManager
NewReadyKafkaManager creates a new kafka manager to reconcile ready kafkas.
func (*ReadyKafkaManager) Reconcile ¶
func (k *ReadyKafkaManager) Reconcile() []error
func (*ReadyKafkaManager) Start ¶
func (k *ReadyKafkaManager) Start()
Start initializes the kafka manager to reconcile ready kafka requests.
func (*ReadyKafkaManager) Stop ¶
func (k *ReadyKafkaManager) Stop()
Stop causes the process for reconciling ready kafka requests to stop.
Source Files
Directories