util

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

func CreateAdditionalVolumes(
	k8sClient k8s.K8sClient,
	namespace string,
	volumeConfigs []opsterv1.AdditionalVolume,
) (
	retVolumes []corev1.Volume,
	retVolumeMounts []corev1.VolumeMount,
	retData []byte,
	returnErr error,
)

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

func DataNodesCount(k8sClient k8s.K8sClient, cr *opsterv1.OpenSearchCluster) int32

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

func GetAvailableOpenSearchNodes(k8sClient k8s.K8sClient, ctx context.Context, cluster *opsterv1.OpenSearchCluster, lg logr.Logger) int32

func GetClusterHealth(k8sClient k8s.K8sClient, ctx context.Context, cluster *opsterv1.OpenSearchCluster, lg logr.Logger) opsterv1.OpenSearchHealth

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

func OpensearchClusterURL(cluster *opsterv1.OpenSearchCluster) string

func ReadOrGenerateCaCert(pki tls.PKI, k8sClient k8s.K8sClient, instance *opsterv1.OpenSearchCluster) (tls.Cert, error)