Skip to content

Commit 1246366

Browse files
committed
Remove redundant type conversions and annotations
1 parent ae199bb commit 1246366

File tree

5 files changed

+18
-18
lines changed

5 files changed

+18
-18
lines changed

api/v1beta1/rabbitmqcluster_types_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ var _ = Describe("RabbitmqCluster", func() {
163163
Image: "rabbitmq-image-from-cr",
164164
ImagePullSecret: "my-super-secret",
165165
Service: RabbitmqClusterServiceSpec{
166-
Type: corev1.ServiceType("this-is-a-service"),
166+
Type: "this-is-a-service",
167167
Annotations: map[string]string{
168168
"myannotation": "is-set",
169169
},
@@ -186,7 +186,7 @@ var _ = Describe("RabbitmqCluster", func() {
186186
NodeAffinity: &corev1.NodeAffinity{
187187
RequiredDuringSchedulingIgnoredDuringExecution: &corev1.NodeSelector{
188188
NodeSelectorTerms: []corev1.NodeSelectorTerm{
189-
corev1.NodeSelectorTerm{
189+
{
190190
MatchExpressions: []corev1.NodeSelectorRequirement{
191191
{
192192
Key: "somekey",
@@ -201,7 +201,7 @@ var _ = Describe("RabbitmqCluster", func() {
201201
},
202202
},
203203
Tolerations: []corev1.Toleration{
204-
corev1.Toleration{
204+
{
205205
Key: "mykey",
206206
Operator: "NotEqual",
207207
Value: "myvalue",
@@ -325,15 +325,15 @@ var _ = Describe("RabbitmqCluster", func() {
325325

326326
It("updates an arbitrary condition", func() {
327327
someCondition := status.RabbitmqClusterCondition{}
328-
someCondition.Type = status.RabbitmqClusterConditionType("a-type")
328+
someCondition.Type = "a-type"
329329
someCondition.Reason = "whynot"
330-
someCondition.Status = corev1.ConditionStatus("perhaps")
330+
someCondition.Status = "perhaps"
331331
someCondition.LastTransitionTime = metav1.Unix(10, 0)
332332
rmqStatus := RabbitmqClusterStatus{
333333
Conditions: []status.RabbitmqClusterCondition{someCondition},
334334
}
335335

336-
rmqStatus.SetCondition(status.RabbitmqClusterConditionType("a-type"),
336+
rmqStatus.SetCondition("a-type",
337337
corev1.ConditionTrue, "some-reason", "my-message")
338338

339339
updatedCondition := rmqStatus.Conditions[0]

internal/resource/client_service.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ func (builder *ClientServiceBuilder) Update(object runtime.Object) error {
5252
service := object.(*corev1.Service)
5353
builder.setAnnotations(service)
5454
service.Labels = metadata.GetLabels(builder.Instance.Name, builder.Instance.Labels)
55-
service.Spec.Type = corev1.ServiceType(builder.Instance.Spec.Service.Type)
55+
service.Spec.Type = builder.Instance.Spec.Service.Type
5656
service.Spec.Selector = metadata.LabelSelector(builder.Instance.Name)
5757

5858
service.Spec.Ports = builder.updatePorts(service.Spec.Ports)

internal/resource/client_service_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -334,13 +334,13 @@ var _ = Context("ClientServices", func() {
334334
It("preserves the same node ports after updating from LoadBalancer to NodePort", func() {
335335
svc.Spec.Type = corev1.ServiceTypeLoadBalancer
336336
svc.Spec.Ports = []corev1.ServicePort{
337-
corev1.ServicePort{
337+
{
338338
Protocol: corev1.ProtocolTCP,
339339
Port: 5672,
340340
Name: "amqp",
341341
NodePort: 12345,
342342
},
343-
corev1.ServicePort{
343+
{
344344
Protocol: corev1.ProtocolTCP,
345345
Port: 15672,
346346
Name: "management",
@@ -372,7 +372,7 @@ var _ = Context("ClientServices", func() {
372372
It("unsets nodePort after updating from NodePort to ClusterIP", func() {
373373
svc.Spec.Type = corev1.ServiceTypeNodePort
374374
svc.Spec.Ports = []corev1.ServicePort{
375-
corev1.ServicePort{
375+
{
376376
Protocol: corev1.ProtocolTCP,
377377
Port: 5672,
378378
Name: "amqp",
@@ -399,7 +399,7 @@ var _ = Context("ClientServices", func() {
399399
It("unsets the service type and node ports when service type is deleted from CR spec", func() {
400400
svc.Spec.Type = corev1.ServiceTypeNodePort
401401
svc.Spec.Ports = []corev1.ServicePort{
402-
corev1.ServicePort{
402+
{
403403
Protocol: corev1.ProtocolTCP,
404404
Port: 5672,
405405
Name: "amqp",

internal/resource/statefulset_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1409,7 +1409,7 @@ func generateRabbitmqCluster() rabbitmqv1beta1.RabbitmqCluster {
14091409
Image: "rabbitmq-image-from-cr",
14101410
ImagePullSecret: "my-super-secret",
14111411
Service: rabbitmqv1beta1.RabbitmqClusterServiceSpec{
1412-
Type: corev1.ServiceType("this-is-a-service"),
1412+
Type: "this-is-a-service",
14131413
Annotations: map[string]string{},
14141414
},
14151415
Persistence: rabbitmqv1beta1.RabbitmqClusterPersistenceSpec{
@@ -1430,7 +1430,7 @@ func generateRabbitmqCluster() rabbitmqv1beta1.RabbitmqCluster {
14301430
NodeAffinity: &corev1.NodeAffinity{
14311431
RequiredDuringSchedulingIgnoredDuringExecution: &corev1.NodeSelector{
14321432
NodeSelectorTerms: []corev1.NodeSelectorTerm{
1433-
corev1.NodeSelectorTerm{
1433+
{
14341434
MatchExpressions: []corev1.NodeSelectorRequirement{
14351435
{
14361436
Key: "somekey",
@@ -1445,7 +1445,7 @@ func generateRabbitmqCluster() rabbitmqv1beta1.RabbitmqCluster {
14451445
},
14461446
},
14471447
Tolerations: []corev1.Toleration{
1448-
corev1.Toleration{
1448+
{
14491449
Key: "mykey",
14501450
Operator: "NotEqual",
14511451
Value: "myvalue",

internal/status/status_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,16 +20,16 @@ var _ = Describe("Status", func() {
2020
BeforeEach(func() {
2121
someConditionTime = metav1.Unix(1, 1)
2222
someCondition = RabbitmqClusterCondition{
23-
Type: RabbitmqClusterConditionType("a-type"),
24-
Status: corev1.ConditionStatus("some-status"),
23+
Type: "a-type",
24+
Status: "some-status",
2525
LastTransitionTime: (*someConditionTime.DeepCopy()),
2626
Reason: "reasons",
2727
Message: "ship-it",
2828
}
2929
})
3030

3131
It("changes the status and transition time", func() {
32-
someCondition.UpdateState(corev1.ConditionStatus("maybe"))
32+
someCondition.UpdateState("maybe")
3333
Expect(someCondition.Status).To(Equal(corev1.ConditionStatus("maybe")))
3434

3535
Expect(someCondition.LastTransitionTime).NotTo(Equal(someConditionTime))
@@ -38,7 +38,7 @@ var _ = Describe("Status", func() {
3838
})
3939

4040
It("preserves the status and transtion time", func() {
41-
someCondition.UpdateState(corev1.ConditionStatus("some-status"))
41+
someCondition.UpdateState("some-status")
4242
Expect(someCondition.Status).To(Equal(corev1.ConditionStatus("some-status")))
4343
Expect(someCondition.LastTransitionTime).To(Equal(someConditionTime))
4444
})

0 commit comments

Comments
 (0)