Interface Encoder

protocol/encoder.go:28–30 · view source on GitHub ↗

Source from the content-addressed store, hash-verified

26	}
27
28	type Encoder interface {
29	Encode(e PacketEncoder) error
30	}
31
32	func Encode(e Encoder) ([]byte, error) {
33	lenEnc := new(LenEncoder)

EncodeMethod · 0.65

EncodeFunction · 0.65

EncodeMethod · 0.65

TestBroker_RunFunction · 0.65

writeMethod · 0.65

MessageSetprotocol/message_set.go

LeaveGroupRequestprotocol/leave_group_request.go

APIVersionsResponseprotocol/api_versions_response.go

Messageprotocol/message.go

LeaderAndISRResponseprotocol/leader_and_isr_response.go

GroupCoordinatorResponseprotocol/group_coordinator_response.go

RequestHeaderprotocol/request_header.go

JoinGroupResponseprotocol/join_group_response.go

GroupCoordinatorRequestprotocol/group_coordinator_request.go

OffsetsRequestprotocol/offsets_request.go

FetchRequestprotocol/fetch_request.go

StopReplicaResponseprotocol/stop_replica_response.go

no outgoing calls

no test coverage detected