worker

Documentation

Index

• Variables
• func NewStatusKVPublisher(s events.Stream, log *logrus.Logger, opts ...kv.Option) sm.Publisher
• type Worker
  • func New(facilityCode string, dryrun, useStatusKV, faultInjection bool, ...) *Worker
  • func (o *Worker) Run(ctx context.Context)

Variables

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

Functions

func NewStatusKVPublisher

func NewStatusKVPublisher(s events.Stream, log *logrus.Logger, opts ...kv.Option) sm.Publisher

Types

type Worker

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

Worker holds attributes for firmware install routines.

func New

func New(
	facilityCode string,
	dryrun,
	useStatusKV,
	faultInjection bool,
	concurrency,
	replicaCount int,
	stream events.Stream,
	repository store.Repository,
	logger *logrus.Logger,
) *Worker

NewOutofbandWorker returns a out of band firmware install worker instance

func (*Worker) Run

func (o *Worker) Run(ctx context.Context)

Run runs the firmware install worker which listens for events to action.