Home
last modified time | relevance | path

Searched defs:ConsumerMessage (Results 1 – 25 of 26) sorted by relevance

12

/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dconsumer.go12 type ConsumerMessage struct { struct
13 Key, Value []byte
14 Topic string
15 Partition int32
16 Offset int64
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 …Timestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
19 Headers []*RecordHeader // only set if kafka is version 0.11+
H A Dfunctional_consumer_test.go111 func consMsg2Str(consMsg *ConsumerMessage) string {
H A Dconsumer_test.go988 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
H A Dfunctional_consumer_group_test.go190 *ConsumerMessage anonMember
H A Dconsumer_group.go437 MarkMessage(msg *ConsumerMessage, metadata string)
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Dconsumer.go12 type ConsumerMessage struct { struct
13 Key, Value []byte
14 Topic string
15 Partition int32
16 Offset int64
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 …Timestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
19 Headers []*RecordHeader // only set if kafka is version 0.11+
H A Dconsumer_group.go437 MarkMessage(msg *ConsumerMessage, metadata string)
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dconsumer.go15 type ConsumerMessage struct { struct
16 Headers []*RecordHeader // only set if kafka is version 0.11+
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 …Timestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
20 Key, Value []byte
21 Topic string
22 Partition int32
23 Offset int64
H A Dfunctional_consumer_test.go165 func consMsg2Str(consMsg *ConsumerMessage) string {
H A Dconsumer_test.go1250 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
H A Dfunctional_consumer_group_test.go190 *ConsumerMessage anonMember
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dconsumer.go15 type ConsumerMessage struct { struct
16 Headers []*RecordHeader // only set if kafka is version 0.11+
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 …Timestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
20 Key, Value []byte
21 Topic string
22 Partition int32
23 Offset int64
H A Dconsumer_group.go524 MarkMessage(msg *ConsumerMessage, metadata string)
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dconsumer.go12 type ConsumerMessage struct { struct
13 Key, Value []byte
14 Topic string
15 Partition int32
16 Offset int64
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 BlockTimestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
H A Dconsumer_test.go848 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dconsumer.go15 type ConsumerMessage struct { struct
16 Headers []*RecordHeader // only set if kafka is version 0.11+
17 Timestamp time.Time // only set if kafka is version 0.10+, inner message timestamp
18 …Timestamp time.Time // only set if kafka is version 0.10+, outer (compressed) block timestamp
20 Key, Value []byte
21 Topic string
22 Partition int32
23 Offset int64
H A Dinterceptors.go22 OnConsume(*ConsumerMessage)
H A Dconsumer_test.go1644 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
1744 expectationFn func(*testing.T, int, *ConsumerMessage),
H A Dfunctional_consumer_test.go167 func consMsg2Str(consMsg *ConsumerMessage) string {
H A Dfunctional_consumer_group_test.go190 *ConsumerMessage anonMember
H A Dconsumer_group.go529 MarkMessage(msg *ConsumerMessage, metadata string)
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/
H A Dconsumer.go12 type ConsumerMessage struct { struct
13 Key, Value []byte
14 Topic string
15 Partition int32
16 Offset int64
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/matrix-org/naffka/types/
H A Dtypes.go20 func (m *Message) ConsumerMessage(topic string) *sarama.ConsumerMessage { func
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama/
H A Dheaders.go66 func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier {
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/Shopify/sarama/
H A Dheaders.go66 func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier {

12