worker

Documentation

Index

• func ExecuteFeed(connectionConfig module.ConnectionConfig, config defaults.ConfigPattern, ...) []error
• func ExecuteSteps(prefix string, steps []*module.Step, selectedHostGroup *defaults.HostGroups, ...) []error
• type ErrorHandler
  • func (handler *ErrorHandler) GetAll() []ErrorItem
  • func (handler *ErrorHandler) HandleError(uuid string, e error)
  • func (handler *ErrorHandler) Reset()
• type ErrorItem

Functions

func ExecuteFeed

func ExecuteFeed(connectionConfig module.ConnectionConfig, config defaults.ConfigPattern, feed *module.FeedExec, sessionsMap map[string]module.Session, logger log.Logger) []error

Execute Feed, after definition of per Session and Host Client components

func ExecuteSteps

func ExecuteSteps(prefix string, steps []*module.Step,
	selectedHostGroup *defaults.HostGroups, threadPool pool.ThreadPool,
	errorsHandler *ErrorHandler, config defaults.ConfigPattern,
	sessionsMap map[string]module.Session, logger log.Logger,
	connectionConfig module.ConnectionConfig) []error

Execute module.Step pointers list, recovering definition of per Session and Host Client components

Types

type ErrorHandler

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

func (*ErrorHandler) GetAll

func (handler *ErrorHandler) GetAll() []ErrorItem

func (*ErrorHandler) HandleError

func (handler *ErrorHandler) HandleError(uuid string, e error)

func (*ErrorHandler) Reset

func (handler *ErrorHandler) Reset()

type ErrorItem

type ErrorItem struct {
	UUID  string
	Error error
}