Documentation
¶
Index ¶
- type CleanupClustersManager
- type ClusterManager
- func (c *ClusterManager) GetID() string
- func (c *ClusterManager) GetStopChan() *chan struct{}
- func (c *ClusterManager) GetSyncGroup() *sync.WaitGroup
- func (c *ClusterManager) GetWorkerType() string
- func (c *ClusterManager) HasTerminated() bool
- func (c *ClusterManager) IsRunning() bool
- func (c *ClusterManager) Reconcile() []error
- func (c *ClusterManager) SetIsRunning(val bool)
- func (c *ClusterManager) Start()
- func (c *ClusterManager) Stop()
- type ClusterManagerOptions
- type DeprovisioningClustersManager
- type DynamicScaleDownManager
- type DynamicScaleUpManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CleanupClustersManager ¶
type CleanupClustersManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
CleanupClustersManager represents a worker that periodically reconciles data plane clusters in cleanup state.
func NewCleanupClustersManager ¶
func NewCleanupClustersManager(reconciler workers.Reconciler, clusterService services.ClusterService, kasFleetshardOperatorAddon services.KasFleetshardOperatorAddon, osdIDPKeycloakService sso.OsdKeycloakService, dataplaneClusterConfig *config.DataplaneClusterConfig) *CleanupClustersManager
NewCleanupClustersManager creates a new worker that reconciles data plane clusters in cleanup state.
func (*CleanupClustersManager) Reconcile ¶
func (m *CleanupClustersManager) Reconcile() []error
func (*CleanupClustersManager) Start ¶
func (m *CleanupClustersManager) Start()
Start initializes the worker to reconcile data plane clusters in cleanup state.
func (*CleanupClustersManager) Stop ¶
func (m *CleanupClustersManager) Stop()
Stop causes the process for reconciling data plane clusters in cleanup state to stop.
type ClusterManager ¶
type ClusterManager struct {
ClusterManagerOptions
// contains filtered or unexported fields
}
func NewClusterManager ¶
func NewClusterManager(o ClusterManagerOptions) *ClusterManager
NewClusterManager creates a new cluster manager.
func (*ClusterManager) GetID ¶
func (c *ClusterManager) GetID() string
GetID returns the ID that represents this worker.
func (*ClusterManager) GetStopChan ¶
func (c *ClusterManager) GetStopChan() *chan struct{}
func (*ClusterManager) GetSyncGroup ¶
func (c *ClusterManager) GetSyncGroup() *sync.WaitGroup
func (*ClusterManager) GetWorkerType ¶
func (c *ClusterManager) GetWorkerType() string
func (*ClusterManager) HasTerminated ¶
func (c *ClusterManager) HasTerminated() bool
func (*ClusterManager) IsRunning ¶
func (c *ClusterManager) IsRunning() bool
func (*ClusterManager) Reconcile ¶
func (c *ClusterManager) Reconcile() []error
func (*ClusterManager) SetIsRunning ¶
func (c *ClusterManager) SetIsRunning(val bool)
func (*ClusterManager) Start ¶
func (c *ClusterManager) Start()
Start initializes the cluster manager to reconcile osd clusters.
func (*ClusterManager) Stop ¶
func (c *ClusterManager) Stop()
Stop causes the process for reconciling osd clusters to stop.
type ClusterManagerOptions ¶
type ClusterManagerOptions struct {
di.Inject
Reconciler workers.Reconciler
OCMConfig *ocm.OCMConfig
ObservabilityConfiguration *observatorium.ObservabilityConfiguration
DataplaneClusterConfig *config.DataplaneClusterConfig
SupportedProviders *config.ProviderConfig
ClusterService services.ClusterService
CloudProvidersService services.CloudProvidersService
KasFleetshardOperatorAddon services.KasFleetshardOperatorAddon
SsoService sso.KafkaKeycloakService
OsdIdpKeycloakService sso.OsdKeycloakService
ProviderFactory clusters.ProviderFactory
}
type DeprovisioningClustersManager ¶
type DeprovisioningClustersManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
DeprovisioningClustersManager represents a cluster manager that periodically reconciles data plane clusters in deprovisioning state.
func NewDeprovisioningClustersManager ¶
func NewDeprovisioningClustersManager(reconciler workers.Reconciler, clusterService services.ClusterService) *DeprovisioningClustersManager
NewDeprovisioningClustersManager creates a new cluster manager to reconcile data plane clusters in deprovisioning state.
func (*DeprovisioningClustersManager) Reconcile ¶
func (m *DeprovisioningClustersManager) Reconcile() []error
func (*DeprovisioningClustersManager) Start ¶
func (m *DeprovisioningClustersManager) Start()
Start initializes the cluster manager to reconcile data plane clusters in deprovisioning state.
func (*DeprovisioningClustersManager) Stop ¶
func (m *DeprovisioningClustersManager) Stop()
Stop causes the process for reconciling data plane clusters in deprovisioning state to stop.
type DynamicScaleDownManager ¶
type DynamicScaleDownManager struct {
workers.BaseWorker
// contains filtered or unexported fields
}
func NewDynamicScaleDownManager ¶
func NewDynamicScaleDownManager( reconciler workers.Reconciler, dataplaneClusterConfig *config.DataplaneClusterConfig, clusterProvidersConfig *config.ProviderConfig, kafkaConfig *config.KafkaConfig, clusterService services.ClusterService, ) *DynamicScaleDownManager
func (*DynamicScaleDownManager) Reconcile ¶
func (m *DynamicScaleDownManager) Reconcile() []error
func (*DynamicScaleDownManager) Start ¶
func (m *DynamicScaleDownManager) Start()
func (*DynamicScaleDownManager) Stop ¶
func (m *DynamicScaleDownManager) Stop()
type DynamicScaleUpManager ¶
type DynamicScaleUpManager struct {
workers.BaseWorker
DataplaneClusterConfig *config.DataplaneClusterConfig
ClusterProvidersConfig *config.ProviderConfig
KafkaConfig *config.KafkaConfig
ClusterService services.ClusterService
}
func NewDynamicScaleUpManager ¶
func NewDynamicScaleUpManager( reconciler workers.Reconciler, dataplaneClusterConfig *config.DataplaneClusterConfig, clusterProvidersConfig *config.ProviderConfig, kafkaConfig *config.KafkaConfig, clusterService services.ClusterService, ) *DynamicScaleUpManager
func (*DynamicScaleUpManager) Reconcile ¶
func (m *DynamicScaleUpManager) Reconcile() []error
func (*DynamicScaleUpManager) Start ¶
func (m *DynamicScaleUpManager) Start()
func (*DynamicScaleUpManager) Stop ¶
func (m *DynamicScaleUpManager) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.