migagent

Documentation

Index

• type MigActuator
  • func NewActuator(client client.Client, migClient mig.Client, sharedState *SharedState, ...) MigActuator
  • func (a *MigActuator) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (a *MigActuator) SetupWithManager(mgr ctrl.Manager, controllerName string) error
• type MigReporter
  • func NewReporter(client client.Client, migClient mig.Client, sharedState *SharedState, ...) MigReporter
  • func (r *MigReporter) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MigReporter) SetupWithManager(mgr ctrl.Manager, controllerName string, nodeName string) error
• type SharedState
  • func NewSharedState() *SharedState
  • func (s *SharedState) AtLeastOneReportSinceLastApply() bool
  • func (s *SharedState) OnApplyDone()
  • func (s *SharedState) OnReportDone()

Types

type MigActuator

type MigActuator struct {
	client.Client
	// contains filtered or unexported fields
}

func NewActuator

func NewActuator(client client.Client, migClient mig.Client, sharedState *SharedState, nodeName string) MigActuator

func (*MigActuator) Reconcile

func (a *MigActuator) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MigActuator) SetupWithManager

func (a *MigActuator) SetupWithManager(mgr ctrl.Manager, controllerName string) error

type MigReporter

type MigReporter struct {
	client.Client
	// contains filtered or unexported fields
}

func NewReporter

func NewReporter(client client.Client, migClient mig.Client, sharedState *SharedState, refreshInterval time.Duration) MigReporter

func (*MigReporter) Reconcile

func (r *MigReporter) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*MigReporter) SetupWithManager

func (r *MigReporter) SetupWithManager(mgr ctrl.Manager, controllerName string, nodeName string) error

type SharedState

type SharedState struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SharedState contains the information shared between the Actuator and the Reporter processes

func NewSharedState

func NewSharedState() *SharedState

func (*SharedState) AtLeastOneReportSinceLastApply

func (s *SharedState) AtLeastOneReportSinceLastApply() bool

func (*SharedState) OnApplyDone

func (s *SharedState) OnApplyDone()

func (*SharedState) OnReportDone

func (s *SharedState) OnReportDone()