queue

Documentation

Index

• type Processor
  • func NewProcessor(sender route.Sender, compositions []cutter.Composition) Processor
• type Scheduler
  • func NewScheduler(processor Processor, maxWaitTime time.Duration, queueSize int) *Scheduler
  • func (s *Scheduler) Schedule(i *tx.Item)
  • func (s *Scheduler) Start()

Types

type Processor

type Processor interface {
	Submit(i *tx.Item) bool
	Process()
	Empty() bool
}

func NewProcessor

func NewProcessor(sender route.Sender, compositions []cutter.Composition) Processor

type Scheduler

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

func NewScheduler

func NewScheduler(processor Processor, maxWaitTime time.Duration, queueSize int) *Scheduler

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(i *tx.Item)

func (*Scheduler) Start

func (s *Scheduler) Start()