spread

Documentation

Index

• Constants
• type GenerateNextReconcileTimer
• type Spreader
  • func NewSpreader() *Spreader
  • func (s *Spreader) OnNextReconcile(instance runtimeobject.RuntimeObject, log *logger.Logger) (ctrl.Result, error)
  • func (s *Spreader) ReconcileRequired(instance runtimeobject.RuntimeObject, log *logger.Logger) bool
  • func (s *Spreader) RemoveRefreshLabelIfExists(instance runtimeobject.RuntimeObject) bool
  • func (s *Spreader) SetNextReconcileTime(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, log *logger.Logger)
  • func (s *Spreader) UpdateObservedGeneration(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, log *logger.Logger)

Constants

const ReconcileRefreshLabel = "platform-mesh.io/refresh-reconcile"

Types

type GenerateNextReconcileTimer

type GenerateNextReconcileTimer interface {
	GenerateNextReconcileTime() time.Duration
}

type Spreader

type Spreader struct {
}

func NewSpreader

func NewSpreader() *Spreader

func (*Spreader) OnNextReconcile

func (s *Spreader) OnNextReconcile(instance runtimeobject.RuntimeObject, log *logger.Logger) (ctrl.Result, error)

func (*Spreader) ReconcileRequired

func (s *Spreader) ReconcileRequired(instance runtimeobject.RuntimeObject, log *logger.Logger) bool

func (*Spreader) RemoveRefreshLabelIfExists

func (s *Spreader) RemoveRefreshLabelIfExists(instance runtimeobject.RuntimeObject) bool

func (*Spreader) SetNextReconcileTime

func (s *Spreader) SetNextReconcileTime(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, log *logger.Logger)

SetNextReconcileTime calculates and sets the next reconcile time for the instance

func (*Spreader) UpdateObservedGeneration

func (s *Spreader) UpdateObservedGeneration(instanceStatusObj api.RuntimeObjectSpreadReconcileStatus, log *logger.Logger)

UpdateObservedGeneration updates the observed generation of the instance struct