Versions in this module Expand all Collapse all v1 v1.2.4 Feb 13, 2019 Changes in this version + type Envelope struct + Event *types.Any + Namespace string + Timestamp time.Time + Topic string + func (e *Envelope) Field(fieldpath []string) (string, bool) + type Event interface + type Forwarder interface + Forward func(ctx context.Context, envelope *Envelope) error + type Publisher interface + Publish func(ctx context.Context, topic string, event Event) error + type Subscriber interface + Subscribe func(ctx context.Context, filters ...string) (ch <-chan *Envelope, errs <-chan error)
Go to main page