internal

Documentation

Index

• type Message
  • func NewMessage(msg *kafka.Message) *Message
  • func (m *Message) GetHeader(key string) string
  • func (m *Message) SetHeader(key, val string)
• type MessageCarrier
  • func NewMessageCarrier(msg *Message) MessageCarrier
  • func (m MessageCarrier) Get(key string) string
  • func (m MessageCarrier) Keys() []string
  • func (m MessageCarrier) Set(key string, value string)

Types

type Message

type Message struct {
	*kafka.Message
}

func NewMessage

func NewMessage(msg *kafka.Message) *Message

func (*Message) GetHeader

func (m *Message) GetHeader(key string) string

func (*Message) SetHeader

func (m *Message) SetHeader(key, val string)

type MessageCarrier

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

MessageCarrier injects and extracts traces from a types.Message.

func NewMessageCarrier

func NewMessageCarrier(msg *Message) MessageCarrier

NewMessageCarrier returns a new MessageCarrier.

func (MessageCarrier) Get

func (m MessageCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (MessageCarrier) Keys

func (m MessageCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (MessageCarrier) Set

func (m MessageCarrier) Set(key string, value string)

Set stores the key-value pair.