statemachine

Documentation

Index

• func Run(ctx context.Context, r ReplicationMachine, l logr.Logger) (ctrl.Result, error)
• type ReplicationMachine

Functions

func Run

func Run(ctx context.Context, r ReplicationMachine, l logr.Logger) (ctrl.Result, error)

Run the state machine to reconcile the ReplicationController

Types

type ReplicationMachine

type ReplicationMachine interface {
	Cronspec() string
	ManualTag() string
	LastManualTag() string
	SetLastManualTag(string)

	NextSyncTime() *metav1.Time
	SetNextSyncTime(*metav1.Time)

	LastSyncStartTime() *metav1.Time
	SetLastSyncStartTime(*metav1.Time)

	LastSyncTime() *metav1.Time
	SetLastSyncTime(*metav1.Time)

	LastSyncDuration() *metav1.Duration
	SetLastSyncDuration(*metav1.Duration)

	Conditions() *[]metav1.Condition

	SetOutOfSync(bool)
	IncMissedIntervals()
	ObserveSyncDuration(time.Duration)

	Synchronize(ctx context.Context) (mover.Result, error)
	Cleanup(ctx context.Context) (mover.Result, error)
}

ReplicationMachine is a common interface to the ReplicationSource and ReplicationDestination types that allow us to generically implement the synchronization state machine.