Searched defs:OffsetFetchResponse (Results 1 – 9 of 9) sorted by relevance
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | offset_fetch_response.go | 54 type OffsetFetchResponse struct { struct
55 Version int16
56 ThrottleTimeMs int32
57 Blocks map[string]map[int32]*OffsetFetchResponseBlock
58 Err KError
61 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
89 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
150 func (r *OffsetFetchResponse) key() int16 {
154 func (r *OffsetFetchResponse) version() int16 {
158 func (r *OffsetFetchResponse) headerVersion() int16 {
[all …]
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | offset_fetch_response.go | 54 type OffsetFetchResponse struct { struct
55 Version int16
56 ThrottleTimeMs int32
57 Blocks map[string]map[int32]*OffsetFetchResponseBlock
58 Err KError
61 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
89 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
150 func (r *OffsetFetchResponse) key() int16 {
154 func (r *OffsetFetchResponse) version() int16 {
158 func (r *OffsetFetchResponse) headerVersion() int16 {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | offset_fetch_response.go | 74 type OffsetFetchResponse struct { struct
75 Version int16
76 ThrottleTimeMs int32
77 Blocks map[string]map[int32]*OffsetFetchResponseBlock
78 Err KError
81 func (r *OffsetFetchResponse) encode(pe packetEncoder) (err error) {
133 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
221 func (r *OffsetFetchResponse) key() int16 {
225 func (r *OffsetFetchResponse) version() int16 {
229 func (r *OffsetFetchResponse) headerVersion() int16 {
[all …]
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | offset_fetch_response.go | 42 type OffsetFetchResponse struct { struct
43 Blocks map[string]map[int32]*OffsetFetchResponseBlock
46 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
67 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
109 func (r *OffsetFetchResponse) key() int16 {
113 func (r *OffsetFetchResponse) version() int16 {
117 func (r *OffsetFetchResponse) requiredVersion() KafkaVersion {
121 func (r *OffsetFetchResponse) GetBlock(topic string, partition int32) *OffsetFetchResponseBlock {
133 …(r *OffsetFetchResponse) AddBlock(topic string, partition int32, block *OffsetFetchResponseBlock) {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | offset_fetch_response.go | 42 type OffsetFetchResponse struct { struct
43 Blocks map[string]map[int32]*OffsetFetchResponseBlock
46 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
67 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
109 func (r *OffsetFetchResponse) key() int16 {
113 func (r *OffsetFetchResponse) version() int16 {
117 func (r *OffsetFetchResponse) requiredVersion() KafkaVersion {
121 func (r *OffsetFetchResponse) GetBlock(topic string, partition int32) *OffsetFetchResponseBlock {
133 …(r *OffsetFetchResponse) AddBlock(topic string, partition int32, block *OffsetFetchResponseBlock) {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | offset_fetch_response.go | 42 type OffsetFetchResponse struct { struct
43 Blocks map[string]map[int32]*OffsetFetchResponseBlock
46 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
67 func (r *OffsetFetchResponse) decode(pd packetDecoder, version int16) (err error) {
109 func (r *OffsetFetchResponse) key() int16 {
113 func (r *OffsetFetchResponse) version() int16 {
117 func (r *OffsetFetchResponse) requiredVersion() KafkaVersion {
121 func (r *OffsetFetchResponse) GetBlock(topic string, partition int32) *OffsetFetchResponseBlock {
133 …(r *OffsetFetchResponse) AddBlock(topic string, partition int32, block *OffsetFetchResponseBlock) {
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/ |
| H A D | offset_fetch_response.go | 42 type OffsetFetchResponse struct { struct
43 Blocks map[string]map[int32]*OffsetFetchResponseBlock
46 func (r *OffsetFetchResponse) encode(pe packetEncoder) error {
67 func (r *OffsetFetchResponse) decode(pd packetDecoder) (err error) {
109 func (r *OffsetFetchResponse) GetBlock(topic string, partition int32) *OffsetFetchResponseBlock {
121 …(r *OffsetFetchResponse) AddBlock(topic string, partition int32, block *OffsetFetchResponseBlock) {
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/protocol/ |
| H A D | consumer.rs | 181 pub struct OffsetFetchResponse { struct
183 pub topic_partitions: Vec<TopicPartitionOffsetFetchResponse>, argument
223 impl FromByte for OffsetFetchResponse { implementation
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/ |
| H A D | commit.py | 206 OffsetFetchResponse = [ variable
|