Versions in this module Expand all Collapse all v1 v1.4.4 Mar 5, 2021 Changes in this version + type Exchange struct + func NewExchange() *Exchange + func (e *Exchange) Forward(ctx context.Context, envelope *events.Envelope) (err error) + func (e *Exchange) Publish(ctx context.Context, topic string, event events.Event) (err error) + func (e *Exchange) Subscribe(ctx context.Context, fs ...string) (ch <-chan *events.Envelope, errs <-chan error)