The highest tagged major version is v2.

consequential

package

v1.0.0-rc2 Latest Latest Go to latest Published: Jun 30, 2019 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/nknorg/nkn

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

consequential.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL