| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | metadata_response.go | 143 type MetadataResponse struct { struct
144 Version int16
145 ThrottleTimeMs int32
146 Brokers []*Broker
147 ClusterID *string
148 ControllerID int32
149 Topics []*TopicMetadata
209 func (r *MetadataResponse) encode(pe packetEncoder) error {
250 func (r *MetadataResponse) key() int16 {
254 func (r *MetadataResponse) version() int16 {
[all …]
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | metadata_response.go | 143 type MetadataResponse struct { struct
144 Version int16
145 ThrottleTimeMs int32
146 Brokers []*Broker
147 ClusterID *string
148 ControllerID int32
149 Topics []*TopicMetadata
209 func (r *MetadataResponse) encode(pe packetEncoder) error {
250 func (r *MetadataResponse) key() int16 {
254 func (r *MetadataResponse) version() int16 {
[all …]
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | metadata_response.go | 143 type MetadataResponse struct { struct
144 Version int16
145 ThrottleTimeMs int32
146 Brokers []*Broker
147 ClusterID *string
148 ControllerID int32
149 Topics []*TopicMetadata
209 func (r *MetadataResponse) encode(pe packetEncoder) error {
250 func (r *MetadataResponse) key() int16 {
254 func (r *MetadataResponse) version() int16 {
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | metadata_response.go | 143 type MetadataResponse struct { struct
144 Version int16
145 ThrottleTimeMs int32
146 Brokers []*Broker
147 ClusterID *string
148 ControllerID int32
149 Topics []*TopicMetadata
209 func (r *MetadataResponse) encode(pe packetEncoder) error {
250 func (r *MetadataResponse) key() int16 {
254 func (r *MetadataResponse) version() int16 {
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | metadata_response.go | 143 type MetadataResponse struct { struct
144 Version int16
145 ThrottleTimeMs int32
146 Brokers []*Broker
147 ClusterID *string
148 ControllerID int32
149 Topics []*TopicMetadata
209 func (r *MetadataResponse) encode(pe packetEncoder) error {
250 func (r *MetadataResponse) key() int16 {
254 func (r *MetadataResponse) version() int16 {
[all …]
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | metadata_response.go | 116 type MetadataResponse struct { struct
117 Brokers []*Broker
118 Topics []*TopicMetadata
121 func (r *MetadataResponse) decode(pd packetDecoder, version int16) (err error) {
153 func (r *MetadataResponse) encode(pe packetEncoder) error {
179 func (r *MetadataResponse) key() int16 {
183 func (r *MetadataResponse) version() int16 {
187 func (r *MetadataResponse) requiredVersion() KafkaVersion {
193 func (r *MetadataResponse) AddBroker(addr string, id int32) {
197 func (r *MetadataResponse) AddTopic(topic string, err KError) *TopicMetadata {
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/ |
| H A D | metadata_response.go | 116 type MetadataResponse struct { struct
117 Brokers []*Broker
118 Topics []*TopicMetadata
121 func (m *MetadataResponse) decode(pd packetDecoder) (err error) {
153 func (m *MetadataResponse) encode(pe packetEncoder) error {
181 func (m *MetadataResponse) AddBroker(addr string, id int32) {
185 func (m *MetadataResponse) AddTopic(topic string, err KError) *TopicMetadata {
205 …se) AddTopicPartition(topic string, partition, brokerID int32, replicas, isr []int32, err KError) {
|
| /dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/ffsend-api-0.7.3/src/action/ |
| H A D | metadata.rs | 46 pub fn invoke(self, client: &Client) -> Result<MetadataResponse, Error> { in invoke()
89 ) -> Result<MetadataResponse, MetaError> { in fetch_metadata()
207 pub struct MetadataResponse { struct
218 impl<'a> MetadataResponse { impl
|
| H A D | download.rs | 61 metadata_response: Option<MetadataResponse>, in new()
161 metadata: &MetadataResponse, in create_file_reader()
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/protocol/ |
| H A D | metadata.rs | 33 pub struct MetadataResponse { struct
34 pub header: HeaderResponse,
35 pub brokers: Vec<BrokerMetadata>,
36 pub topics: Vec<TopicMetadata>,
62 impl FromByte for MetadataResponse { implementation
|
| /dports/net-im/matterbridge/matterbridge-1.22.3/vendor/github.com/keybase/go-keybase-chat-bot/kbchat/types/keybase1/ |
| H A D | metadata.go | 61 type MetadataResponse struct { struct
62 FolderID string `codec:"folderID" json:"folderID"`
63 MdBlocks []MDBlock `codec:"mdBlocks" json:"mdBlocks"`
66 func (o MetadataResponse) DeepCopy() MetadataResponse {
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/github.com/hashicorp/aws-sdk-go-base/ |
| H A D | mock.go | 322 func awsMetadataApiMock(responses []*MetadataResponse) func() {
412 type MetadataResponse struct { struct
413 Uri string `json:"uri"`
414 Body string `json:"body"`
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
| H A D | structs.py | 12 MetadataResponse = namedtuple("MetadataResponse", variable
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/ |
| H A D | metadata.py | 197 MetadataResponse = [ variable
|
| /dports/security/keybase/client-v5.7.1/go/protocol/keybase1/ |
| H A D | metadata.go | 67 type MetadataResponse struct { struct
68 FolderID string `codec:"folderID" json:"folderID"`
69 MdBlocks []MDBlock `codec:"mdBlocks" json:"mdBlocks"`
72 func (o MetadataResponse) DeepCopy() MetadataResponse {
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/client/ |
| H A D | mod.rs | 798 ) -> Result<protocol::MetadataResponse> { in fetch_metadata()
|