scheduled

Documentation

Index

• func Factory(l logr.Logger, _ client.Client) gates.Gate
• type ScheduledGate
  • func New(l logr.Logger, opts ...func(*ScheduledGate)) *ScheduledGate
  • func (g ScheduledGate) Check(ctx context.Context, gate *deployerv1.KustomizationGate, ...) (bool, error)
  • func (g ScheduledGate) Interval(gate *deployerv1.KustomizationGate) (time.Duration, error)

Functions

func Factory

func Factory(l logr.Logger, _ client.Client) gates.Gate

Factory is a function for creating per-reconciliation gates for the ScheduledGate.

Types

type ScheduledGate

type ScheduledGate struct {
	Logger logr.Logger
	Clock  func() time.Time
}

ScheduledGate is open based on the current time.

func New

func New(l logr.Logger, opts ...func(*ScheduledGate)) *ScheduledGate

New creates and returns a new ScheduledGate.

func (ScheduledGate) Check

func (g ScheduledGate) Check(ctx context.Context, gate *deployerv1.KustomizationGate, _ *deployerv1.KustomizationAutoDeployer) (bool, error)

Check returns true if now is within the the Scheduled gate time duration.

func (ScheduledGate) Interval

func (g ScheduledGate) Interval(gate *deployerv1.KustomizationGate) (time.Duration, error)

Interval returns the time after which to requeue this check.