local

Documentation

Index

• Variables
• type Local
  • func New(ctx context.Context, b int, s map[string]transport.Message) *Local
  • func (l *Local) Broadcast(topic string, message transport.Message) error
  • func (l *Local) Messages(topic string) chan transport.ReceivedMessage
  • func (l *Local) Start() error
  • func (l *Local) Wait() chan error

Variables

var ErrNotSubscribed = errors.New("topic is not subscribed")

Types

type Local

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

Local is a simple implementation of the transport.Transport interface using local channels.

func New

func New(ctx context.Context, b int, s map[string]transport.Message) *Local

New returns a new instance of the Local structure. The created transport can handle up to b unread messages before it is blocked. The list of supported subscriptions must be given as a map in s argument, where the key is the subscription's topic name, and the map value is the message type messages given as a nil pointer, e.g: (*Message)(nil).

func (*Local) Broadcast

func (l *Local) Broadcast(topic string, message transport.Message) error

Broadcast implements the transport.Transport interface.

func (*Local) Messages

func (l *Local) Messages(topic string) chan transport.ReceivedMessage

Messages implements the transport.Transport interface.

func (*Local) Start

func (l *Local) Start() error

Start implements the transport.Transport interface.

func (*Local) Wait

func (l *Local) Wait() chan error

Wait implements the transport.Transport interface.