Home
last modified time | relevance | path

Searched refs:PartitionMetadata (Results 1 – 25 of 54) sorted by relevance

123

/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
11 func (pm *PartitionMetadata) decode(pd packetDecoder) (err error) { argument
41 func (pm *PartitionMetadata) encode(pe packetEncoder) (err error) { argument
62 Partitions []*PartitionMetadata
81 tm.Partitions = make([]*PartitionMetadata, n)
83 tm.Partitions[i] = new(PartitionMetadata)
207 var pmatch *PartitionMetadata
216 pmatch = new(PartitionMetadata)
H A Dclient.go92 metadata map[string]map[int32]*PartitionMetadata // maps topics to partition ids to metadata
125 metadata: make(map[string]map[int32]*PartitionMetadata),
450 func (client *client) cachedMetadata(topic string, partitionID int32) *PartitionMetadata {
650 client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
11 func (pm *PartitionMetadata) decode(pd packetDecoder) (err error) { argument
41 func (pm *PartitionMetadata) encode(pe packetEncoder) (err error) { argument
62 Partitions []*PartitionMetadata
81 tm.Partitions = make([]*PartitionMetadata, n)
83 tm.Partitions[i] = new(PartitionMetadata)
219 var pmatch *PartitionMetadata
228 pmatch = new(PartitionMetadata)
H A Dclient.go101 metadata map[string]map[int32]*PartitionMetadata // maps topics to partition ids to metadata
134 metadata: make(map[string]map[int32]*PartitionMetadata),
496 func (client *client) cachedMetadata(topic string, partitionID int32) *PartitionMetadata {
712 client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
12 func (pm *PartitionMetadata) decode(pd packetDecoder, version int16) (err error) { argument
49 func (pm *PartitionMetadata) encode(pe packetEncoder, version int16) (err error) { argument
78 Partitions []*PartitionMetadata
104 tm.Partitions = make([]*PartitionMetadata, n)
106 tm.Partitions[i] = new(PartitionMetadata)
305 var pmatch *PartitionMetadata
314 pmatch = new(PartitionMetadata)
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
12 func (pm *PartitionMetadata) decode(pd packetDecoder, version int16) (err error) { argument
49 func (pm *PartitionMetadata) encode(pe packetEncoder, version int16) (err error) { argument
78 Partitions []*PartitionMetadata
104 tm.Partitions = make([]*PartitionMetadata, n)
106 tm.Partitions[i] = new(PartitionMetadata)
301 var pmatch *PartitionMetadata
310 pmatch = new(PartitionMetadata)
H A Dclient.go105 metadata map[string]map[int32]*PartitionMetadata // maps topics to partition ids to metadata
139 metadata: make(map[string]map[int32]*PartitionMetadata),
544 func (client *client) cachedMetadata(topic string, partitionID int32) *PartitionMetadata {
753 client.metadata = make(map[string]map[int32]*PartitionMetadata)
786 client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))
/dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
12 func (pm *PartitionMetadata) decode(pd packetDecoder, version int16) (err error) { argument
49 func (pm *PartitionMetadata) encode(pe packetEncoder, version int16) (err error) { argument
78 Partitions []*PartitionMetadata
104 tm.Partitions = make([]*PartitionMetadata, n)
106 tm.Partitions[i] = new(PartitionMetadata)
301 var pmatch *PartitionMetadata
310 pmatch = new(PartitionMetadata)
H A Dclient.go105 metadata map[string]map[int32]*PartitionMetadata // maps topics to partition ids to metadata
139 metadata: make(map[string]map[int32]*PartitionMetadata),
544 func (client *client) cachedMetadata(topic string, partitionID int32) *PartitionMetadata {
753 client.metadata = make(map[string]map[int32]*PartitionMetadata)
786 client.metadata[topic.Name] = make(map[int32]*PartitionMetadata, len(topic.Partitions))
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
12 func (pm *PartitionMetadata) decode(pd packetDecoder, version int16) (err error) { argument
49 func (pm *PartitionMetadata) encode(pe packetEncoder, version int16) (err error) { argument
78 Partitions []*PartitionMetadata
104 tm.Partitions = make([]*PartitionMetadata, n)
106 tm.Partitions[i] = new(PartitionMetadata)
305 var pmatch *PartitionMetadata
314 pmatch = new(PartitionMetadata)
/dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/
H A Dmetadata_response.go3 type PartitionMetadata struct { struct
12 func (pm *PartitionMetadata) decode(pd packetDecoder, version int16) (err error) { argument
49 func (pm *PartitionMetadata) encode(pe packetEncoder, version int16) (err error) { argument
78 Partitions []*PartitionMetadata
104 tm.Partitions = make([]*PartitionMetadata, n)
106 tm.Partitions[i] = new(PartitionMetadata)
305 var pmatch *PartitionMetadata
314 pmatch = new(PartitionMetadata)
/dports/net/p5-Kafka/Kafka-0.8010/t/lib/Kafka/
H A DMockProtocol.pm800 my $PartitionMetadata_array = $TopicMetadata->{PartitionMetadata} // [];
807 foreach my $PartitionMetadata ( @$PartitionMetadata_array ) {
808 …( defined( $PartitionMetadata->{ErrorCode} ) && isint( $PartitionMetadata->{ErrorCode} ) ) # Erro…
809 ? push( @data, $PartitionMetadata->{ErrorCode} )
811 …( defined( $PartitionMetadata->{Partition} ) && isint( $PartitionMetadata->{Partition} ) ) # Part…
812 ? push( @data, $PartitionMetadata->{Partition} )
814 … ( defined( $PartitionMetadata->{Leader} ) && isint( $PartitionMetadata->{Leader} ) ) # Leader
815 ? push( @data, $PartitionMetadata->{Leader} )
817 my $Replicas_array = $PartitionMetadata->{Replicas} // [];
832 my $Isr_array = $PartitionMetadata->{Isr} // [];
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A DMetadataImpl.cpp34 PartitionMetadata::~PartitionMetadata() {}; in ~PartitionMetadata()
62 class PartitionMetadataImpl : public PartitionMetadata {
117 const std::vector<const PartitionMetadata *> *partitions() const { in partitions()
125 std::vector<const PartitionMetadata *> partitions_;
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A DMetadataImpl.cpp34 PartitionMetadata::~PartitionMetadata() {}; in ~PartitionMetadata()
62 class PartitionMetadataImpl : public PartitionMetadata {
117 const std::vector<const PartitionMetadata *> *partitions() const { in partitions()
125 std::vector<const PartitionMetadata *> partitions_;
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A DMetadataImpl.cpp34 PartitionMetadata::~PartitionMetadata() {}; in ~PartitionMetadata()
62 class PartitionMetadataImpl : public PartitionMetadata {
117 const std::vector<const PartitionMetadata *> *partitions() const { in partitions()
125 std::vector<const PartitionMetadata *> partitions_;
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/src/protocol/
H A Dmetadata.rs50 pub partitions: Vec<PartitionMetadata>,
54 pub struct PartitionMetadata { struct
97 impl FromByte for PartitionMetadata { implementation
98 type R = PartitionMetadata;
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/protocol/
H A Dmetadata_test.exs42 %KafkaEx.Protocol.Metadata.PartitionMetadata{
80 %KafkaEx.Protocol.Metadata.PartitionMetadata{
141 %KafkaEx.Protocol.Metadata.PartitionMetadata{
196 %KafkaEx.Protocol.Metadata.PartitionMetadata{
254 %KafkaEx.Protocol.Metadata.PartitionMetadata{
309 %KafkaEx.Protocol.Metadata.PartitionMetadata{
349 partition_metadata = %KafkaEx.Protocol.Metadata.PartitionMetadata{
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/
H A Dmetadata.ex97 alias KafkaEx.Protocol.Metadata.PartitionMetadata
108 partition_metadatas: [PartitionMetadata.t()]
112 defmodule PartitionMetadata do module
120 @type t :: %PartitionMetadata{
333 %PartitionMetadata{
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/kafka_ex/
H A Ddefault_partitioner_test.exs8 alias KafkaEx.Protocol.Metadata.PartitionMetadata
21 %PartitionMetadata{
/dports/net/p5-Kafka/Kafka-0.8010/lib/Kafka/
H A DProtocol.pm1046 my $PartitionMetadata_array = $TopicMetadata->{PartitionMetadata} = [];
1049 my $PartitionMetadata = {
1055 my $Replicas_array = $PartitionMetadata->{Replicas} = [];
1061 my $Isr_array = $PartitionMetadata->{Isr} = [];
1067 push( @$PartitionMetadata_array, $PartitionMetadata );
/dports/net-mgmt/librenms/librenms-vendor-21.5.1/symfony/var-dumper/Caster/
H A DRdKafkaCaster.php20 use RdKafka\Metadata\Partition as PartitionMetadata; alias
143 …public static function castPartitionMetadata(PartitionMetadata $c, array $a, Stub $stub, $isNested)
/dports/www/typo3-11/typo3_src-11.5.7/vendor/symfony/var-dumper/Caster/
H A DRdKafkaCaster.php20 use RdKafka\Metadata\Partition as PartitionMetadata; alias
143 …public static function castPartitionMetadata(PartitionMetadata $c, array $a, Stub $stub, bool $isN…
/dports/www/drupal9/drupal-9.2.10/vendor/symfony/var-dumper/Caster/
H A DRdKafkaCaster.php20 use RdKafka\Metadata\Partition as PartitionMetadata; alias
143 …public static function castPartitionMetadata(PartitionMetadata $c, array $a, Stub $stub, $isNested)
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/
H A Dstructs.py71 PartitionMetadata = namedtuple("PartitionMetadata", variable
/dports/net/p5-Kafka/Kafka-0.8010/t/
H A D42_nonfatal_errors.t184 PartitionMetadata => [
234 PartitionMetadata => [

123