Skip to content

Commit a614b1d

Browse files
[Follow Up][Test] Support to set QPS and burst by configuration (#3999)
* [Follow Up][Test] Support to set QPS and burst by configuration Signed-off-by: Future-Outlier <[email protected]> * nit Signed-off-by: Future-Outlier <[email protected]> * nit Signed-off-by: Future-Outlier <[email protected]> --------- Signed-off-by: Future-Outlier <[email protected]>
1 parent 33e35de commit a614b1d

File tree

1 file changed

+31
-21
lines changed

1 file changed

+31
-21
lines changed

ray-operator/main_test.go

Lines changed: 31 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -128,13 +128,15 @@ unknownfield: 1
128128
expectErr: false,
129129
},
130130
{
131-
name: "invalid type for field",
131+
name: "set QPS and Burst",
132132
configData: `apiVersion: config.ray.io/v1alpha1
133133
kind: Configuration
134134
metricsAddr: ":8080"
135135
probeAddr: ":8082"
136136
enableLeaderElection: true
137-
reconcileConcurrency: true
137+
reconcileConcurrency: 1
138+
qps: 150.5
139+
burst: 300
138140
`,
139141
expectedConfig: configapi.Configuration{
140142
TypeMeta: metav1.TypeMeta{
@@ -144,38 +146,46 @@ reconcileConcurrency: true
144146
MetricsAddr: ":8080",
145147
ProbeAddr: ":8082",
146148
EnableLeaderElection: ptr.To(true),
147-
ReconcileConcurrency: 0,
148-
QPS: ptr.To(configapi.DefaultQPS),
149-
Burst: ptr.To(configapi.DefaultBurst),
149+
ReconcileConcurrency: 1,
150+
QPS: ptr.To(150.5),
151+
Burst: ptr.To(300),
150152
},
151-
expectErr: true,
152-
errContains: "json: cannot unmarshal bool into Go struct field Configuration.reconcileConcurrency of type int",
153+
expectErr: false,
153154
},
154155
{
155-
name: "invalid version for config",
156-
configData: `apiVersion: config.ray.io/v1beta1
156+
name: "set Burst using float",
157+
configData: `apiVersion: config.ray.io/v1alpha1
157158
kind: Configuration
158159
metricsAddr: ":8080"
159160
probeAddr: ":8082"
160161
enableLeaderElection: true
161-
reconcileConcurrency: true
162+
reconcileConcurrency: 1
163+
qps: 150
164+
burst: 300.5
162165
`,
163166
expectedConfig: configapi.Configuration{
167+
TypeMeta: metav1.TypeMeta{
168+
Kind: "Configuration",
169+
APIVersion: "config.ray.io/v1alpha1",
170+
},
164171
MetricsAddr: ":8080",
165172
ProbeAddr: ":8082",
166173
EnableLeaderElection: ptr.To(true),
167-
QPS: ptr.To(configapi.DefaultQPS),
168-
Burst: ptr.To(configapi.DefaultBurst),
174+
ReconcileConcurrency: 1,
175+
QPS: ptr.To(150.0),
176+
Burst: ptr.To(300),
169177
},
170178
expectErr: true,
171-
errContains: `no kind "Configuration" is registered for version "config.ray.io/v1beta1" in scheme`,
179+
errContains: "json: cannot unmarshal number 300.5 into Go struct field Configuration.burst of type int",
172180
},
173181
{
174-
name: "set QPS and Burst",
175-
configData: `apiVersion: config.ray.io/v1beta1
182+
name: "invalid type for field",
183+
configData: `apiVersion: config.ray.io/v1alpha1
176184
kind: Configuration
177-
qps: 150
178-
burst: 300
185+
metricsAddr: ":8080"
186+
probeAddr: ":8082"
187+
enableLeaderElection: true
188+
reconcileConcurrency: true
179189
`,
180190
expectedConfig: configapi.Configuration{
181191
TypeMeta: metav1.TypeMeta{
@@ -185,12 +195,12 @@ burst: 300
185195
MetricsAddr: ":8080",
186196
ProbeAddr: ":8082",
187197
EnableLeaderElection: ptr.To(true),
188-
ReconcileConcurrency: 1,
189-
QPS: ptr.To((150.0)),
190-
Burst: ptr.To(300),
198+
ReconcileConcurrency: 0,
199+
QPS: ptr.To(configapi.DefaultQPS),
200+
Burst: ptr.To(configapi.DefaultBurst),
191201
},
192202
expectErr: true,
193-
errContains: `no kind "Configuration" is registered for version "config.ray.io/v1beta1" in scheme`,
203+
errContains: "json: cannot unmarshal bool into Go struct field Configuration.reconcileConcurrency of type int",
194204
},
195205
{
196206
name: "Set ReconcileConcurrency",

0 commit comments

Comments
 (0)