builders

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Jul 14, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ConfigurationChecksumAnnotation = "opster.io/config"
	DefaultDiskSize                 = "30Gi"
)

Variables

This section is empty.

Functions

func AllMastersReady

func AllMastersReady(ctx context.Context, k8sClient client.Client, cr *opsterv1.OpenSearchCluster) bool

func BootstrapPodName

func BootstrapPodName(cr *opsterv1.OpenSearchCluster) string

func DataNodesCount

func DataNodesCount(ctx context.Context, k8sClient client.Client, cr *opsterv1.OpenSearchCluster) int32

func DiscoveryServiceName

func DiscoveryServiceName(cr *opsterv1.OpenSearchCluster) string

func DnsOfService

func DnsOfService(cr *opsterv1.OpenSearchCluster) string

func NewBootstrapPod

func NewBootstrapPod(
	cr *opsterv1.OpenSearchCluster,
	volumes []corev1.Volume,
	volumeMounts []corev1.VolumeMount,
) *corev1.Pod

func NewDashboardsConfigMapForCR

func NewDashboardsConfigMapForCR(cr *opsterv1.OpenSearchCluster, name string, config map[string]string) *corev1.ConfigMap

func NewDashboardsDeploymentForCR

func NewDashboardsDeploymentForCR(cr *opsterv1.OpenSearchCluster, volumes []corev1.Volume, volumeMounts []corev1.VolumeMount, annotations map[string]string) *appsv1.Deployment

func NewDashboardsSvcForCr

func NewDashboardsSvcForCr(cr *opsterv1.OpenSearchCluster) *corev1.Service

func NewDiscoveryServiceForCR

func NewDiscoveryServiceForCR(cr *opsterv1.OpenSearchCluster) *corev1.Service

func NewHeadlessServiceForNodePool

func NewHeadlessServiceForNodePool(cr *opsterv1.OpenSearchCluster, nodePool *opsterv1.NodePool) *corev1.Service

func NewNodePortService

func NewNodePortService(cr *opsterv1.OpenSearchCluster) *corev1.Service

func NewSTSForNodePool

func NewSTSForNodePool(
	username string,
	cr *opsterv1.OpenSearchCluster,
	node opsterv1.NodePool,
	configChecksum string,
	volumes []corev1.Volume,
	volumeMounts []corev1.VolumeMount,
	extraConfig map[string]string,
) *appsv1.StatefulSet

func NewSecurityconfigUpdateJob

func NewSecurityconfigUpdateJob(
	instance *opsterv1.OpenSearchCluster,
	jobName string,
	namespace string,
	checksum string,
	adminCertName string,
	cmdArg string,
	volumes []corev1.Volume,
	volumeMounts []corev1.VolumeMount,
) batchv1.Job

func NewServiceForCR

func NewServiceForCR(cr *opsterv1.OpenSearchCluster) *corev1.Service

func NewSnapshotRepoconfigUpdateJob

func NewSnapshotRepoconfigUpdateJob(
	instance *opsterv1.OpenSearchCluster,
	jobName string,
	namespace string,
	checksum string,
	volumes []corev1.Volume,
	volumeMounts []corev1.VolumeMount,
) batchv1.Job

func PasswordSecret

func PasswordSecret(cr *opsterv1.OpenSearchCluster, username, password string) *corev1.Secret

func PortForCluster

func PortForCluster(cr *opsterv1.OpenSearchCluster) int32

func ReplicaHostName

func ReplicaHostName(currentSts appsv1.StatefulSet, repNum int32) string

func STSInNodePools

func STSInNodePools(sts appsv1.StatefulSet, nodepools []opsterv1.NodePool) bool

func StsName

func StsName(cr *opsterv1.OpenSearchCluster, nodePool *opsterv1.NodePool) string

func URLForCluster

func URLForCluster(cr *opsterv1.OpenSearchCluster) string

func WorkingPodForRollingRestart

func WorkingPodForRollingRestart(sts *appsv1.StatefulSet) string

Types

This section is empty.

Jump to

Keyboard shortcuts

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