consequential

Documentation

Index

• type ConSequential
  • func NewConSequential(config *Config) (*ConSequential, error)
  • func (cs *ConSequential) Start() error
• type Config
• type FinishJob
• type RunJob

Types

type ConSequential

type ConSequential struct {
	*Config

	sync.RWMutex
	// contains filtered or unexported fields
}

ConSequential is short for CONcurrent SEQUENTIAL

func NewConSequential

func NewConSequential(config *Config) (*ConSequential, error)

NewConSequential creates a new ConSequential struct

func (*ConSequential) Start

func (cs *ConSequential) Start() error

Start starts workers concurrently

type Config

type Config struct {
	StartJobID          uint32
	EndJobID            uint32
	JobBufSize          uint32
	WorkerPoolSize      uint32
	MaxWorkerFails      uint32
	WorkerStartInterval time.Duration
	RunJob              RunJob
	FinishJob           FinishJob
}

Config is the ConSequential config.

type FinishJob

type FinishJob func(jobID uint32, result interface{}) (success bool)

FinishJob finish a job with job id, returns whether success

type RunJob

type RunJob func(workerID, jobID uint32) (result interface{}, success bool)

RunJob runs a job with job id, returns result and whether success