-
Notifications
You must be signed in to change notification settings - Fork 1
/
service_builder.go
45 lines (40 loc) · 1.11 KB
/
service_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
package kibana
import (
"fmt"
kibanacrd "github.com/webcenter-fr/elasticsearch-operator/apis/kibana/v1"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/intstr"
)
// BuilderService permit to generate service
func buildServices(kb *kibanacrd.Kibana) (services []corev1.Service, err error) {
services = []corev1.Service{
{
ObjectMeta: metav1.ObjectMeta{
Namespace: kb.Namespace,
Name: GetServiceName(kb),
Labels: getLabels(kb, map[string]string{
fmt.Sprintf("%s/service", kibanacrd.KibanaAnnotationKey): "true",
}),
Annotations: getAnnotations(kb),
},
Spec: corev1.ServiceSpec{
Type: corev1.ServiceTypeClusterIP,
SessionAffinity: corev1.ServiceAffinityNone,
Selector: map[string]string{
"cluster": kb.Name,
kibanacrd.KibanaAnnotationKey: "true",
},
Ports: []corev1.ServicePort{
{
Name: "http",
Protocol: corev1.ProtocolTCP,
Port: 5601,
TargetPort: intstr.FromInt(5601),
},
},
},
},
}
return services, nil
}