Documentation ¶
Index ¶
Constants ¶
const ( RisingWaveAction_SyncMetaService = manager.RisingWaveAction_SyncMetaService RisingWaveAction_SyncMetaStatefulSets = manager.RisingWaveAction_SyncMetaStatefulSets RisingWaveAction_SyncMetaAdvancedStatefulSets = manager.RisingWaveAction_SyncMetaAdvancedStatefulSets RisingWaveAction_WaitBeforeMetaServiceIsAvailable = manager.RisingWaveAction_WaitBeforeMetaServiceIsAvailable RisingWaveAction_WaitBeforeMetaStatefulSetsReady = manager.RisingWaveAction_WaitBeforeMetaStatefulSetsReady RisingWaveAction_WaitBeforeMetaAdvancedStatefulSetsReady = manager.RisingWaveAction_WaitBeforeMetaAdvancedStatefulSetsReady RisingWaveAction_SyncFrontendService = manager.RisingWaveAction_SyncFrontendService RisingWaveAction_SyncFrontendDeployments = manager.RisingWaveAction_SyncFrontendDeployments RisingWaveAction_SyncFrontendCloneSets = manager.RisingWaveAction_SyncFrontendCloneSets RisingWaveAction_WaitBeforeFrontendDeploymentsReady = manager.RisingWaveAction_WaitBeforeFrontendDeploymentsReady RisingWaveAction_WaitBeforeFrontendCloneSetsReady = manager.RisingWaveAction_WaitBeforeFrontendCloneSetsReady RisingWaveAction_SyncComputeService = manager.RisingWaveAction_SyncComputeService RisingWaveAction_SyncComputeStatefulSets = manager.RisingWaveAction_SyncComputeStatefulSets RisingWaveAction_SyncComputeAdvancedStatefulSets = manager.RisingWaveAction_SyncComputeAdvancedStatefulSets RisingWaveAction_WaitBeforeComputeStatefulSetsReady = manager.RisingWaveAction_WaitBeforeComputeStatefulSetsReady RisingWaveAction_WaitBeforeComputeAdvancedStatefulSetsReady = manager.RisingWaveAction_WaitBeforeComputeAdvancedStatefulSetsReady RisingWaveAction_SyncCompactorService = manager.RisingWaveAction_SyncCompactorService RisingWaveAction_SyncCompactorDeployments = manager.RisingWaveAction_SyncCompactorDeployments RisingWaveAction_SyncCompactorCloneSets = manager.RisingWaveAction_SyncCompactorCloneSets RisingWaveAction_WaitBeforeCompactorDeploymentsReady = manager.RisingWaveAction_WaitBeforeCompactorDeploymentsReady RisingWaveAction_WaitBeforeCompactorCloneSetsReady = manager.RisingWaveAction_WaitBeforeCompactorCloneSetsReady RisingWaveAction_SyncConfigConfigMap = manager.RisingWaveAction_SyncConfigConfigMap RisingWaveAction_CollectRunningStatisticsAndSyncStatus = manager.RisingWaveAction_CollectRunningStatisticsAndSyncStatus RisingWaveAction_SyncServiceMonitor = manager.RisingWaveAction_SyncServiceMonitor )
Pre-defined actions. Import from manager package.
const ( RisingWaveAction_UpdateRisingWaveStatusViaClient = "UpdateRisingWaveStatusViaClient" RisingWaveAction_BarrierFirstTimeObserved = "BarrierFirstTimeObserved" RisingWaveAction_MarkConditionInitializingAsTrue = "MarkConditionInitializingAsTrue" RisingWaveAction_MarkConditionRunningAsFalse = "MarkConditionRunningAsFalse" RisingWaveAction_BarrierConditionInitializingIsTrue = "BarrierConditionInitializingIsTrue" RisingWaveAction_MarkConditionRunningAsTrue = "MarkConditionRunningAsTrue" RisingWaveAction_RemoveConditionInitializing = "RemoveConditionInitializing" RisingWaveAction_BarrierConditionRunningIsTrue = "BarrierConditionRunningIsTrue" RisingWaveAction_BarrierConditionRunningIsFalse = "BarrierConditionRunningIsFalse" RisingWaveAction_MarkConditionUpgradingAsTrue = "MarkConditionUpgradingAsTrue" RisingWaveAction_BarrierConditionUpgradingIsTrue = "BarrierConditionUpgradingIsTrue" RisingWaveAction_MarkConditionUpgradingAsFalse = "MarkConditionUpgradingAsFalse" RisingWaveAction_BarrierObservedGenerationOutdated = "BarrierObservedGenerationOutdated" RisingWaveAction_SyncObservedGeneration = "SyncObservedGeneration" RisingWaveAction_BarrierPrometheusCRDsInstalled = "BarrierPrometheusCRDsInstalled" RisingWaveAction_ReleaseScaleViewLock = "ReleaseScaleViewLock" )
Actions defined in controller.
const ( RisingWaveScaleViewSyncLockRetryLimit = 2 RisingWaveScaleViewSyncLockRetryInterval = 5 * time.Millisecond )
RisingWaveScaleView controller related constants.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetaPodRoleLabeler ¶ added in v0.2.6
MetaPodRoleLabeler reconciles meta pods object.
func NewMetaPodRoleLabeler ¶ added in v0.2.6
func NewMetaPodRoleLabeler(client client.Client) *MetaPodRoleLabeler
NewMetaPodRoleLabeler creates a new MetaPodRoleLabeler.
func (*MetaPodRoleLabeler) Reconcile ¶ added in v0.2.6
func (mpl *MetaPodRoleLabeler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, e error)
Reconcile handles the pods of the meta service. Will add the metaLeaderLabel to the pods.
func (*MetaPodRoleLabeler) SetupWithManager ¶ added in v0.2.6
func (mpl *MetaPodRoleLabeler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type RisingWaveComputeSTSUpdateStrategy ¶ added in v0.5.4
type RisingWaveComputeSTSUpdateStrategy struct {
// contains filtered or unexported fields
}
RisingWaveComputeSTSUpdateStrategy implements an optimized update strategy for the StatefulSets that controls the compute nodes.
func NewRisingWaveComputeSTSUpdateStrategy ¶ added in v0.5.4
func NewRisingWaveComputeSTSUpdateStrategy(client client.Client) *RisingWaveComputeSTSUpdateStrategy
NewRisingWaveComputeSTSUpdateStrategy creates a new RisingWaveComputeSTSUpdateStrategy.
func (*RisingWaveComputeSTSUpdateStrategy) Reconcile ¶ added in v0.5.4
func (s *RisingWaveComputeSTSUpdateStrategy) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile implements reconcile.Reconciler.
func (*RisingWaveComputeSTSUpdateStrategy) SetupWithManager ¶ added in v0.5.4
func (s *RisingWaveComputeSTSUpdateStrategy) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager registers itself with the given manager.
type RisingWaveController ¶
type RisingWaveController struct { Client client.Client Recorder record.EventRecorder ActionHookFactory func() ctrlkit.ActionHook // contains filtered or unexported fields }
RisingWaveController is the controller for RisingWave.
func NewRisingWaveController ¶
func NewRisingWaveController(client client.Client, recorder record.EventRecorder, openKruiseAvailable, forceUpdateEnabled bool, operatorVersion string) *RisingWaveController
NewRisingWaveController creates a new RisingWaveController.
func (*RisingWaveController) Reconcile ¶
func (c *RisingWaveController) Reconcile(ctx context.Context, request reconcile.Request) (res reconcile.Result, err error)
Reconcile reconciles a request and also adds metrics information to prometheus.
func (*RisingWaveController) SetupWithManager ¶
func (c *RisingWaveController) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with a given manager.
type RisingWaveEventRecorder ¶
type RisingWaveEventRecorder struct {
// contains filtered or unexported fields
}
RisingWaveEventRecorder is an action hook for recording events.
func NewEventHook ¶
func NewEventHook(recorder record.EventRecorder, mgr *object.RisingWaveManager, msgStore *event.MessageStore) *RisingWaveEventRecorder
NewEventHook creates an event hook for the given risingwave.
type RisingWaveScaleViewController ¶ added in v0.2.2
RisingWaveScaleViewController is the controller for RisingWaveScaleView.
func NewRisingWaveScaleViewController ¶ added in v0.2.2
func NewRisingWaveScaleViewController(client client.Client) *RisingWaveScaleViewController
NewRisingWaveScaleViewController creates a new RisingWaveScaleViewController.
func (*RisingWaveScaleViewController) Reconcile ¶ added in v0.2.2
func (c *RisingWaveScaleViewController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
Reconcile implements the reconcile.Reconciler.
func (*RisingWaveScaleViewController) SetupWithManager ¶ added in v0.2.2
func (c *RisingWaveScaleViewController) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with a given manager.