| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | functional_consumer_test.go | 115 func versionRange(lower KafkaVersion) []KafkaVersion {
136 func produceMsgs(t *testing.T, clientVersions []KafkaVersion, codecs []CompressionCodec, flush int,…
185 func consumeMsgs(t *testing.T, clientVersions []KafkaVersion, producedMessages []*ProducerMessage) {
|
| H A D | utils.go | 113 type KafkaVersion struct { struct
116 version [4]uint
129 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
208 func (v KafkaVersion) String() string {
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-kafka/source/model/ |
| H A D | KafkaVersion.cpp | 21 KafkaVersion::KafkaVersion() : in KafkaVersion() function in Aws::Kafka::Model::KafkaVersion
28 KafkaVersion::KafkaVersion(JsonView jsonValue) : in KafkaVersion() function in Aws::Kafka::Model::KafkaVersion
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/Shopify/sarama/ |
| H A D | functional_consumer_test.go | 171 func versionRange(lower KafkaVersion) []KafkaVersion {
192 func produceMsgs(t *testing.T, clientVersions []KafkaVersion, codecs []CompressionCodec, flush int,…
246 func consumeMsgs(t *testing.T, clientVersions []KafkaVersion, producedMessages []*ProducerMessage) {
|
| H A D | utils.go | 111 type KafkaVersion struct { struct
114 version [4]uint
127 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
228 func (v KafkaVersion) String() string {
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/sarama-1.26.4/ |
| H A D | functional_consumer_test.go | 169 func versionRange(lower KafkaVersion) []KafkaVersion {
190 func produceMsgs(t *testing.T, clientVersions []KafkaVersion, codecs []CompressionCodec, flush int,…
244 func consumeMsgs(t *testing.T, clientVersions []KafkaVersion, producedMessages []*ProducerMessage) {
|
| H A D | utils.go | 111 type KafkaVersion struct { struct
114 version [4]uint
127 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
221 func (v KafkaVersion) String() string {
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | utils.go | 113 type KafkaVersion struct { struct
116 version [4]uint
129 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
208 func (v KafkaVersion) String() string {
|
| /dports/net/goreplay/goreplay-1.2.0/vendor/github.com/Shopify/sarama/ |
| H A D | utils.go | 111 type KafkaVersion struct { struct
114 version [4]uint
127 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
221 func (v KafkaVersion) String() string {
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | utils.go | 111 type KafkaVersion struct { struct
114 version [4]uint
127 func (v KafkaVersion) IsAtLeast(other KafkaVersion) bool {
|
| /dports/security/vault/aws-sdk-go-v2-fdbaadbce5fd/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
407 type KafkaVersion struct { struct
408 Status KafkaVersionStatus
410 Version *string
436 KafkaVersion *string member
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aws/aws-sdk-go-v2/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
407 type KafkaVersion struct { struct
408 Status KafkaVersionStatus
410 Version *string
436 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/aws/aws-sdk-go-v2/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
407 type KafkaVersion struct { struct
408 Status KafkaVersionStatus
410 Version *string
433 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/aws-sdk-go-v2-be1c89938486/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
407 type KafkaVersion struct { struct
408 Status KafkaVersionStatus
410 Version *string
433 KafkaVersion *string member
|
| /dports/security/vault/aws-sdk-go-v2-1.5.0/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
414 type KafkaVersion struct { struct
415 Status KafkaVersionStatus
417 Version *string
443 KafkaVersion *string member
|
| /dports/security/vault/aws-sdk-go-v2-credentials-v1.1.5/service/kafka/types/ |
| H A D | types.go | 104 KafkaVersion *string member
407 type KafkaVersion struct { struct
408 Status KafkaVersionStatus
410 Version *string
436 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/aws-sdk-go-v2-a930583ec379/service/kafka/types/ |
| H A D | types.go | 113 KafkaVersion *string member
466 type KafkaVersion struct { struct
467 Status KafkaVersionStatus
469 Version *string
471 noSmithyDocumentSerde
505 KafkaVersion *string member
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aws/aws-sdk-go-v2/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/security/vault/aws-sdk-go-v2-fdbaadbce5fd/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/aws-sdk-go-v2-credentials-v1.1.1/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/aws/aws-sdk-go-v2/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/aws-sdk-go-v2-be1c89938486/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/security/vault/aws-sdk-go-v2-credentials-v1.1.5/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/security/vault/aws-sdk-go-v2-1.5.0/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|
| /dports/net-p2p/go-ethereum/aws-sdk-go-v2-a930583ec379/service/kafka/ |
| H A D | api_op_CreateCluster.go | 45 KafkaVersion *string member
|