addoninstance

Documentation

Index

• type AddonInstanceClient
• type AddonInstanceClientImpl
  • func NewAddonInstanceClient(client client.Client) *AddonInstanceClientImpl
  • func (c *AddonInstanceClientImpl) Get(ctx context.Context, name, namespace string) (*av1alpha1.AddonInstance, error)
  • func (c *AddonInstanceClientImpl) UpdateStatus(ctx context.Context, instance *av1alpha1.AddonInstance) error
• type Clock
• type Controller
  • func NewController(c client.Client, opts ...ControllerOption) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Controller) SetupWithManager(mgr ctrl.Manager) error
• type ControllerConfig
  • func (c *ControllerConfig) Default()
  • func (c *ControllerConfig) Option(opts ...ControllerOption)
• type ControllerOption
• type DefaultClock
  • func NewDefaultClock() DefaultClock
  • func (c DefaultClock) Now() time.Time
• type Phase
• type PhaseCheckHeartbeat
  • func NewPhaseCheckHeartbeat(opts ...PhaseCheckHeartbeatOption) *PhaseCheckHeartbeat
  • func (c *PhaseCheckHeartbeat) Execute(ctx context.Context, req phase.Request) phase.Result
  • func (p *PhaseCheckHeartbeat) String() string
• type PhaseCheckHeartbeatConfig
  • func (c *PhaseCheckHeartbeatConfig) Default()
  • func (c *PhaseCheckHeartbeatConfig) Option(opts ...PhaseCheckHeartbeatOption)
• type PhaseCheckHeartbeatOption
• type WithClock
  • func (w WithClock) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)
• type WithLog
  • func (w WithLog) ConfigureController(c *ControllerConfig)
  • func (w WithLog) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)
• type WithPollingInterval
  • func (w WithPollingInterval) ConfigureController(c *ControllerConfig)
• type WithSerialPhases
  • func (w WithSerialPhases) ConfigureController(c *ControllerConfig)
• type WithThresholdMultiplier
  • func (w WithThresholdMultiplier) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)

Types

type AddonInstanceClient

type AddonInstanceClient interface {
	Get(ctx context.Context, name, namespace string) (*av1alpha1.AddonInstance, error)
	UpdateStatus(ctx context.Context, instance *av1alpha1.AddonInstance) error
}

type AddonInstanceClientImpl

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

func NewAddonInstanceClient

func NewAddonInstanceClient(client client.Client) *AddonInstanceClientImpl

func (*AddonInstanceClientImpl) Get

func (c *AddonInstanceClientImpl) Get(ctx context.Context, name, namespace string) (*av1alpha1.AddonInstance, error)

func (*AddonInstanceClientImpl) UpdateStatus

func (c *AddonInstanceClientImpl) UpdateStatus(ctx context.Context, instance *av1alpha1.AddonInstance) error

type Clock

type Clock interface {
	Now() time.Time
}

type Controller

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

func NewController

func NewController(c client.Client, opts ...ControllerOption) *Controller

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Controller) SetupWithManager

func (r *Controller) SetupWithManager(mgr ctrl.Manager) error

type ControllerConfig

type ControllerConfig struct {
	Log             logr.Logger
	PollingInterval time.Duration
	SerialPhases    []Phase
}

func (*ControllerConfig) Default

func (c *ControllerConfig) Default()

func (*ControllerConfig) Option

func (c *ControllerConfig) Option(opts ...ControllerOption)

type ControllerOption

type ControllerOption interface {
	ConfigureController(c *ControllerConfig)
}

type DefaultClock

type DefaultClock struct{}

func NewDefaultClock

func NewDefaultClock() DefaultClock

func (DefaultClock) Now

func (c DefaultClock) Now() time.Time

type Phase

type Phase interface {
	Execute(ctx context.Context, req phase.Request) phase.Result
	fmt.Stringer
}

type PhaseCheckHeartbeat

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

func NewPhaseCheckHeartbeat

func NewPhaseCheckHeartbeat(opts ...PhaseCheckHeartbeatOption) *PhaseCheckHeartbeat

func (*PhaseCheckHeartbeat) Execute

func (c *PhaseCheckHeartbeat) Execute(ctx context.Context, req phase.Request) phase.Result

func (*PhaseCheckHeartbeat) String

func (p *PhaseCheckHeartbeat) String() string

type PhaseCheckHeartbeatConfig

type PhaseCheckHeartbeatConfig struct {
	Log                 logr.Logger
	Clock               Clock
	ThresholdMultiplier int64
}

func (*PhaseCheckHeartbeatConfig) Default

func (c *PhaseCheckHeartbeatConfig) Default()

func (*PhaseCheckHeartbeatConfig) Option

func (c *PhaseCheckHeartbeatConfig) Option(opts ...PhaseCheckHeartbeatOption)

type PhaseCheckHeartbeatOption

type PhaseCheckHeartbeatOption interface {
	ConfigurePhaseCheckHeartbeat(*PhaseCheckHeartbeatConfig)
}

type WithClock

type WithClock struct{ Clock Clock }

func (WithClock) ConfigurePhaseCheckHeartbeat

func (w WithClock) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)

type WithLog

type WithLog struct{ Log logr.Logger }

func (WithLog) ConfigureController

func (w WithLog) ConfigureController(c *ControllerConfig)

func (WithLog) ConfigurePhaseCheckHeartbeat

func (w WithLog) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)

type WithPollingInterval

type WithPollingInterval time.Duration

func (WithPollingInterval) ConfigureController

func (w WithPollingInterval) ConfigureController(c *ControllerConfig)

type WithSerialPhases

type WithSerialPhases []Phase

func (WithSerialPhases) ConfigureController

func (w WithSerialPhases) ConfigureController(c *ControllerConfig)

type WithThresholdMultiplier

type WithThresholdMultiplier int64

func (WithThresholdMultiplier) ConfigurePhaseCheckHeartbeat

func (w WithThresholdMultiplier) ConfigurePhaseCheckHeartbeat(c *PhaseCheckHeartbeatConfig)