invoker

Documentation

Index

• func IsNoFallbackReconcilerDefinedError(err error) bool
• type Invoker
• type LocalReconcilerInvoker
  • func NewLocalReconcilerInvoker(reconRepo reconciliation.Repository, statusFunc ReconcilerStatusFunc, ...) *LocalReconcilerInvoker
  • func (i *LocalReconcilerInvoker) Invoke(ctx context.Context, params *Params) error
• type NoFallbackReconcilerDefinedError
  • func (err *NoFallbackReconcilerDefinedError) Error() string
• type Params
• type ReconcilerStatusFunc
• type RemoteReconcilerInvoker
  • func NewRemoteReconcilerInvoker(reconRepo reconciliation.Repository, cfg *config.Config, ...) *RemoteReconcilerInvoker
  • func (i *RemoteReconcilerInvoker) Invoke(_ context.Context, params *Params) error

Functions

func IsNoFallbackReconcilerDefinedError

func IsNoFallbackReconcilerDefinedError(err error) bool

Types

type Invoker

type Invoker interface {
	Invoke(ctx context.Context, params *Params) error
}

type LocalReconcilerInvoker

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

func NewLocalReconcilerInvoker

func NewLocalReconcilerInvoker(reconRepo reconciliation.Repository, statusFunc ReconcilerStatusFunc, logger *zap.SugaredLogger) *LocalReconcilerInvoker

func (*LocalReconcilerInvoker) Invoke

func (i *LocalReconcilerInvoker) Invoke(ctx context.Context, params *Params) error

type NoFallbackReconcilerDefinedError

type NoFallbackReconcilerDefinedError struct {
}

func (*NoFallbackReconcilerDefinedError) Error

func (err *NoFallbackReconcilerDefinedError) Error() string

type Params

type Params struct {
	ComponentToReconcile *keb.Component
	ComponentsReady      []string
	ClusterState         *cluster.State
	SchedulingID         string
	CorrelationID        string
	MaxOperationRetries  int
	Type                 model.OperationType
	Debug                bool
}

type ReconcilerStatusFunc

type ReconcilerStatusFunc func(component string, msg *reconciler.CallbackMessage)

ReconcilerStatusFunc can be passed by caller to retrieve status updates

type RemoteReconcilerInvoker

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

func NewRemoteReconcilerInvoker

func NewRemoteReconcilerInvoker(reconRepo reconciliation.Repository, cfg *config.Config, logger *zap.SugaredLogger) *RemoteReconcilerInvoker

func (*RemoteReconcilerInvoker) Invoke

func (i *RemoteReconcilerInvoker) Invoke(_ context.Context, params *Params) error