repeater

Documentation

Index

• type Checker
• type Config
• type LimitCountExceedError
  • func (e *LimitCountExceedError) Error() string
• type Worker
  • func (worker Worker) Run(inData interface{}, checker Checker, config Config) (interface{}, error)
• type WorkerResult

Types

type Checker

type Checker func(wr WorkerResult) (bool, error)

Проверка условия завершения

type Config

type Config struct {
	LimitCount int64
	Timeout    time.Duration
	// contains filtered or unexported fields
}

type LimitCountExceedError

type LimitCountExceedError struct {
}

func (*LimitCountExceedError) Error

func (e *LimitCountExceedError) Error() string

type Worker

type Worker func(data interface{}) WorkerResult

Выполняемая функция

func (Worker) Run

func (worker Worker) Run(inData interface{}, checker Checker, config Config) (interface{}, error)

type WorkerResult

type WorkerResult struct {
	OutData interface{}
	Err     error
}