Versions in this module Expand all Collapse all v1 v1.0.0 Dec 16, 2024 Changes in this version + type MemoryQueue struct + Capacity uint32 + Default bool + Enabled bool + MemorySize int + func (this *MemoryQueue) Close(string) error + func (this *MemoryQueue) Consume(q *queue.QueueConfig, consumer *queue.ConsumerConfig, offsetStr string) (*queue.Context, []queue.Message, bool, error) + func (this *MemoryQueue) Depth(q string) int64 + func (this *MemoryQueue) GetQueues() []string + func (this *MemoryQueue) Init(q string) error + func (this *MemoryQueue) LatestOffset(string) string + func (this *MemoryQueue) Name() string + func (this *MemoryQueue) Pop(q string, t time.Duration) (data []byte, timeout bool) + func (this *MemoryQueue) Push(q string, data []byte) error + func (this *MemoryQueue) Setup() + func (this *MemoryQueue) Start() error + func (this *MemoryQueue) Stop() error + type Queue struct + func New() *Queue + func (q *Queue) Back() interface{} + func (q *Queue) Front() interface{} + func (q *Queue) Init() *Queue + func (q *Queue) Len() int + func (q *Queue) PopBack() interface{} + func (q *Queue) PopFront() interface{} + func (q *Queue) PushBack(v interface{}) + func (q *Queue) PushFront(v interface{}) + func (q *Queue) String() string
Go to main page