memory

Documentation

Overview

Package memory provides a message broker using memory.

Index

• type Broker
  • func New() *Broker
  • func (br *Broker) Close(ctx context.Context) error
  • func (br *Broker) Connect() error
  • func (br *Broker) HealthCheck() health.CheckFunc
  • func (br *Broker) Publish(topic string, m *broker.Message, opts ...broker.PublishOption) error
  • func (br *Broker) Subscribe(topic string, h broker.Handler, opts ...broker.SubscribeOption) (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) Close

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

Close implements broker.Broker interface.

func (*Broker) Connect

func (br *Broker) Connect() error

Connect implements broker.Broker interface.

func (*Broker) HealthCheck

func (br *Broker) HealthCheck() health.CheckFunc

HealthCheck implements broker.Broker interface.

func (*Broker) Publish

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

Publish implements broker.Broker interface.

func (*Broker) Subscribe

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

Subscribe implements broker.Broker interface.