File tree Expand file tree Collapse file tree 2 files changed +22
-6
lines changed Expand file tree Collapse file tree 2 files changed +22
-6
lines changed Original file line number Diff line number Diff line change @@ -23,25 +23,41 @@ type AlterClientQuotasRequest struct {
23
23
}
24
24
25
25
type AlterClientQuotaEntry struct {
26
+ // The quota entities to alter.
26
27
Entities []AlterClientQuotaEntity
27
- Ops []AlterClientQuotaOps
28
+
29
+ // An individual quota configuration entry to alter.
30
+ Ops []AlterClientQuotaOps
28
31
}
29
32
30
33
type AlterClientQuotaEntity struct {
34
+ // The quota entity type.
31
35
EntityType string
36
+
37
+ // The name of the quota entity, or null if the default.
32
38
EntityName string
33
39
}
34
40
35
41
type AlterClientQuotaOps struct {
36
- Key string
37
- Value float64
42
+ // The quota configuration key.
43
+ Key string
44
+
45
+ // The quota configuration value to set, otherwise ignored if the value is to be removed.
46
+ Value float64
47
+
48
+ // Whether the quota configuration value should be removed, otherwise set.
38
49
Remove bool
39
50
}
40
51
41
52
type AlterClientQuotaResponseQuotas struct {
42
- ErrorCode int16
53
+ // The error code, or `0` if the quota alteration succeeded.
54
+ ErrorCode int16
55
+
56
+ // The error message, or `nil` if the quota alteration succeeded.
43
57
ErrorMessage string
44
- Entities []AlterClientQuotaEntity
58
+
59
+ // The altered quota entities
60
+ Entities []AlterClientQuotaEntity
45
61
}
46
62
47
63
// AlterClientQuotasResponse represents a response from a kafka broker to an alter client
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ func TestClientAlterClientQuotas(t *testing.T) {
23
23
client , shutdown := newLocalClient ()
24
24
defer shutdown ()
25
25
26
- resp , err := client .AlterClientQuotas (context .Background (), & AlterClientQuotasRequest {
26
+ _ , err := client .AlterClientQuotas (context .Background (), & AlterClientQuotasRequest {
27
27
Entries : []AlterClientQuotaEntry {
28
28
AlterClientQuotaEntry {
29
29
Entities : []AlterClientQuotaEntity {
You can’t perform that action at this time.
0 commit comments