/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
H A D | consumer.go | 12 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 D | functional_consumer_test.go | 111 func consMsg2Str(consMsg *ConsumerMessage) string {
|
H A D | consumer_test.go | 988 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
|
H A D | functional_consumer_group_test.go | 190 *ConsumerMessage anonMember
|
H A D | consumer_group.go | 437 MarkMessage(msg *ConsumerMessage, metadata string)
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 12 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 D | consumer_group.go | 437 MarkMessage(msg *ConsumerMessage, metadata string)
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
H A D | consumer.go | 15 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 D | functional_consumer_test.go | 165 func consMsg2Str(consMsg *ConsumerMessage) string {
|
H A D | consumer_test.go | 1250 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
|
H A D | functional_consumer_group_test.go | 190 *ConsumerMessage anonMember
|
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 15 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 D | consumer_group.go | 524 MarkMessage(msg *ConsumerMessage, metadata string)
|
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 12 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 D | consumer_test.go | 848 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) {
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
H A D | consumer.go | 15 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 D | interceptors.go | 22 OnConsume(*ConsumerMessage)
|
H A D | consumer_test.go | 1644 func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) { 1744 expectationFn func(*testing.T, int, *ConsumerMessage),
|
H A D | functional_consumer_test.go | 167 func consMsg2Str(consMsg *ConsumerMessage) string {
|
H A D | functional_consumer_group_test.go | 190 *ConsumerMessage anonMember
|
H A D | consumer_group.go | 529 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 D | consumer.go | 12 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 D | types.go | 20 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 D | headers.go | 66 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 D | headers.go | 66 func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier {
|