Home
last modified time | relevance | path

Searched defs:OffsetCommitRequest (Results 1 – 10 of 10) sorted by relevance

/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Doffset_commit_request.go45 type OffsetCommitRequest struct { struct
46 ConsumerGroup string
47 ConsumerGroupGeneration int32 // v1 or later
48 ConsumerID string // v1 or later
49 RetentionTime int64 // v2 or later
57 Version int16
58 blocks map[string]map[int32]*offsetCommitRequestBlock
61 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
165 func (r *OffsetCommitRequest) key() int16 {
169 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Doffset_commit_request.go45 type OffsetCommitRequest struct { struct
46 ConsumerGroup string
47 ConsumerGroupGeneration int32 // v1 or later
48 ConsumerID string // v1 or later
49 RetentionTime int64 // v2 or later
57 Version int16
58 blocks map[string]map[int32]*offsetCommitRequestBlock
61 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
165 func (r *OffsetCommitRequest) key() int16 {
169 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Doffset_commit_request.go45 type OffsetCommitRequest struct { struct
46 ConsumerGroup string
47 ConsumerGroupGeneration int32 // v1 or later
48 ConsumerID string // v1 or later
49 RetentionTime int64 // v2 or later
57 Version int16
58 blocks map[string]map[int32]*offsetCommitRequestBlock
61 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
165 func (r *OffsetCommitRequest) key() int16 {
169 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Doffset_commit_request.go45 type OffsetCommitRequest struct { struct
46 ConsumerGroup string
47 ConsumerGroupGeneration int32 // v1 or later
48 ConsumerID string // v1 or later
49 RetentionTime int64 // v2 or later
55 Version int16
56 blocks map[string]map[int32]*offsetCommitRequestBlock
59 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
163 func (r *OffsetCommitRequest) key() int16 {
167 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Doffset_commit_request.go45 type OffsetCommitRequest struct { struct
46 ConsumerGroup string
47 ConsumerGroupGeneration int32 // v1 or later
48 ConsumerID string // v1 or later
49 RetentionTime int64 // v2 or later
55 Version int16
56 blocks map[string]map[int32]*offsetCommitRequestBlock
59 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
163 func (r *OffsetCommitRequest) key() int16 {
167 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Doffset_commit_request.go43 type OffsetCommitRequest struct { struct
44 ConsumerGroup string
45 ConsumerGroupGeneration int32 // v1 or later
46 ConsumerID string // v1 or later
47 RetentionTime int64 // v2 or later
53 Version int16
54 blocks map[string]map[int32]*offsetCommitRequestBlock
57 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
161 func (r *OffsetCommitRequest) key() int16 {
165 func (r *OffsetCommitRequest) version() int16 {
[all …]
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/
H A Doffset_commit_request.go38 type OffsetCommitRequest struct { struct
39 ConsumerGroup string
40 ConsumerGroupGeneration int32 // v1 or later
41 ConsumerID string // v1 or later
42 RetentionTime int64 // v2 or later
48 Version int16
49 blocks map[string]map[int32]*offsetCommitRequestBlock
52 func (r *OffsetCommitRequest) encode(pe packetEncoder) error {
101 func (r *OffsetCommitRequest) decode(pd packetDecoder) (err error) {
154 func (r *OffsetCommitRequest) key() int16 {
[all …]
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/protocol/
H A Dconsumer.rs278 pub struct OffsetCommitRequest<'a, 'b> { struct
281 pub topic_partitions: Vec<TopicPartitionOffsetCommitRequest<'b>>, argument
297 impl<'a, 'b> OffsetCommitRequest<'a, 'b> { argument
356 impl<'a, 'b> ToByte for OffsetCommitRequest<'a, 'b> { implementation
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/
H A Dcommit.py104 OffsetCommitRequest = [ variable
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/client/
H A Dmod.rs1385 req: protocol::OffsetCommitRequest, in __commit_offsets()