MCPcopy Create free account
hub / github.com/IBM/sarama / encoder

Interface encoder

encoder_decoder.go:11–13  ·  view source on GitHub ↗

Encoder is the interface that wraps the basic Encode method. Anything implementing Encoder can be turned into bytes using Kafka's encoding rules.

Source from the content-addressed store, hash-verified

9// Encoder is the interface that wraps the basic Encode method.
10// Anything implementing Encoder can be turned into bytes using Kafka's encoding rules.
11type encoder interface {
12 encode(pe packetEncoder) error
13}
14
15type encoderWithHeader interface {
16 encoder

Callers 8

encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65
encodeMethod · 0.65

Implementers 15

AlterConfigsRequestalter_configs_request.go
AlterConfigsResourcealter_configs_request.go
ConsumerMetadataResponseconsumer_metadata_response.go
InitProducerIDResponseinit_producer_id_response.go
MessageBlockmessage_set.go
MessageSetmessage_set.go
DeleteAclsResponseacl_delete_response.go
FilterResponseacl_delete_response.go
MatchingAclacl_delete_response.go
RecordHeaderrecord.go
Recordrecord.go
offsetCommitRequestBlockoffset_commit_request.go

Calls

no outgoing calls

Tested by

no test coverage detected