task

Documentation

Index

• type Element
• type Queue
  • func NewCustomTaskQueue(syncFn func(interface{}) error, fn func(interface{}) (interface{}, error)) *Queue
  • func NewTaskQueue(syncFn func(interface{}) error) *Queue
  • func (t *Queue) Enqueue(obj interface{})
  • func (t *Queue) IsShuttingDown() bool
  • func (t *Queue) Run(period time.Duration, stopCh <-chan struct{})
  • func (t *Queue) Shutdown()

Types

type Element

type Element struct {
	Key       interface{}
	Timestamp int64
}

Element represents one item of the queue

type Queue

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

Queue manages a time work queue through an independent worker that invokes the given sync function for every work item inserted. The queue uses an internal timestamp that allows the removal of certain elements which timestamp is older than the last successful get operation.

func NewCustomTaskQueue

func NewCustomTaskQueue(syncFn func(interface{}) error, fn func(interface{}) (interface{}, error)) *Queue

NewCustomTaskQueue ...

func NewTaskQueue

func NewTaskQueue(syncFn func(interface{}) error) *Queue

NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.

func (*Queue) Enqueue

func (t *Queue) Enqueue(obj interface{})

Enqueue enqueues ns/name of the given api object in the task queue.

func (*Queue) IsShuttingDown

func (t *Queue) IsShuttingDown() bool

IsShuttingDown returns if the method Shutdown was invoked

func (*Queue) Run

func (t *Queue) Run(period time.Duration, stopCh <-chan struct{})

Run ...

func (*Queue) Shutdown

func (t *Queue) Shutdown()

Shutdown shuts down the work queue and waits for the worker to ACK