gochannel

Documentation

Index

• type Broker
  • func New() *Broker
  • func (b Broker) Close() error
  • func (b Broker) Publish(topic cqrs.RouteKey, messages ...cqrs.Message) error
  • func (b Broker) Subscribe(ctx context.Context, topic cqrs.RouteKey, _ *time.Duration) (<-chan cqrs.Envelope, error)

Types

type Broker

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

Broker implements the cqrs.Broker interface as a wrapper around watermills go channel implementation

func New

func New() *Broker

New creates a new Broker

func (Broker) Close

func (b Broker) Close() error

Close noop

func (Broker) Publish

func (b Broker) Publish(topic cqrs.RouteKey, messages ...cqrs.Message) error

Publish publishes (N) cqrs.Message(s) over the given topic

func (Broker) Subscribe

func (b Broker) Subscribe(ctx context.Context, topic cqrs.RouteKey, _ *time.Duration) (<-chan cqrs.Envelope, error)

Subscribe attaches to the given topic and returns a channel to receive cqrs.Message(s)