tasks

Documentation

Index

• Variables
• type ExeOption
  • func ExecutorWithGoroutinesCount(count int) ExeOption
  • func ExecutorWithInitialTimeout(initialTimeout time.Duration) ExeOption
• type PeriodicExecutor
  • func NewPeriodicExecutor(timeout time.Duration, opts ...ExeOption) *PeriodicExecutor
  • func (pe *PeriodicExecutor) SetSchedulerTimeout(duration time.Duration) *PeriodicExecutor
  • func (pe *PeriodicExecutor) StartTask(function func() bool) *PeriodicExecutor
  • func (pe *PeriodicExecutor) StopTask()
• type Queue
  • func NewInMemoryQueue(concurrentConsumers, queueSize int) *Queue
  • func (q *Queue) Close()
  • func (q *Queue) Offer(value interface{})
  • func (q *Queue) StartConsuming(f func(value interface{}))
  • func (q *Queue) Take() (interface{}, bool)

Variables

var (
	ErrAlreadyStopped = errors.New("task already has stopped")
)

Types

type ExeOption

type ExeOption func(exe *PeriodicExecutor)

func ExecutorWithGoroutinesCount

func ExecutorWithGoroutinesCount(count int) ExeOption

func ExecutorWithInitialTimeout

func ExecutorWithInitialTimeout(initialTimeout time.Duration) ExeOption

type PeriodicExecutor

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

func NewPeriodicExecutor

func NewPeriodicExecutor(timeout time.Duration, opts ...ExeOption) *PeriodicExecutor

func (*PeriodicExecutor) SetSchedulerTimeout

func (pe *PeriodicExecutor) SetSchedulerTimeout(duration time.Duration) *PeriodicExecutor

func (*PeriodicExecutor) StartTask

func (pe *PeriodicExecutor) StartTask(function func() bool) *PeriodicExecutor

func (*PeriodicExecutor) StopTask

func (pe *PeriodicExecutor) StopTask()

type Queue

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

func NewInMemoryQueue

func NewInMemoryQueue(concurrentConsumers, queueSize int) *Queue

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Offer

func (q *Queue) Offer(value interface{})

func (*Queue) StartConsuming

func (q *Queue) StartConsuming(f func(value interface{}))

func (*Queue) Take

func (q *Queue) Take() (interface{}, bool)