MCPcopy
hub / github.com/segmentio/kafka-go / Message

Interface Message

protocol/protocol.go:18–20  ·  protocol/protocol.go::Message

Message is an interface implemented by all request and response types of the kafka protocol. This interface is used mostly as a safe-guard to provide a compile-time check for values passed to functions dealing kafka message types.

Source from the content-addressed store, hash-verified

16// This interface is used mostly as a safe-guard to provide a compile-time check
17// for values passed to functions dealing kafka message types.
18type Message interface {
19 ApiKey() ApiKey
20}
21
22type ApiKey int16
23

Callers 8

RoundTripFunction · 0.65
RegisterFunction · 0.65
RegisterOverrideFunction · 0.65
RoundTripMethod · 0.65
WriteRequestFunction · 0.65
WriteResponseFunction · 0.65
TestResponseFunction · 0.65
BenchmarkResponseFunction · 0.65

Implementers 15

Requestprotocol/fetch/fetch.go
Responseprotocol/fetch/fetch.go
Requestprotocol/createtopics/createtopics.go
Responseprotocol/createtopics/createtopics.go
Requestprotocol/txnoffsetcommit/txnoffsetcomm
Responseprotocol/txnoffsetcommit/txnoffsetcomm
Requestprotocol/deletetopics/deletetopics.go
Responseprotocol/deletetopics/deletetopics.go
Requestprotocol/describegroups/describegroups
Responseprotocol/describegroups/describegroups
Requestprotocol/createacls/createacls.go
Responseprotocol/createacls/createacls.go

Calls

no outgoing calls

Tested by

no test coverage detected