qgroup

package module

v0.0.0-...-adf9f55 Latest Latest Go to latest Published: Jan 22, 2017 License: GPL-3.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Func struct {
	// contains filtered or unexported fields
}

Func has func(context.Context) and context. The context uses with DoWithContext().

type QGroup struct {
	// contains filtered or unexported fields
}

QGroup represents function calling queues and settings

func NewGroup(opts ...QGroupOption) *QGroup

NewGroup returnes QGroup struct is configured with QGroupOptions

func (g *QGroup) Cancel() error

Cancel can cancel all queue calling tasks

func (g *QGroup) Do(key string, fn func(context.Context)) error

Do enqueues the given function in a queue with key name If a queue of the key doesn't exists,Do makes a new queue with key name

func (g *QGroup) DoWithContext(key string, ctx context.Context, fn func(context.Context)) error

DoWithContext the given function and the given ctx in q queue with key name

type QGroupOption func(g *QGroup)

A QGroupOption is a functional option type for QGroup

func WithMaxQueue(maxQueue int) QGroupOption

WithMaxQueue configures max number of queue items. Default is 0.

func WithTimeout(d time.Duration) QGroupOption

WithTimeout configures function call timeout. if a function reaches the timeout, ctx in the function returns a channel.