message

Documentation

Index

• type KafkaMessage
  • func NewKafkaMessage(brokers []string, groupID string) (*KafkaMessage, error)
  • func (k *KafkaMessage) Close() error
  • func (k *KafkaMessage) PublishEvent(ctx context.Context, topic string, event interface{}) error
• type KafkaTracer
  • func NewKafkaTracer(groupID string) *KafkaTracer
  • func (t *KafkaTracer) Trace(options ...Option) message.HandlerMiddleware
  • func (t *KafkaTracer) TraceHandler(h message.HandlerFunc, options ...Option) message.HandlerFunc
  • func (t *KafkaTracer) TraceNoPublishHandler(h message.NoPublishHandlerFunc, options ...Option) message.NoPublishHandlerFunc
• type Option
  • func WithSpanAttributes(attributes ...attribute.KeyValue) Option

Types

type KafkaMessage

type KafkaMessage struct {
	Subscriber *kafka.Subscriber
	Publisher  *kafka.Publisher
	Tracer     *KafkaTracer
	Router     *message.Router
}

func NewKafkaMessage

func NewKafkaMessage(brokers []string, groupID string) (*KafkaMessage, error)

func (*KafkaMessage) Close

func (k *KafkaMessage) Close() error

func (*KafkaMessage) PublishEvent

func (k *KafkaMessage) PublishEvent(ctx context.Context, topic string, event interface{}) error

type KafkaTracer

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

func NewKafkaTracer

func NewKafkaTracer(groupID string) *KafkaTracer

func (*KafkaTracer) Trace

func (t *KafkaTracer) Trace(options ...Option) message.HandlerMiddleware

Trace defines a middleware that will add tracing.

func (*KafkaTracer) TraceHandler

func (t *KafkaTracer) TraceHandler(h message.HandlerFunc, options ...Option) message.HandlerFunc

TraceHandler decorates a watermill HandlerFunc to add tracing when a message is received.

func (*KafkaTracer) TraceNoPublishHandler

func (t *KafkaTracer) TraceNoPublishHandler(h message.NoPublishHandlerFunc, options ...Option) message.NoPublishHandlerFunc

TraceNoPublishHandler decorates a watermill NoPublishHandlerFunc to add tracing when a message is received.

type Option

type Option func(*config)

Option provides a convenience wrapper for simple options that can be represented as functions.

func WithSpanAttributes

func WithSpanAttributes(attributes ...attribute.KeyValue) Option

WithSpanAttributes includes the given attributes to the generated Spans.