async

Documentation

Index

• type JobResult
• type ProcessResult
  • func (p *ProcessResult) GetErrors() (errs []error)
• type Processor

Types

type JobResult

type JobResult struct {
	Input  any
	Output any
	Err    error
}

JobResult is the result of a single job.

type ProcessResult

type ProcessResult struct {
	Results  []JobResult
	HasError bool
}

ProcessResult is the result of a list of jobs, the hasError flag indicates if any job has failed.

func (*ProcessResult) GetErrors

func (p *ProcessResult) GetErrors() (errs []error)

GetErrors return all errors from failed jobs, it uses HasError flag to minimize allocations on getting errors

type Processor

type Processor[I any, O any] interface {
	Process([]I) ProcessResult
	Close()
}

Processor is a generic interface to process asynchronously a list of inputs.