worker

Documentation

Index

• Variables
• func Run(ctx context.Context, dryrun, faultInjection bool, repository store.Repository, ...)
• type ConditionTaskHandler
  • func (h *ConditionTaskHandler) Handle(ctx context.Context, condition *rctypes.Condition, ...) error

Variables

var (
	ErrSaveTask          = errors.New("error in saveTask transition handler")
	ErrTaskTypeAssertion = errors.New("error asserting Task type")
)

Functions

func Run

func Run(
	ctx context.Context,
	dryrun,
	faultInjection bool,
	repository store.Repository,
	nc *controller.NatsController,
	logger *logrus.Logger,
)

NewOutofbandWorker returns a out of band firmware install worker instance

Types

type ConditionTaskHandler

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

func (*ConditionTaskHandler) Handle

func (h *ConditionTaskHandler) Handle(ctx context.Context, condition *rctypes.Condition, publisher controller.ConditionStatusPublisher) error

Handle implements the controller.ConditionHandler interface