builders

package

v0.0.0-...-5fa7f0c Latest Latest Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Opster/opensearch-k8s-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AllMastersReady(ctx context.Context, k8sClient client.Client, cr *opsterv1.OpenSearchCluster) bool
func BootstrapPodName(cr *opsterv1.OpenSearchCluster) string
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 PasswordSecret(cr *opsterv1.OpenSearchCluster, username, password string) *corev1.Secret
func PortForCluster(cr *opsterv1.OpenSearchCluster) int32
func STSInNodePools(sts appsv1.StatefulSet, nodepools []opsterv1.NodePool) bool
func StsName(cr *opsterv1.OpenSearchCluster, nodePool *opsterv1.NodePool) string
func URLForCluster(cr *opsterv1.OpenSearchCluster) 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 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 PasswordSecret ¶

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

func PortForCluster ¶

func PortForCluster(cr *opsterv1.OpenSearchCluster) int32

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

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