queue

Documentation

Index

• type ObservableType
• type Queue
  • func NewQueue(ctx context.Context, workers int, done chan ObservableType) Queue
• type WorkFunc

Types

type ObservableType

type ObservableType generic.Type // nolint

type Queue

type Queue interface {
	Enqueue(key string, work WorkFunc) error
}

Queue -

func NewQueue

func NewQueue(ctx context.Context, workers int, done chan ObservableType) Queue

NewQueue constructs a new queue

type WorkFunc

type WorkFunc func() (ObservableType, error)

WorkFunc defines work that must be completed