kesavand | c71914f | 2022-03-25 11:19:03 +0530 | [diff] [blame] | 1 | package sarama |
| 2 | |
| 3 | type ( |
| 4 | QuotaEntityType string |
| 5 | |
| 6 | QuotaMatchType int |
| 7 | ) |
| 8 | |
| 9 | // ref: https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/quota/ClientQuotaEntity.java |
| 10 | const ( |
| 11 | QuotaEntityUser QuotaEntityType = "user" |
| 12 | QuotaEntityClientID QuotaEntityType = "client-id" |
| 13 | QuotaEntityIP QuotaEntityType = "ip" |
| 14 | ) |
| 15 | |
| 16 | // ref: https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java |
| 17 | const ( |
| 18 | QuotaMatchExact QuotaMatchType = iota |
| 19 | QuotaMatchDefault |
| 20 | QuotaMatchAny |
| 21 | ) |