memory

Documentation

Overview

Package memory provides a message broker using memory.

Index

• type Broker
  • func New() *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)

Types

type Broker

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

Broker is a memory message broker.

func New

func New() *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.