@@ -21,37 +21,37 @@ import (
21
21
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
22
22
23
23
"github.com/open-telemetry/opentelemetry-operator/apis/v1alpha1"
24
- "github.com/open-telemetry/opentelemetry-operator/apis/v1alpha2 "
24
+ "github.com/open-telemetry/opentelemetry-operator/apis/v1beta1 "
25
25
)
26
26
27
- func V1Alpha1to2 (in v1alpha1.OpenTelemetryCollector ) (v1alpha2 .OpenTelemetryCollector , error ) {
27
+ func V1Alpha1to2 (in v1alpha1.OpenTelemetryCollector ) (v1beta1 .OpenTelemetryCollector , error ) {
28
28
copy := in .DeepCopy ()
29
- out := v1alpha2 .OpenTelemetryCollector {
29
+ out := v1beta1 .OpenTelemetryCollector {
30
30
TypeMeta : copy .TypeMeta ,
31
31
ObjectMeta : copy .ObjectMeta ,
32
32
}
33
33
34
- cfg := & v1alpha2 .Config {}
34
+ cfg := & v1beta1 .Config {}
35
35
if err := yaml .Unmarshal ([]byte (in .Spec .Config ), cfg ); err != nil {
36
- return v1alpha2 .OpenTelemetryCollector {}, errors .New ("could not convert config json to v1alpha2 .Config" )
36
+ return v1beta1 .OpenTelemetryCollector {}, errors .New ("could not convert config json to v1beta1 .Config" )
37
37
}
38
38
out .Spec .Config = * cfg
39
39
40
- out .Spec .OpenTelemetryCommonFields .ManagementState = v1alpha2 .ManagementStateType (copy .Spec .ManagementState )
40
+ out .Spec .OpenTelemetryCommonFields .ManagementState = v1beta1 .ManagementStateType (copy .Spec .ManagementState )
41
41
out .Spec .OpenTelemetryCommonFields .Resources = copy .Spec .Resources
42
42
out .Spec .OpenTelemetryCommonFields .NodeSelector = copy .Spec .NodeSelector
43
43
out .Spec .OpenTelemetryCommonFields .Args = copy .Spec .NodeSelector
44
44
out .Spec .OpenTelemetryCommonFields .Replicas = copy .Spec .Replicas
45
45
46
46
if copy .Spec .Autoscaler != nil {
47
- metrics := make ([]v1alpha2 .MetricSpec , len (copy .Spec .Autoscaler .Metrics ))
47
+ metrics := make ([]v1beta1 .MetricSpec , len (copy .Spec .Autoscaler .Metrics ))
48
48
for i , m := range copy .Spec .Autoscaler .Metrics {
49
- metrics [i ] = v1alpha2 .MetricSpec {
49
+ metrics [i ] = v1beta1 .MetricSpec {
50
50
Type : m .Type ,
51
51
Pods : m .Pods ,
52
52
}
53
53
}
54
- out .Spec .OpenTelemetryCommonFields .Autoscaler = & v1alpha2 .AutoscalerSpec {
54
+ out .Spec .OpenTelemetryCommonFields .Autoscaler = & v1beta1 .AutoscalerSpec {
55
55
MinReplicas : copy .Spec .Autoscaler .MinReplicas ,
56
56
MaxReplicas : copy .Spec .Autoscaler .MaxReplicas ,
57
57
Behavior : copy .Spec .Autoscaler .Behavior ,
@@ -62,7 +62,7 @@ func V1Alpha1to2(in v1alpha1.OpenTelemetryCollector) (v1alpha2.OpenTelemetryColl
62
62
}
63
63
64
64
if copy .Spec .PodDisruptionBudget != nil {
65
- out .Spec .OpenTelemetryCommonFields .PodDisruptionBudget = & v1alpha2 .PodDisruptionBudgetSpec {
65
+ out .Spec .OpenTelemetryCommonFields .PodDisruptionBudget = & v1beta1 .PodDisruptionBudgetSpec {
66
66
MinAvailable : copy .Spec .PodDisruptionBudget .MinAvailable ,
67
67
MaxUnavailable : copy .Spec .PodDisruptionBudget .MaxUnavailable ,
68
68
}
@@ -96,18 +96,18 @@ func V1Alpha1to2(in v1alpha1.OpenTelemetryCollector) (v1alpha2.OpenTelemetryColl
96
96
97
97
out .Spec .TargetAllocator = TargetAllocatorEmbedded (copy .Spec .TargetAllocator )
98
98
99
- out .Spec .Mode = v1alpha2 .Mode (copy .Spec .Mode )
100
- out .Spec .UpgradeStrategy = v1alpha2 .UpgradeStrategy (copy .Spec .UpgradeStrategy )
101
- out .Spec .Ingress .Type = v1alpha2 .IngressType (copy .Spec .Ingress .Type )
102
- out .Spec .Ingress .RuleType = v1alpha2 .IngressRuleType (copy .Spec .Ingress .RuleType )
99
+ out .Spec .Mode = v1beta1 .Mode (copy .Spec .Mode )
100
+ out .Spec .UpgradeStrategy = v1beta1 .UpgradeStrategy (copy .Spec .UpgradeStrategy )
101
+ out .Spec .Ingress .Type = v1beta1 .IngressType (copy .Spec .Ingress .Type )
102
+ out .Spec .Ingress .RuleType = v1beta1 .IngressRuleType (copy .Spec .Ingress .RuleType )
103
103
out .Spec .Ingress .Hostname = copy .Spec .Ingress .Hostname
104
104
out .Spec .Ingress .Annotations = copy .Spec .Ingress .Annotations
105
105
out .Spec .Ingress .TLS = copy .Spec .Ingress .TLS
106
106
out .Spec .Ingress .IngressClassName = copy .Spec .Ingress .IngressClassName
107
- out .Spec .Ingress .Route .Termination = v1alpha2 .TLSRouteTerminationType (copy .Spec .Ingress .Route .Termination )
107
+ out .Spec .Ingress .Route .Termination = v1beta1 .TLSRouteTerminationType (copy .Spec .Ingress .Route .Termination )
108
108
109
109
if copy .Spec .LivenessProbe != nil {
110
- out .Spec .LivenessProbe = & v1alpha2 .Probe {
110
+ out .Spec .LivenessProbe = & v1beta1 .Probe {
111
111
InitialDelaySeconds : copy .Spec .LivenessProbe .InitialDelaySeconds ,
112
112
TimeoutSeconds : copy .Spec .LivenessProbe .TimeoutSeconds ,
113
113
PeriodSeconds : copy .Spec .LivenessProbe .PeriodSeconds ,
@@ -127,13 +127,13 @@ func V1Alpha1to2(in v1alpha1.OpenTelemetryCollector) (v1alpha2.OpenTelemetryColl
127
127
return out , nil
128
128
}
129
129
130
- func TargetAllocatorEmbedded (in v1alpha1.OpenTelemetryTargetAllocator ) v1alpha2 .TargetAllocatorEmbedded {
131
- out := v1alpha2 .TargetAllocatorEmbedded {}
130
+ func TargetAllocatorEmbedded (in v1alpha1.OpenTelemetryTargetAllocator ) v1beta1 .TargetAllocatorEmbedded {
131
+ out := v1beta1 .TargetAllocatorEmbedded {}
132
132
out .Replicas = in .Replicas
133
133
out .NodeSelector = in .NodeSelector
134
134
out .Resources = in .Resources
135
- out .AllocationStrategy = v1alpha2 .TargetAllocatorAllocationStrategy (in .AllocationStrategy )
136
- out .FilterStrategy = v1alpha2 .TargetAllocatorFilterStrategy (in .FilterStrategy )
135
+ out .AllocationStrategy = v1beta1 .TargetAllocatorAllocationStrategy (in .AllocationStrategy )
136
+ out .FilterStrategy = v1beta1 .TargetAllocatorFilterStrategy (in .FilterStrategy )
137
137
out .ServiceAccount = in .ServiceAccount
138
138
out .Image = in .Image
139
139
out .Enabled = in .Enabled
@@ -158,7 +158,7 @@ func TargetAllocatorEmbedded(in v1alpha1.OpenTelemetryTargetAllocator) v1alpha2.
158
158
MatchLabels : in .PrometheusCR .ServiceMonitorSelector ,
159
159
}
160
160
if in .PodDisruptionBudget != nil {
161
- out .PodDisruptionBudget = & v1alpha2 .PodDisruptionBudgetSpec {
161
+ out .PodDisruptionBudget = & v1beta1 .PodDisruptionBudgetSpec {
162
162
MinAvailable : in .PodDisruptionBudget .MinAvailable ,
163
163
MaxUnavailable : in .PodDisruptionBudget .MaxUnavailable ,
164
164
}
0 commit comments