transformer

Documentation

Index

• Constants
• func GetMemberTopology(stsRef types.NamespacedName, svcName string, replicas int) string
• func GetServiceKey(xlineClusterName types.NamespacedName) types.NamespacedName
• func GetStatefulSetKey(xlineClusterName types.NamespacedName) types.NamespacedName
• func GetXlineInstanceLabels(xlineClusterName types.NamespacedName) map[string]string
• func MakeResourceLabels(xlineName string) map[string]string
• func MakeService(cr *xapi.XlineCluster, scheme *runtime.Scheme) *corev1.Service
• func MakeStatefulSet(cr *xapi.XlineCluster, scheme *runtime.Scheme) *appv1.StatefulSet

Constants

const (
	K8sNameLabelKey     = "app.kubernetes.io/name"
	K8sInstanceLabelKey = "app.kubernetes.io/instance"

	XlineK8sNameLabelValue      = "xline-cluster"
	XlineK8sManagedByLabelValue = "xline-operator"
)

const (
	XlinePort = 2379
	DataDir   = "/usr/local/xline/data-dir"
)

Functions

func GetMemberTopology

func GetMemberTopology(stsRef types.NamespacedName, svcName string, replicas int) string

func GetServiceKey

func GetServiceKey(xlineClusterName types.NamespacedName) types.NamespacedName

func GetStatefulSetKey

func GetStatefulSetKey(xlineClusterName types.NamespacedName) types.NamespacedName

func GetXlineInstanceLabels

func GetXlineInstanceLabels(xlineClusterName types.NamespacedName) map[string]string

func MakeResourceLabels

func MakeResourceLabels(xlineName string) map[string]string

MakeResourceLabels make the k8s label meta for the managed resource

func MakeService

func MakeService(cr *xapi.XlineCluster, scheme *runtime.Scheme) *corev1.Service

func MakeStatefulSet

func MakeStatefulSet(cr *xapi.XlineCluster, scheme *runtime.Scheme) *appv1.StatefulSet