kafka

Documentation

Index

• Constants
• type ConnTuple
• type EbpfTx
• type Key
  • func NewKey(saddr, daddr util.Address, sport, dport uint16, topicName string, ...) Key
• type RequestStat
  • func (r *RequestStat) CombineWith(newStats *RequestStat)

Constants

const (
	// ProduceAPIKey is the API key for produce requests
	ProduceAPIKey = 0

	// FetchAPIKey is the API key for fetch requests
	FetchAPIKey = 1
)

Types

type ConnTuple

type ConnTuple struct {
	Saddr_h  uint64
	Saddr_l  uint64
	Daddr_h  uint64
	Daddr_l  uint64
	Sport    uint16
	Dport    uint16
	Netns    uint32
	Pid      uint32
	Metadata uint32
}

type EbpfTx

type EbpfTx struct {
	Tup                 ConnTuple
	Request_api_key     uint16
	Request_api_version uint16
	Topic_name          [80]byte
	Topic_name_size     uint16
	Records_count       uint32
	Pad_cgo_0           [4]byte
}

type Key

type Key struct {
	RequestAPIKey  uint16
	RequestVersion uint16
	TopicName      string
	types.ConnectionKey
}

Key is an identifier for a group of Kafka transactions

func NewKey

func NewKey(saddr, daddr util.Address, sport, dport uint16, topicName string, requestAPIKey, requestAPIVersion uint16) Key

NewKey generates a new Key

type RequestStat

type RequestStat struct {
	Count int
}

RequestStat stores stats for Kafka requests to a particular key

func (*RequestStat) CombineWith

func (r *RequestStat) CombineWith(newStats *RequestStat)

CombineWith merges the data in 2 RequestStats objects newStats is kept as it is, while the method receiver gets mutated