chain

Documentation

Index

• type Chain
  • func New(ts ...transport.Service) *Chain
  • func (m *Chain) Broadcast(topic string, message transport.Message) error
  • func (m *Chain) Messages(topic string) <-chan transport.ReceivedMessage
  • func (m *Chain) Start(ctx context.Context) error
  • func (m *Chain) Wait() <-chan error

Types

type Chain

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

Chain is a transport implementation that chains multiple transports together.

func New

func New(ts ...transport.Service) *Chain

New creates a new Chain instance.

func (*Chain) Broadcast

func (m *Chain) Broadcast(topic string, message transport.Message) error

Broadcast implements the transport.Transport interface.

func (*Chain) Messages

func (m *Chain) Messages(topic string) <-chan transport.ReceivedMessage

Messages implements the transport.Transport interface.

func (*Chain) Start

func (m *Chain) Start(ctx context.Context) error

Start implements the transport.Transport interface.

func (*Chain) Wait

func (m *Chain) Wait() <-chan error

Wait implements the transport.Transport interface.