Versions in this module Expand all Collapse all v1 v1.0.0 Oct 13, 2022 Changes in this version + const ErrListenerAlreadyRegistered + const ErrSourceAlreadyRegistered + type Queue struct + func NewQueue(queueLimit int) *Queue + func (q *Queue) Pop() *proto.Frame + func (q *Queue) Push(v *proto.Frame) + func (q *Queue) Subscribe(name string) (chan int, func(), error) + type QueueListener struct + IsConnected bool + Signal chan int + type QueueManager struct + Logger *zerolog.Logger + func NewQueueManager(logger *zerolog.Logger) *QueueManager + func (m *QueueManager) RegisterListener(source, name string) (*Queue, func(), error) + func (m *QueueManager) RegisterSource(name string) (*Queue, func(), error) + func (m *QueueManager) Shutdown()
Go to main page