message

Documentation

Index

• type Header
  • func Headers(headers interface{}) []Header
• type Message

Types

type Header

type Header struct {
	Key   string
	Value []byte
}

Header from message.

func Headers

func Headers(headers interface{}) []Header

type Message

type Message struct {
	// Topic is reads only and MUST NOT be set when writing messages
	Topic string

	// Partition is reads only and MUST NOT be set when writing messages
	Partition int32
	Offset    int64
	Key       []byte
	Value     []byte
	Headers   []Header

	// If not set at the creation, Time will be automatically set when
	// writing the message.
	Time time.Time
}

Message to read/write.