broker

Documentation

Index

• func ContextFromMapCarrier(mapCarrier propagation.MapCarrier) context.Context
• type Event
  • func NewEvent(ctx context.Context, topic string, partition string, headers map[string]string, ...) *Event
  • func (e *Event) MapCarrier() propagation.MapCarrier
  • func (e *Event) WithLabel(label string) *Event
• type Logger

Functions

func ContextFromMapCarrier

func ContextFromMapCarrier(mapCarrier propagation.MapCarrier) context.Context

Types

type Event

type Event struct {
	Ctx context.Context //nolint:containedctx // context is used by drivers and should be passed along
	Idx uint64
	// User-defined label for incident investigation
	Label     string
	Topic     string
	Partition string
	Headers   map[string]string
	Body      []byte
}

func NewEvent

func NewEvent(
	ctx context.Context,
	topic string,
	partition string,
	headers map[string]string,
	body []byte,
) *Event

func (*Event) MapCarrier

func (e *Event) MapCarrier() propagation.MapCarrier

func (*Event) WithLabel

func (e *Event) WithLabel(label string) *Event

type Logger

type Logger interface {
	Error(msg string, keysValues ...any)
}