worker

Documentation

Index

• type BatchOptions
  • func (b *BatchOptions) GetItem() (string, error)
• type RequestHandler
• type Worker
  • func NewWorker(log *logger.Logger, cfg *config.Config, iostream *iostreams.IOStreams, ...) (*Worker, error)
  • func (w *Worker) GetMaxJobs() int64
  • func (w *Worker) GetMaxWorkers() int
  • func (w *Worker) ProcessRequestAndResponse(cmd *cobra.Command, r *c8y.RequestOptions, ...) error

Types

type BatchOptions

type BatchOptions struct {
	StartIndex        int
	NumJobs           int
	TotalWorkers      int
	Delay             time.Duration
	DelayBefore       time.Duration
	AbortOnErrorCount int
	SemanticMethod    string

	PostActions []flags.Action

	InputData []string
	// contains filtered or unexported fields
}

func (*BatchOptions) GetItem

func (b *BatchOptions) GetItem() (string, error)

type RequestHandler

type RequestHandler func(requests []c8y.RequestOptions, input any, commonOptions config.CommonCommandOptions) (*c8y.Response, error)

type Worker

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

func NewWorker

func NewWorker(log *logger.Logger, cfg *config.Config, iostream *iostreams.IOStreams, client *c8y.Client, activityLog *activitylogger.ActivityLogger, reqHandlerFunc RequestHandler, checkError func(error) error) (*Worker, error)

func (*Worker) GetMaxJobs

func (w *Worker) GetMaxJobs() int64

GetMaxJob maximum number of jobs allowed

func (*Worker) GetMaxWorkers

func (w *Worker) GetMaxWorkers() int

GetMaxWorkers maximum number of workers

func (*Worker) ProcessRequestAndResponse

func (w *Worker) ProcessRequestAndResponse(cmd *cobra.Command, r *c8y.RequestOptions, inputIterators *flags.RequestInputIterators) error