Home
last modified time | relevance | path

Searched refs:MsgSet (Results 1 – 25 of 47) sorted by relevance

12

/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Drecords.go17 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 Dproduce_set.go100 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 Dfetch_response_test.go158 msgBlock := block.RecordsSet[0].MsgSet.Messages[0]
218 msgBlock := block.Records.MsgSet.Messages[0]
317 msgBlock := block.RecordsSet[0].MsgSet.Messages[0]
H A Drecords_test.go48 if !reflect.DeepEqual(set, r.MsgSet) {
49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
H A Dproduce_request.go118 …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 Drecords.go17 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 Dproduce_set.go100 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 Dproduce_request.go118 …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 Drecords.go16 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 Dproduce_set.go119 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 Dfetch_response_test.go222 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 Drecords_test.go48 if !reflect.DeepEqual(set, r.MsgSet) {
49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
H A Dproduce_request.go118 …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 Drecords.go16 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 Dproduce_set.go119 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 Dfetch_response_test.go213 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 Drecords_test.go48 if !reflect.DeepEqual(set, r.MsgSet) {
49 t.Errorf("Wrong decoding for legacy records, wanted %#+v, got %#+v", set, r.MsgSet)
H A Dproduce_request.go118 …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 Drecords.go16 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 Dproduce_set.go119 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 Dproduce_request.go118 …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 Dfetch_response.go6 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 Dfetch_response_test.go63 if block.MsgSet.PartialTrailingMessage {
67 if len(block.MsgSet.Messages) != 1 {
70 msgBlock := block.MsgSet.Messages[0]
H A Dfetch_response.go8 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 Dconsumer.go491 if len(block.MsgSet.Messages) == 0 {
494 if block.MsgSet.PartialTrailingMessage {
517 for _, msgBlock := range block.MsgSet.Messages {

12