util

Documentation

Index

• func CheckEquels(from_env *appsv1.StatefulSetSpec, from_crd *appsv1.StatefulSetSpec, ...) (int32, bool, error)
• func CreateAdditionalVolumes(ctx context.Context, k8sClient client.Client, namespace string, ...) (retVolumes []corev1.Volume, retVolumeMounts []corev1.VolumeMount, ...)
• func CreateClientForCluster(ctx context.Context, k8sClient client.Client, ...) (*services.OsClusterClient, error)
• func FetchOpensearchCluster(ctx context.Context, k8sClient client.Client, ref types.NamespacedName) (*opsterv1.OpenSearchCluster, error)
• func GetSha1Sum(data []byte) (string, error)
• func OpensearchClusterURL(cluster *opsterv1.OpenSearchCluster) string
• func ReadOrGenerateCaCert(pki tls.PKI, k8sClient client.Client, ctx context.Context, ...) (tls.Cert, error)

Functions

func CheckEquels

func CheckEquels(from_env *appsv1.StatefulSetSpec, from_crd *appsv1.StatefulSetSpec, text string) (int32, bool, error)

func CreateAdditionalVolumes

func CreateAdditionalVolumes(
	ctx context.Context,
	k8sClient client.Client,
	namespace string,
	volumeConfigs []opsterv1.AdditionalVolume,
) (
	retVolumes []corev1.Volume,
	retVolumeMounts []corev1.VolumeMount,
	retData []byte,
	returnErr error,
)

func CreateClientForCluster

func CreateClientForCluster(
	ctx context.Context,
	k8sClient client.Client,
	cluster *opsterv1.OpenSearchCluster,
	transport http.RoundTripper,
) (*services.OsClusterClient, error)

func FetchOpensearchCluster

func FetchOpensearchCluster(
	ctx context.Context,
	k8sClient client.Client,
	ref types.NamespacedName,
) (*opsterv1.OpenSearchCluster, error)

func GetSha1Sum

func GetSha1Sum(data []byte) (string, error)

Generates a checksum of binary data using the SHA1 algorithm.

func OpensearchClusterURL

func OpensearchClusterURL(cluster *opsterv1.OpenSearchCluster) string

func ReadOrGenerateCaCert

func ReadOrGenerateCaCert(pki tls.PKI, k8sClient client.Client, ctx context.Context, instance *opsterv1.OpenSearchCluster) (tls.Cert, error)