queue

type Factory interface {
	// Create a new queue if name does not exist
	// If name already exists, return the existing queue
	GetOrCreate(name string, maxSize int) Queue
}

type Handler func([]byte) error

type Kind uint8

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

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

type Queue interface {
	Kind() Kind

	// Reports max size of queue
	MaxSize() int

	// Push data to end of queue
	// Failed if queue is full or closed
	Enqueue([]byte) error

	// Pop data from beginning of queue without message confirmation
	// Failed if queue is empty
	Dequeue() ([]byte, error)

	// Subscribe queue with message confirmation.
	// Once handler returns error, it'll automatically put message back to queue using `Recover` mechanism internally.
	Subscribe(h Handler)
}

type RecoverableQueue interface {
	Queue

	// or just does not implement it
	Recover([]byte) error
}

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