sm

Documentation

Index

• func NewSafeQueue(queueSize, batchSize int, onItem OnItemsCB) *safeQueue
• func NewStateMachine(wg *sync.WaitGroup, closed Closable, rQueue, ckpQueue Queue) *stateMachine
• func NewWaitableQueue(queueSize, batchSize int, closed Closable, wg *sync.WaitGroup, ...) *waitableQueue
• type Closable
• type ClosedState
  • func (s *ClosedState) IsClosed() bool
  • func (s *ClosedState) TryClose() bool
• type EnqueueOp
• type OnFinCB
• type OnItemsCB
• type Queue
• type State
• type StateMachine

Functions

func NewSafeQueue

func NewSafeQueue(queueSize, batchSize int, onItem OnItemsCB) *safeQueue

func NewStateMachine

func NewStateMachine(wg *sync.WaitGroup, closed Closable, rQueue, ckpQueue Queue) *stateMachine

func NewWaitableQueue

func NewWaitableQueue(queueSize, batchSize int, closed Closable, wg *sync.WaitGroup, enqueueOp EnqueueOp, onFin OnFinCB, onItem OnItemsCB) *waitableQueue

Types

type Closable

type Closable interface {
	IsClosed() bool
	TryClose() bool
}

type ClosedState

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

func (*ClosedState) IsClosed

func (s *ClosedState) IsClosed() bool

func (*ClosedState) TryClose

func (s *ClosedState) TryClose() bool

type EnqueueOp

type EnqueueOp = func(interface{}) interface{}

type OnFinCB

type OnFinCB = func()

type OnItemsCB

type OnItemsCB = func(...interface{})

type Queue

type Queue interface {
	Start()
	Stop()
	Enqueue(interface{}) (interface{}, error)
}

type State

type State = int32

const (
	Created State = iota
	Running
	ReceiverStopped
	PrepareStop
	Stopped
)

type StateMachine

type StateMachine interface {
	Start()
	Stop()
	EnqueueRecevied(interface{}) (interface{}, error)
	EnqueueCheckpoint(interface{}) (interface{}, error)
}