/
ingress_builder.go
67 lines (57 loc) · 1.85 KB
/
ingress_builder.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package logstash
import (
logstashcrd "github.com/webcenter-fr/elasticsearch-operator/apis/logstash/v1"
networkingv1 "k8s.io/api/networking/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// BuildIngresses permit to generate Ingresses object
// It will overwrite the target service
func buildIngresses(ls *logstashcrd.Logstash) (ingresses []networkingv1.Ingress, err error) {
ingresses = make([]networkingv1.Ingress, 0, len(ls.Spec.Ingresses))
var (
ingress *networkingv1.Ingress
)
for _, i := range ls.Spec.Ingresses {
// Global ingress
ingress = &networkingv1.Ingress{
ObjectMeta: metav1.ObjectMeta{
Namespace: ls.Namespace,
Name: GetIngressName(ls, i.Name),
Labels: getLabels(ls, i.Labels),
Annotations: getAnnotations(ls, i.Annotations),
},
Spec: *i.Spec.DeepCopy(),
}
for indexRule, rule := range ingress.Spec.Rules {
if rule.HTTP != nil && len(rule.HTTP.Paths) > 0 {
for indexPath, path := range rule.HTTP.Paths {
path.Backend = networkingv1.IngressBackend{
Service: &networkingv1.IngressServiceBackend{
Name: GetServiceName(ls, i.Name),
Port: networkingv1.ServiceBackendPort{
Number: int32(i.ContainerPort),
},
},
}
rule.HTTP.Paths[indexPath] = path
}
}
if rule.IngressRuleValue.HTTP != nil && len(rule.IngressRuleValue.HTTP.Paths) > 0 {
for indexPath, path := range rule.IngressRuleValue.HTTP.Paths {
path.Backend = networkingv1.IngressBackend{
Service: &networkingv1.IngressServiceBackend{
Name: GetServiceName(ls, i.Name),
Port: networkingv1.ServiceBackendPort{
Number: int32(i.ContainerPort),
},
},
}
rule.IngressRuleValue.HTTP.Paths[indexPath] = path
}
}
ingress.Spec.Rules[indexRule] = rule
}
ingresses = append(ingresses, *ingress)
}
return ingresses, nil
}