bus

Documentation

Index

• Variables
• type Bus
  • func New(prefix string, nc *nats.EncodedConn, log log15.Logger) *Bus
  • func (b *Bus) Close()
  • func (b *Bus) Send(e ari.Event)
  • func (b *Bus) Subscribe(key *ari.Key, n ...string) ari.Subscription
• type Subscription
  • func (s *Subscription) Cancel()
  • func (s *Subscription) Events() <-chan ari.Event

Variables

var EventChanBufferLength = 10

EventChanBufferLength is the number of unhandled events which can be queued to the event channel buffer before further events are lost.

Types

type Bus

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

Bus provides an ari.Bus interface to NATS

func New

func New(prefix string, nc *nats.EncodedConn, log log15.Logger) *Bus

New returns a new Bus

func (*Bus) Close

func (b *Bus) Close()

Close implements ari.Bus

func (*Bus) Send

func (b *Bus) Send(e ari.Event)

Send implements ari.Bus

func (*Bus) Subscribe

func (b *Bus) Subscribe(key *ari.Key, n ...string) ari.Subscription

Subscribe implements ari.Bus

type Subscription

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

Subscription represents an ari.Subscription over NATS

func (*Subscription) Cancel

func (s *Subscription) Cancel()

Cancel destroys the subscription

func (*Subscription) Events

func (s *Subscription) Events() <-chan ari.Event

Events returns the channel on which events from this subscription will be sent