memorybus

Documentation

Index

• type InMemoryBus
  • func New() *InMemoryBus
  • func (bus *InMemoryBus) Publish(topic string, stream streams.Readable) error
  • func (bus *InMemoryBus) SetLogger(logger log.Logger)
  • func (bus *InMemoryBus) Start() <-chan bool
  • func (bus *InMemoryBus) Subscribe(topics []string, fn streams.SubscribeFunc) error
• type StreamSubscription
  • func NewStreamSubscription(topics []string, subscribeFn streams.SubscribeFunc) *StreamSubscription
• type StreamSubscriptionCollection

Types

type InMemoryBus

type InMemoryBus struct {
	Subscriptions StreamSubscriptionCollection
	// contains filtered or unexported fields
}

func New

func New() *InMemoryBus

func (*InMemoryBus) Publish

func (bus *InMemoryBus) Publish(topic string, stream streams.Readable) error

func (*InMemoryBus) SetLogger

func (bus *InMemoryBus) SetLogger(logger log.Logger)

func (*InMemoryBus) Start

func (bus *InMemoryBus) Start() <-chan bool

func (*InMemoryBus) Subscribe

func (bus *InMemoryBus) Subscribe(topics []string, fn streams.SubscribeFunc) error

type StreamSubscription

type StreamSubscription struct {
	Topics           []string
	Ready            chan bool
	SubscribeFn      streams.SubscribeFunc
	PublishedStreams chan streams.Readable
	ReadyStreams     int
}

func NewStreamSubscription

func NewStreamSubscription(topics []string, subscribeFn streams.SubscribeFunc) *StreamSubscription

type StreamSubscriptionCollection

type StreamSubscriptionCollection []*StreamSubscription