k8s

func EnsureCronJob(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	job *batchv1.CronJob,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureDeployment(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	deployment *appsv1.Deployment,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureHPA(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	svc *autoscalingv2.HorizontalPodAutoscaler,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureHTTPRoute(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	httpRoute *gatewayv1.HTTPRoute,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureIngress(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	ingress *networkingv1.Ingress,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureJob(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	job *batchv1.Job,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureObjectWithHash(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	obj client.Object,
	s *runtime.Scheme,
) error

func EnsurePDB(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	pdb *policy.PodDisruptionBudget,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsurePod(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	pod *corev1.Pod,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func EnsureService(
	ctx context.Context,
	cl client.Client,
	owner metav1.Object,
	svc *corev1.Service,
	s *runtime.Scheme,
	saveOldMeta bool,
) error

func GetOperatorNamespace() (string, error)

func GetSecret(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*corev1.Secret, error)

func GetStore(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.Store, error)

func GetStoreDebugInstance(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.StoreDebugInstance, error)

func GetStoreExec(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.StoreExec, error)

func GetStoreSnapshotCreate(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.StoreSnapshotCreate, error)

func GetStoreSnapshotRestore(
	ctx context.Context,
	cl client.Client,
	nn types.NamespacedName,
) (*v1.StoreSnapshotRestore, error)

func GetWatchNamespace() (string, error)

func HasObjectChanged(
	ctx context.Context,
	cl client.Client,
	obj client.Object,
) (bool, error)

func ObjectDiff(oldObj, newObj runtime.Object) (string, error)

func ObjectExists(
	ctx context.Context,
	cl client.Reader,
	nn types.NamespacedName,
	o client.Object,
) (bool, error)

func ObjectHash(obj runtime.Object) (string, error)