Versions in this module Expand all Collapse all v0 v0.0.14 Jan 4, 2023 Changes in this version + const BROKER + const KEY_BROKER_MSG + const KEY_TRACE_MSG_CARRIER + func LogError(l logger.Logger, msg string, topic string, err error) + type Broker interface + Logger func() logger.Logger + Publish func(ctx context.Context, topic string, message interface{}, opts ...PublishOption) error + String func() string + Subscribe func(ctx context.Context, topic string, handler Handler, opts ...SubscribeOption) error + Unsubscribe func(topic string) error + type Handler interface + Handle func(ctx context.Context, m *Message) error + type Message struct + Body []byte + Extras map[string]interface{} + type Option func(Broker) + type PublishCallback func(*TraceMsgCarrier) error + type PublishOption func(Publisher) + type Publisher interface + type RunOption func(Runner) + type Runner interface + type SubscribeCallback func(context.Context, *TraceMsgCarrier) error + type SubscribeOption func(Subscriber) + type Subscriber interface + type Trace struct + func NewTrace(b Broker) *Trace + func (t *Trace) Publish(ctx context.Context, tm *TraceMsgCarrier, publish PublishCallback) error + func (t *Trace) Subscribe(ctx context.Context, tm *TraceMsgCarrier, subscribe SubscribeCallback) error + type TraceMsgCarrier struct + Headers map[string]string + Message []byte + Topic string + func NewTraceMsgCarrier(topic string, data []byte) *TraceMsgCarrier + func NewTraceMsgCarrierFromBytes(tmBytes []byte) *TraceMsgCarrier + func (tm *TraceMsgCarrier) Bytes() ([]byte, error) + func (tm *TraceMsgCarrier) Get(key string) string + func (tm *TraceMsgCarrier) Keys() []string + func (tm *TraceMsgCarrier) Set(key string, value string) + type Wrapper struct + func NewWrapper(b Broker) *Wrapper + func (w *Wrapper) Publish(ctx context.Context, topic string, payload []byte, publish PublishCallback) error + func (w *Wrapper) Subscribe(ctx context.Context, topic string, tmBytes []byte, subscribe SubscribeCallback) error