memqueue

Documentation

Overview

Package memqueue provides an in-memory queue.Queue implementation for use with the publisher pipeline. The queue implementation is registered as queue type "mem".

Index

• type Broker
  • func NewBroker(settings Settings) *Broker
  • func (b *Broker) BufferConfig() queue.BufferConfig
  • func (b *Broker) Close() error
  • func (b *Broker) Consumer() queue.Consumer
  • func (b *Broker) Producer(cfg queue.ProducerConfig) queue.Producer
• type Settings

Types

type Broker

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

func NewBroker

func NewBroker(
	settings Settings,
) *Broker

NewBroker creates a new broker based in-memory queue holding up to sz number of events. If waitOnClose is set to true, the broker will block on Close, until all internal workers handling incoming messages and ACKs have been shut down.

func (*Broker) BufferConfig

func (b *Broker) BufferConfig() queue.BufferConfig

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Consumer

func (b *Broker) Consumer() queue.Consumer

func (*Broker) Producer

func (b *Broker) Producer(cfg queue.ProducerConfig) queue.Producer

type Settings

type Settings struct {
	Eventer        queue.Eventer
	Events         int
	FlushMinEvents int
	FlushTimeout   time.Duration
	WaitOnClose    bool
}