builders

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/saketmht/opensearch-k8s-operator

Documentation ¶

Index ¶

Constants
func AllMastersReady(ctx context.Context, k8sClient client.Client, cr *opsterv1.OpenSearchCluster) bool
func BootstrapPodName(cr *opsterv1.OpenSearchCluster) string
func DataNodesCount(ctx context.Context, k8sClient client.Client, cr *opsterv1.OpenSearchCluster) int32
func DiscoveryServiceName(cr *opsterv1.OpenSearchCluster) string
func DnsOfService(cr *opsterv1.OpenSearchCluster) string
func NewBootstrapPod(cr *opsterv1.OpenSearchCluster, volumes []corev1.Volume, ...) *corev1.Pod
func NewDashboardsConfigMapForCR(cr *opsterv1.OpenSearchCluster, name string, config map[string]string) *corev1.ConfigMap
func NewDashboardsDeploymentForCR(cr *opsterv1.OpenSearchCluster, volumes []corev1.Volume, ...) *appsv1.Deployment
func NewDashboardsSvcForCr(cr *opsterv1.OpenSearchCluster) *corev1.Service
func NewDiscoveryServiceForCR(cr *opsterv1.OpenSearchCluster) *corev1.Service
func NewHeadlessServiceForNodePool(cr *opsterv1.OpenSearchCluster, nodePool *opsterv1.NodePool) *corev1.Service
func NewNodePortService(cr *opsterv1.OpenSearchCluster) *corev1.Service
func NewSTSForNodePool(username string, cr *opsterv1.OpenSearchCluster, node opsterv1.NodePool, ...) *appsv1.StatefulSet
func NewSecurityconfigUpdateJob(instance *opsterv1.OpenSearchCluster, jobName string, namespace string, ...) batchv1.Job
func NewServiceForCR(cr *opsterv1.OpenSearchCluster) *corev1.Service
func NewServiceMonitor(cr *opsterv1.OpenSearchCluster) *monitoring.ServiceMonitor
func NewSnapshotRepoconfigUpdateJob(instance *opsterv1.OpenSearchCluster, jobName string, namespace string, ...) batchv1.Job
func PasswordSecret(cr *opsterv1.OpenSearchCluster, username, password string) *corev1.Secret
func PortForCluster(cr *opsterv1.OpenSearchCluster) int32
func ReplicaHostName(currentSts appsv1.StatefulSet, repNum int32) string
func STSInNodePools(sts appsv1.StatefulSet, nodepools []opsterv1.NodePool) bool
func StsName(cr *opsterv1.OpenSearchCluster, nodePool *opsterv1.NodePool) string
func URLForCluster(cr *opsterv1.OpenSearchCluster) string
func WorkingPodForRollingRestart(sts *appsv1.StatefulSet) string

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 NewServiceMonitor ¶

func NewServiceMonitor(cr *opsterv1.OpenSearchCluster) *monitoring.ServiceMonitor

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.

Source Files ¶

View all Source files

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