memory

package

v1.0.8 Latest Latest Go to latest Published: Jan 19, 2026 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewQueue(bufferSize int) *MemoryQueue

func (q *MemoryQueue) Close() error

func (q *MemoryQueue) Dequeue(ctx context.Context, timeout time.Duration) (*queue.Event, error)

func (q *MemoryQueue) Enqueue(ctx context.Context, event queue.Event) error

func (q *MemoryQueue) Size(ctx context.Context) (int64, error)