controller

Documentation

Index

• Constants
• type MetaPodRoleLabeler
  • func NewMetaPodRoleLabeler(client client.Client) *MetaPodRoleLabeler
  • func (mpl *MetaPodRoleLabeler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, e error)
  • func (mpl *MetaPodRoleLabeler) SetupWithManager(mgr ctrl.Manager) error
• type RisingWaveController
  • func NewRisingWaveController(client client.Client, recorder record.EventRecorder, ...) *RisingWaveController
  • func (c *RisingWaveController) Reconcile(ctx context.Context, request reconcile.Request) (res reconcile.Result, err error)
  • func (c *RisingWaveController) SetupWithManager(mgr ctrl.Manager) error
• type RisingWaveEventRecorder
  • func NewEventHook(recorder record.EventRecorder, mgr *object.RisingWaveManager, ...) *RisingWaveEventRecorder
  • func (h *RisingWaveEventRecorder) PostRun(ctx context.Context, logger logr.Logger, action string, ...)
  • func (h *RisingWaveEventRecorder) PreRun(ctx context.Context, logger logr.Logger, action string, ...)
• type RisingWaveScaleViewController
  • func NewRisingWaveScaleViewController(client client.Client) *RisingWaveScaleViewController
  • func (c *RisingWaveScaleViewController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (c *RisingWaveScaleViewController) SetupWithManager(mgr ctrl.Manager) error

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_SyncConnectorService                       = manager.RisingWaveAction_SyncConnectorService
	RisingWaveAction_SyncConnectorDeployments                   = manager.RisingWaveAction_SyncConnectorDeployments
	RisingWaveAction_SyncConnectorCloneSets                     = manager.RisingWaveAction_SyncConnectorCloneSets
	RisingWaveAction_WaitBeforeConnectorDeploymentsReady        = manager.RisingWaveAction_WaitBeforeConnectorDeploymentsReady
	RisingWaveAction_WaitBeforeConnectorCloneSetsReady          = manager.RisingWaveAction_WaitBeforeConnectorCloneSetsReady
	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.

Types

type MetaPodRoleLabeler

type MetaPodRoleLabeler struct {
	client.Client
}

MetaPodRoleLabeler reconciles meta pods object.

func NewMetaPodRoleLabeler

func NewMetaPodRoleLabeler(client client.Client) *MetaPodRoleLabeler

NewMetaPodRoleLabeler creates a new MetaPodRoleLabeler.

func (*MetaPodRoleLabeler) Reconcile

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

func (mpl *MetaPodRoleLabeler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the 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.

func (*RisingWaveEventRecorder) PostRun

func (h *RisingWaveEventRecorder) PostRun(ctx context.Context, logger logr.Logger, action string, result reconcile.Result, err error)

PostRun implements the ActionHook interface.

func (*RisingWaveEventRecorder) PreRun

func (h *RisingWaveEventRecorder) PreRun(ctx context.Context, logger logr.Logger, action string, states map[string]runtime.Object)

PreRun implements the ActionHook interface.

type RisingWaveScaleViewController

type RisingWaveScaleViewController struct {
	Client client.Client
}

RisingWaveScaleViewController is the controller for RisingWaveScaleView.

func NewRisingWaveScaleViewController

func NewRisingWaveScaleViewController(client client.Client) *RisingWaveScaleViewController

NewRisingWaveScaleViewController creates a new RisingWaveScaleViewController.

func (*RisingWaveScaleViewController) Reconcile

func (c *RisingWaveScaleViewController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile implements the reconcile.Reconciler.

func (*RisingWaveScaleViewController) SetupWithManager

func (c *RisingWaveScaleViewController) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with a given manager.