clusterbuilder

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 5, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TLSVolumeName      = builder.ValkeyTLSVolumeName
	TLSVolumeMountPath = builder.ValkeyTLSVolumeDefaultMountPath

	StorageVolumeName      = builder.ValkeyDataVolumeName
	StorageVolumeMountPath = builder.ValkeyDataVolumeDefaultMountPath

	ValkeyTempVolumeName      = "temp"
	ValkeyTempVolumeMountPath = "/tmp"

	ValkeyPasswordVolumeName = "valkey-auth" //#nosec
	PasswordVolumeMountPath  = "/account"

	ConfigVolumeName      = "conf"
	ConfigVolumeMountPath = "/etc/valkey"

	ValkeyOptVolumeName      = "valkey-opt"
	ValkeyOptVolumeMountPath = "/opt"
)

Variables

This section is empty.

Functions

func ClusterHeadlessSvcName

func ClusterHeadlessSvcName(name string, i int) string

func ClusterNodeServiceName

func ClusterNodeServiceName(clusterName string, shard, repl int) string

func ClusterStatefulSetName

func ClusterStatefulSetName(name string, i int) string

func GenerateClusterLabels

func GenerateClusterLabels(name string, extra map[string]string) map[string]string

GenerateClusterStaticLabels extra labels will override by the static labels

func GenerateClusterStatefulSetLabels

func GenerateClusterStatefulSetLabels(name string, index int, extra ...map[string]string) map[string]string

GenerateClusterStatefulSetLabels

func GenerateClusterStatefulSetSelectors

func GenerateClusterStatefulSetSelectors(name string, index int) map[string]string

GenerateClusterStatefulSetSelectors

func GenerateHeadlessService

func GenerateHeadlessService(cluster *v1alpha1.Cluster, index int) *corev1.Service

GenerateHeadlessService creates a new headless service for the given Cluster.

func GenerateInstanceService

func GenerateInstanceService(cluster *v1alpha1.Cluster) *corev1.Service

func GenerateNodePortSerivce

func GenerateNodePortSerivce(cluster *v1alpha1.Cluster, name string, labels map[string]string, port int32) *corev1.Service

func GeneratePodDisruptionBudget

func GeneratePodDisruptionBudget(cluster types.ClusterInstance, index int) *policyv1.PodDisruptionBudget

func GeneratePodService

func GeneratePodService(cluster *v1alpha1.Cluster, name string, typ corev1.ServiceType, annotations map[string]string) *corev1.Service

func GenerateStatefulSet

func GenerateStatefulSet(inst types.ClusterInstance, index int) (*appsv1.StatefulSet, error)

GenerateStatefulSet creates a new StatefulSet for the given Cluster.

func NewConfigMapForCR

func NewConfigMapForCR(cluster types.ClusterInstance) (*corev1.ConfigMap, error)

NewConfigMapForCR creates a new ConfigMap for the given Cluster

func ValkeyConfigMapName

func ValkeyConfigMapName(clusterName string) string

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL