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

Interface decoder

encoder_decoder.go:60–62  ·  view source on GitHub ↗

decoder is the interface that wraps the basic Decode method. Anything implementing Decoder can be extracted from bytes using Kafka's encoding rules.

Source from the content-addressed store, hash-verified

58// decoder is the interface that wraps the basic Decode method.
59// Anything implementing Decoder can be extracted from bytes using Kafka's encoding rules.
60type decoder interface {
61 decode(pd packetDecoder) error
62}
63
64type versionedDecoder interface {
65 decode(pd packetDecoder, version int16) error

Callers 1

getTaggedFieldArrayMethod · 0.85

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