local

Documentation

Index

• Variables
• type Local
  • func New(buffer int) *Local
  • func (l *Local) Broadcast(topic string, message transport.Message) error
  • func (l *Local) Close() error
  • func (l *Local) Subscribe(topic string, typ transport.Message) error
  • func (l *Local) Unsubscribe(topic string) error
  • func (l *Local) WaitFor(topic string) chan transport.ReceivedMessage

Variables

var ErrAlreadySubscribed = errors.New("topic is already subscribed")

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(buffer int) *Local

New returns a new instance of the Local structure.

func (*Local) Broadcast

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

Broadcast implements the transport.Transport interface.

func (*Local) Close

func (l *Local) Close() error

Close implements the transport.Transport interface.

func (*Local) Subscribe

func (l *Local) Subscribe(topic string, typ transport.Message) error

Subscribe implements the transport.Transport interface.

func (*Local) Unsubscribe

func (l *Local) Unsubscribe(topic string) error

Unsubscribe implements the transport.Transport interface.

func (*Local) WaitFor

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

WaitFor implements the transport.Transport interface.