controller

package
v0.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
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.

View Source 
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.

View Source 
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 

type MetaPodRoleLabeler struct {
	client.Client
}

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.

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 added in v0.2.2 

type RisingWaveScaleViewController struct {
	Client client.Client
}

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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.