object

Documentation

Index

• type RisingWaveManager
  • func NewRisingWaveManager(client client.Client, risingwave *risingwavev1alpha1.RisingWave, ...) *RisingWaveManager
  • func (mgr *RisingWaveManager) IsOpenKruiseAvailable() bool
  • func (mgr *RisingWaveManager) IsOpenKruiseEnabled() bool
  • func (mgr *RisingWaveManager) KeepLock(aliveScaleView []risingwavev1alpha1.RisingWaveScaleViewLock)
  • func (mgr *RisingWaveManager) RemoveCondition(conditionType risingwavev1alpha1.RisingWaveConditionType)
  • func (mgr *RisingWaveManager) RisingWaveAfterImage() *risingwavev1alpha1.RisingWave
  • func (mgr *RisingWaveManager) SyncObservedGeneration()
  • func (mgr *RisingWaveManager) UpdateCondition(condition risingwavev1alpha1.RisingWaveCondition)
  • func (mgr *RisingWaveManager) UpdateRemoteRisingWaveStatus(ctx context.Context) error
  • func (mgr *RisingWaveManager) UpdateStatus(f func(*risingwavev1alpha1.RisingWaveStatus))
• type RisingWaveReader
  • func NewRisingWaveReader(risingwave *risingwavev1alpha1.RisingWave) *RisingWaveReader
  • func (r *RisingWaveReader) DoesConditionExistAndEqual(conditionType risingwavev1alpha1.RisingWaveConditionType, value bool) bool
  • func (r *RisingWaveReader) GetCondition(conditionType risingwavev1alpha1.RisingWaveConditionType) *risingwavev1alpha1.RisingWaveCondition
  • func (r *RisingWaveReader) IsObservedGenerationOutdated() bool
  • func (r *RisingWaveReader) RisingWave() *risingwavev1alpha1.RisingWave
• type ScaleViewLockManager
  • func NewScaleViewLockManager(risingwave *risingwavev1alpha1.RisingWave) *ScaleViewLockManager
  • func (svl *ScaleViewLockManager) GetScaleViewLock(sv *risingwavev1alpha1.RisingWaveScaleView) *risingwavev1alpha1.RisingWaveScaleViewLock
  • func (svl *ScaleViewLockManager) GrabOrUpdateScaleViewLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) (bool, error)
  • func (svl *ScaleViewLockManager) GrabScaleViewLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) error
  • func (svl *ScaleViewLockManager) IsScaleViewLocked(sv *risingwavev1alpha1.RisingWaveScaleView) bool
  • func (svl *ScaleViewLockManager) ReleaseLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) bool

Types

type RisingWaveManager

type RisingWaveManager struct {
	RisingWaveReader
	// contains filtered or unexported fields
}

func NewRisingWaveManager

func NewRisingWaveManager(client client.Client, risingwave *risingwavev1alpha1.RisingWave, openkruiseAvailable bool) *RisingWaveManager

func (*RisingWaveManager) IsOpenKruiseAvailable

func (mgr *RisingWaveManager) IsOpenKruiseAvailable() bool

func (*RisingWaveManager) IsOpenKruiseEnabled

func (mgr *RisingWaveManager) IsOpenKruiseEnabled() bool

func (*RisingWaveManager) KeepLock

func (mgr *RisingWaveManager) KeepLock(aliveScaleView []risingwavev1alpha1.RisingWaveScaleViewLock)

func (*RisingWaveManager) RemoveCondition

func (mgr *RisingWaveManager) RemoveCondition(conditionType risingwavev1alpha1.RisingWaveConditionType)

func (*RisingWaveManager) RisingWaveAfterImage

func (mgr *RisingWaveManager) RisingWaveAfterImage() *risingwavev1alpha1.RisingWave

RisingWaveAfterImage returns a copy of the mutable RisingWave.

func (*RisingWaveManager) SyncObservedGeneration

func (mgr *RisingWaveManager) SyncObservedGeneration()

SyncObservedGeneration updates the observed generation to the current generation.

func (*RisingWaveManager) UpdateCondition

func (mgr *RisingWaveManager) UpdateCondition(condition risingwavev1alpha1.RisingWaveCondition)

func (*RisingWaveManager) UpdateRemoteRisingWaveStatus

func (mgr *RisingWaveManager) UpdateRemoteRisingWaveStatus(ctx context.Context) error

func (*RisingWaveManager) UpdateStatus

func (mgr *RisingWaveManager) UpdateStatus(f func(*risingwavev1alpha1.RisingWaveStatus))

type RisingWaveReader

type RisingWaveReader struct {
	// contains filtered or unexported fields
}

RisingWaveReader is a reader for RisingWave object.

func NewRisingWaveReader

func NewRisingWaveReader(risingwave *risingwavev1alpha1.RisingWave) *RisingWaveReader

NewRisingWaveReader creates a RisingWaveReader.

func (*RisingWaveReader) DoesConditionExistAndEqual

func (r *RisingWaveReader) DoesConditionExistAndEqual(conditionType risingwavev1alpha1.RisingWaveConditionType, value bool) bool

func (*RisingWaveReader) GetCondition

func (r *RisingWaveReader) GetCondition(conditionType risingwavev1alpha1.RisingWaveConditionType) *risingwavev1alpha1.RisingWaveCondition

func (*RisingWaveReader) IsObservedGenerationOutdated

func (r *RisingWaveReader) IsObservedGenerationOutdated() bool

IsObservedGenerationOutdated tells whether the observed generation is outdated.

func (*RisingWaveReader) RisingWave

func (r *RisingWaveReader) RisingWave() *risingwavev1alpha1.RisingWave

RisingWave returns the RisingWave immutable reference.

type ScaleViewLockManager

type ScaleViewLockManager struct {
	// contains filtered or unexported fields
}

func NewScaleViewLockManager

func NewScaleViewLockManager(risingwave *risingwavev1alpha1.RisingWave) *ScaleViewLockManager

func (*ScaleViewLockManager) GetScaleViewLock

func (svl *ScaleViewLockManager) GetScaleViewLock(sv *risingwavev1alpha1.RisingWaveScaleView) *risingwavev1alpha1.RisingWaveScaleViewLock

func (*ScaleViewLockManager) GrabOrUpdateScaleViewLockFor

func (svl *ScaleViewLockManager) GrabOrUpdateScaleViewLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) (bool, error)

func (*ScaleViewLockManager) GrabScaleViewLockFor

func (svl *ScaleViewLockManager) GrabScaleViewLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) error

func (*ScaleViewLockManager) IsScaleViewLocked

func (svl *ScaleViewLockManager) IsScaleViewLocked(sv *risingwavev1alpha1.RisingWaveScaleView) bool

func (*ScaleViewLockManager) ReleaseLockFor

func (svl *ScaleViewLockManager) ReleaseLockFor(sv *risingwavev1alpha1.RisingWaveScaleView) bool