resolver

type Controller ¶

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

Controller implements the controller resolver controller. This controller responds to LoadControllerWithConfig directives.

func NewController(le *logrus.Entry, bus bus.Bus, resolver controller.FactoryResolver) *Controller

func (c *Controller) Close() error

func (c *Controller) Execute(ctx context.Context) error

func (c *Controller) GetControllerID() string

func (c *Controller) GetControllerInfo() *controller.Info

func (c *Controller) HandleDirective(ctx context.Context, di directive.Instance) ([]directive.Resolver, error)

type LoadConfigConstructorByID ¶

type LoadConfigConstructorByID interface {
	// Directive indicates this is a directive.
	directive.Directive

	// LoadConfigConstructorByIDConfigID is the configuration ID to use.
	LoadConfigConstructorByIDConfigID() string
}

LoadConfigConstructorByID loads a controller configuration object constructor given a configuration ID. This resolves the configuration ID to a configuration object, which may involve loading controller code. The directive should be held open until the constructor is no longer needed, and the underlying resources have been referenced as needed by controller directives.

Value type: config.Constructor

func NewLoadConfigConstructorByID(
	configID string,
) LoadConfigConstructorByID

type LoadConfigConstructorByIDResolver ¶

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

LoadConfigConstructorByIDResolver implements directive.Resolver for loading a controller configuration constructor with a config ID.

func (r *LoadConfigConstructorByIDResolver) Resolve(
	ctx context.Context,
	vh directive.ResolverHandler,
) error

type LoadConfigConstructorByIDValue ¶

type LoadConfigConstructorByIDValue = config.Constructor

LoadConfigConstructorByIDValue is the value type for LoadConfigConstructorByID.

type LoadControllerWithConfig ¶

type LoadControllerWithConfig interface {
	// Directive indicates this is a directive.
	directive.Directive

	// GetLoadControllerConfig returns the controller config to load.
	GetLoadControllerConfig() config.Config
	// GetExecControllerRetryBackoff returns the backoff to use for retries.
	// If empty / nil, uses the default.
	GetExecControllerRetryBackoff() func() backoff.BackOff
}

LoadControllerWithConfig is a directive indicating a controller should be loaded and executed (in one action) given a configuration.

func NewLoadControllerWithConfig(
	config config.Config,
) LoadControllerWithConfig

func NewLoadControllerWithConfigAndOpts(
	config config.Config,
	valueOpts directive.ValueOptions,
	execBackoff func() backoff.BackOff,
) LoadControllerWithConfig

type LoadControllerWithConfigValue ¶

type LoadControllerWithConfigValue = loader.ExecControllerValue

LoadControllerWithConfig is the value emitted to satisfy the LoadControllerWithConfig directive.

type LoadFactoryByConfig ¶

type LoadFactoryByConfig interface {
	// Directive indicates this is a directive.
	directive.Directive

	// LoadFactoryByConfig is the configuration to load a factory for.
	LoadFactoryByConfig() config.Config
}

LoadFactoryByConfig loads a controller factory given a configuration object. This resolves the configuration object to a controller constructor, which may involve loading controller code. The directive should be held open until the factory is no longer needed, and the underlying resources have been referenced as needed by controller directives.

func NewLoadFactoryByConfig(
	loadConfig config.Config,
) LoadFactoryByConfig

type LoadFactoryByConfigResolver ¶

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

LoadFactoryByConfigResolver implements directive.Resolver for loading a controller factory with a config object.

func (r *LoadFactoryByConfigResolver) Resolve(
	ctx context.Context,
	vh directive.ResolverHandler,
) error

type LoadFactoryByConfigValue ¶

type LoadFactoryByConfigValue = controller.Factory

LoadFactoryByConfigValue is the value type for LoadFactoryByConfig.