membroker

Documentation

Overview

Package membroker provides an in-memory publisher.Broker implementation for use with the publisher pipeline. The broker implementation is registered as broker type "mem".

Index

• type Broker
  • func NewBroker(settings Settings) *Broker
  • func (b *Broker) BufferConfig() broker.BufferConfig
  • func (b *Broker) Close() error
  • func (b *Broker) Consumer() broker.Consumer
  • func (b *Broker) Producer(cfg broker.ProducerConfig) broker.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 in-memory broker 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() broker.BufferConfig

func (*Broker) Close

func (b *Broker) Close() error

func (*Broker) Consumer

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

func (*Broker) Producer

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

type Settings

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