message

Documentation

Index

• func NewRouter(handler *pkg_message.KafkaMessage, mapper *event.TypeMapper, ...) (*message.Router, error)
• type Option
  • func WithSpanAttributes(attributes ...attribute.KeyValue) Option
• type Router

Functions

func NewRouter

func NewRouter(handler *pkg_message.KafkaMessage, mapper *event.TypeMapper, s application.Services, l pwlogger.Interface) (*message.Router, error)

Types

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.

type Router

type Router struct {
	Handler     *pkg_message.KafkaMessage
	EventMapper *event.TypeMapper
	S           application.Services
	L           pwlogger.Interface
}