/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
H A D | records.go | 17 MsgSet *MessageSet member 40 if r.MsgSet != nil { 55 if r.MsgSet == nil { 58 return r.MsgSet.encode(pe) 92 r.MsgSet = &MessageSet{} 93 return r.MsgSet.decode(pd) 110 if r.MsgSet == nil { 113 return len(r.MsgSet.Messages), nil 134 if r.MsgSet == nil { 177 if r.MsgSet == nil { [all …]
|
H A D | produce_set.go | 100 set.recordsToSend.MsgSet.addMessage(msgToSend) 145 req.AddSet(topic, partition, set.recordsToSend.MsgSet) 158 for i, msg := range set.recordsToSend.MsgSet.Messages { 162 payload, err := encode(set.recordsToSend.MsgSet, ps.parent.conf.MetricRegistry) 172 …Set: set.recordsToSend.MsgSet, // Provide the underlying message set for accurate met… 176 compMsg.Timestamp = set.recordsToSend.MsgSet.Messages[0].Msg.Timestamp
|
H A D | fetch_response_test.go | 158 msgBlock := block.RecordsSet[0].MsgSet.Messages[0] 218 msgBlock := block.Records.MsgSet.Messages[0] 317 msgBlock := block.RecordsSet[0].MsgSet.Messages[0]
|
H A D | records_test.go | 48 if !reflect.DeepEqual(set, r.MsgSet) { 49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
|
H A D | produce_request.go | 118 …topicRecordCount += updateMsgSetMetrics(records.MsgSet, compressionRatioMetric, topicCompressionRa… 234 set := r.records[topic][partition].MsgSet
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
H A D | records.go | 17 MsgSet *MessageSet member 40 if r.MsgSet != nil { 55 if r.MsgSet == nil { 58 return r.MsgSet.encode(pe) 92 r.MsgSet = &MessageSet{} 93 return r.MsgSet.decode(pd) 110 if r.MsgSet == nil { 113 return len(r.MsgSet.Messages), nil 134 if r.MsgSet == nil { 177 if r.MsgSet == nil { [all …]
|
H A D | produce_set.go | 100 set.recordsToSend.MsgSet.addMessage(msgToSend) 145 req.AddSet(topic, partition, set.recordsToSend.MsgSet) 158 for i, msg := range set.recordsToSend.MsgSet.Messages { 162 payload, err := encode(set.recordsToSend.MsgSet, ps.parent.conf.MetricRegistry) 172 …Set: set.recordsToSend.MsgSet, // Provide the underlying message set for accurate met… 176 compMsg.Timestamp = set.recordsToSend.MsgSet.Messages[0].Msg.Timestamp
|
H A D | produce_request.go | 118 …topicRecordCount += updateMsgSetMetrics(records.MsgSet, compressionRatioMetric, topicCompressionRa… 234 set := r.records[topic][partition].MsgSet
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
H A D | records.go | 16 MsgSet *MessageSet member 39 if r.MsgSet != nil { 54 if r.MsgSet == nil { 57 return r.MsgSet.encode(pe) 91 r.MsgSet = &MessageSet{} 92 return r.MsgSet.decode(pd) 109 if r.MsgSet == nil { 112 return len(r.MsgSet.Messages), nil 133 if r.MsgSet == nil { 176 if r.MsgSet == nil { [all …]
|
H A D | produce_set.go | 119 set.recordsToSend.MsgSet.addMessage(msgToSend) 167 req.AddSet(topic, partition, set.recordsToSend.MsgSet) 180 for i, msg := range set.recordsToSend.MsgSet.Messages { 184 payload, err := encode(set.recordsToSend.MsgSet, ps.parent.conf.MetricRegistry) 194 …Set: set.recordsToSend.MsgSet, // Provide the underlying message set for accurate met… 198 compMsg.Timestamp = set.recordsToSend.MsgSet.Messages[0].Msg.Timestamp
|
H A D | fetch_response_test.go | 222 msgBlock := block.RecordsSet[0].MsgSet.Messages[0] 282 msgBlock := block.Records.MsgSet.Messages[0] 429 msgBlock := block.RecordsSet[0].MsgSet.Messages[0] 501 msgBlock := block.RecordsSet[0].MsgSet.Messages[0]
|
H A D | records_test.go | 48 if !reflect.DeepEqual(set, r.MsgSet) { 49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
|
H A D | produce_request.go | 118 …topicRecordCount += updateMsgSetMetrics(records.MsgSet, compressionRatioMetric, topicCompressionRa… 240 set := r.records[topic][partition].MsgSet
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
H A D | records.go | 16 MsgSet *MessageSet member 39 if r.MsgSet != nil { 54 if r.MsgSet == nil { 57 return r.MsgSet.encode(pe) 91 r.MsgSet = &MessageSet{} 92 return r.MsgSet.decode(pd) 109 if r.MsgSet == nil { 112 return len(r.MsgSet.Messages), nil 133 if r.MsgSet == nil { 176 if r.MsgSet == nil { [all …]
|
H A D | produce_set.go | 119 set.recordsToSend.MsgSet.addMessage(msgToSend) 167 req.AddSet(topic, partition, set.recordsToSend.MsgSet) 180 for i, msg := range set.recordsToSend.MsgSet.Messages { 184 payload, err := encode(set.recordsToSend.MsgSet, ps.parent.conf.MetricRegistry) 194 …Set: set.recordsToSend.MsgSet, // Provide the underlying message set for accurate met… 198 compMsg.Timestamp = set.recordsToSend.MsgSet.Messages[0].Msg.Timestamp
|
H A D | fetch_response_test.go | 213 msgBlock := block.RecordsSet[0].MsgSet.Messages[0] 273 msgBlock := block.Records.MsgSet.Messages[0] 411 msgBlock := block.RecordsSet[0].MsgSet.Messages[0] 483 msgBlock := block.RecordsSet[0].MsgSet.Messages[0]
|
H A D | records_test.go | 48 if !reflect.DeepEqual(set, r.MsgSet) { 49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
|
H A D | produce_request.go | 118 …topicRecordCount += updateMsgSetMetrics(records.MsgSet, compressionRatioMetric, topicCompressionRa… 240 set := r.records[topic][partition].MsgSet
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
H A D | records.go | 16 MsgSet *MessageSet member 39 if r.MsgSet != nil { 54 if r.MsgSet == nil { 57 return r.MsgSet.encode(pe) 91 r.MsgSet = &MessageSet{} 92 return r.MsgSet.decode(pd) 109 if r.MsgSet == nil { 112 return len(r.MsgSet.Messages), nil 133 if r.MsgSet == nil { 176 if r.MsgSet == nil { [all …]
|
H A D | produce_set.go | 119 set.recordsToSend.MsgSet.addMessage(msgToSend) 167 req.AddSet(topic, partition, set.recordsToSend.MsgSet) 180 for i, msg := range set.recordsToSend.MsgSet.Messages { 184 payload, err := encode(set.recordsToSend.MsgSet, ps.parent.conf.MetricRegistry) 194 …Set: set.recordsToSend.MsgSet, // Provide the underlying message set for accurate met… 198 compMsg.Timestamp = set.recordsToSend.MsgSet.Messages[0].Msg.Timestamp
|
H A D | produce_request.go | 118 …topicRecordCount += updateMsgSetMetrics(records.MsgSet, compressionRatioMetric, topicCompressionRa… 240 set := r.records[topic][partition].MsgSet
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/ |
H A D | fetch_response.go | 6 MsgSet MessageSet member 30 err = (&pr.MsgSet).decode(msgSetDecoder) 45 err = pr.MsgSet.encode(pe) 172 frb.MsgSet.Messages = append(frb.MsgSet.Messages, msgBlock)
|
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
H A D | fetch_response_test.go | 63 if block.MsgSet.PartialTrailingMessage { 67 if len(block.MsgSet.Messages) != 1 { 70 msgBlock := block.MsgSet.Messages[0]
|
H A D | fetch_response.go | 8 MsgSet MessageSet member 32 err = (&b.MsgSet).decode(msgSetDecoder) 43 err = b.MsgSet.encode(pe) 209 frb.MsgSet.Messages = append(frb.MsgSet.Messages, msgBlock)
|
H A D | consumer.go | 491 if len(block.MsgSet.Messages) == 0 { 494 if block.MsgSet.PartialTrailingMessage { 517 for _, msgBlock := range block.MsgSet.Messages {
|