worker

Documentation

Index

• type FormattedError
• type ProcessStarted
• type TaskEnded
• type TaskStarted
• type WorkerPool
  • func NewWorkerPool(workersCount uint32) *WorkerPool
  • func (p *WorkerPool) LoadProcessors() error
  • func (p *WorkerPool) Wait()
  • func (p *WorkerPool) Work(tStart <-chan TaskStarted, tEnd chan<- TaskEnded, splunk *core.Splunkargs, ...)

Types

type FormattedError

type FormattedError struct {
	Error     string
	Processor string
}

type ProcessStarted

type ProcessStarted struct {
	Name            string
	ProcessId       string
	TasksCount      int
	TasksTerminated int
}

type TaskEnded

type TaskEnded struct {
	Name      string
	Source    string
	ProcessId string
	Errors    []string
}

type TaskStarted

type TaskStarted struct {
	ProcessId     string
	Tag           string
	Step          dsl.Step
	ProcessConfig dsl.ProcessConfig
	OutputFolder  string
}

type WorkerPool

type WorkerPool struct {
	// PoolSize int
	// Workers []Worker
	Capacity uint32
	// contains filtered or unexported fields
}

func NewWorkerPool

func NewWorkerPool(workersCount uint32) *WorkerPool

func (*WorkerPool) LoadProcessors

func (p *WorkerPool) LoadProcessors() error

func (*WorkerPool) Wait

func (p *WorkerPool) Wait()

func (*WorkerPool) Work

func (p *WorkerPool) Work(tStart <-chan TaskStarted, tEnd chan<- TaskEnded, splunk *core.Splunkargs, outputFolder string)