workerhandler

Documentation

Index

• type Config
• type Handler
  • func New(c Config) *Handler
  • func (h *Handler) Hand() []Interface
• type Interface

Types

type Config

type Config struct {
	Con contract.Interface
	Emi emitter.Interface
	Env envvar.Env
	Loc locker.Interface
	Log logger.Interface
	Rec reconciler.Interface
	Sam *sample.Sample
	Sto storage.Interface
}

type Handler

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

func New

func New(c Config) *Handler

func (*Handler) Hand

func (h *Handler) Hand() []Interface

type Interface

type Interface interface {
	// Create provides a task template that should be created upon process
	// initiation. The task template should describe scheduled tasks that this
	// handler is going to process. If the handler does not want to bootstrap any
	// task template, nil is returned.
	Create() *task.Task
	// Ensure executes the handler specific business logic in order to complete
	// the given task, if possible.
	Ensure(*task.Task) error
	// Filter expresses whether the handler wants to process the given task.
	Filter(*task.Task) bool
}