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

Method decode

sync_group_request.go:23–34  ·  view source on GitHub ↗
(pd packetDecoder, version int16)

Source from the content-addressed store, hash-verified

21}
22
23func (a *SyncGroupRequestAssignment) decode(pd packetDecoder, version int16) (err error) {
24 if a.MemberId, err = pd.getString(); err != nil {
25 return err
26 }
27
28 if a.Assignment, err = pd.getBytes(); err != nil {
29 return err
30 }
31
32 _, err = pd.getEmptyTaggedFieldArray()
33 return err
34}
35
36type SyncGroupRequest struct {
37 // Version defines the protocol version to use for encode and decode

Callers 1

decodeMethod · 0.95

Calls 3

getStringMethod · 0.65
getBytesMethod · 0.65

Tested by

no test coverage detected