memory

Documentation

Overview

Package memory provides a message broker using memory.

Index

• Variables
• type Broker
  • func New(opts ...Option) *Broker
  • func (br *Broker) CheckHealth(ctx context.Context) error
  • func (br *Broker) Close(ctx context.Context) error
  • func (br *Broker) Open(ctx context.Context) error
  • func (br *Broker) Publish(ctx context.Context, topic string, m *broker.Message, ...) error
  • func (br *Broker) Subscribe(ctx context.Context, topic string, h broker.Handler, ...) (broker.Subscriber, error)
• type Option
  • func Worker(worker, buffer int) Option

Variables

var (

	// ErrInvalidConnectionState indicate that the connection has not been opened properly.
	ErrInvalidConnectionState = errors.New("invalid connection state")
)

Types

type Broker

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

Broker is a memory message broker.

func New

func New(opts ...Option) *Broker

New return new memory broker.

func (*Broker) CheckHealth

func (br *Broker) CheckHealth(ctx context.Context) error

CheckHealth implements health.Checker interface.

func (*Broker) Close

func (br *Broker) Close(ctx context.Context) error

Close implements broker.Broker interface.

func (*Broker) Open

func (br *Broker) Open(ctx context.Context) error

Open implements broker.Broker interface.

func (*Broker) Publish

func (br *Broker) Publish(ctx context.Context, topic string, m *broker.Message, opts ...broker.PublishOption) error

Publish implements broker.Broker interface.

func (*Broker) Subscribe

func (br *Broker) Subscribe(ctx context.Context, topic string, h broker.Handler, opts ...broker.SubscribeOption) (broker.Subscriber, error)

Subscribe implements broker.Broker interface.

type Option

type Option func(*Broker)

func Worker

func Worker(worker, buffer int) Option

Worker is an option to override the default number of worker and buffer.