sm

Documentation

Index

• func NewSafeQueue(queueSize, batchSize int, onItem OnItemsCB) *safeQueue
• func NewStateMachine(wg *sync.WaitGroup, closed common.Closable, rQueue, ckpQueue Queue) *stateMachine
• 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 common.Closable, rQueue, ckpQueue Queue) *stateMachine

Types

type EnqueueOp

type EnqueueOp = func(any) any

type OnFinCB

type OnFinCB = func()

type OnItemsCB

type OnItemsCB = func(...any)

type Queue

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

type State

type State = int32

const (
	Created State = iota
	Running
	ReceiverStopped
	PrepareStop
	Stopped
)

type StateMachine

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