miqutils

Documentation

Index

• func FindCatalogSourceByName(client client.Client, namespace string, name string) *olmv1alpha1.CatalogSource
• func FindDeploymentByName(client client.Client, namespace string, name string) *appsv1.Deployment
• func FindKafka(client client.Client, scheme *runtime.Scheme, namespace string, name string) *unstructured.Unstructured
• func FindKafkaTopic(client client.Client, scheme *runtime.Scheme, namespace string, name string, ...) *unstructured.Unstructured
• func FindPodByName(client client.Client, namespace string, name string) *corev1.Pod
• func FindReplicaSetByName(client client.Client, namespace string, name string) *appsv1.ReplicaSet
• func FindSecretByName(client client.Client, namespace string, name string) *corev1.Secret
• func FindVolume(volumeName string, volumes []corev1.Volume) corev1.Volume
• func FindVolumeProjection(volumeProjectionName string, volumeProjections []corev1.VolumeProjection) corev1.VolumeProjection
• func OperatorNodeAffinityArchValues(deployment *appsv1.Deployment, client client.Client) []string
• func SetDeploymentNodeAffinity(deployment *appsv1.Deployment, client client.Client)
• func SetKafkaNodeAffinity(kafkaCRSpec map[string]interface{}, archs []string) map[string]interface{}

Functions

func FindCatalogSourceByName

func FindCatalogSourceByName(client client.Client, namespace string, name string) *olmv1alpha1.CatalogSource

func FindDeploymentByName

func FindDeploymentByName(client client.Client, namespace string, name string) *appsv1.Deployment

func FindKafka

func FindKafka(client client.Client, scheme *runtime.Scheme, namespace string, name string) *unstructured.Unstructured

func FindKafkaTopic

func FindKafkaTopic(client client.Client, scheme *runtime.Scheme, namespace string, name string, group string) *unstructured.Unstructured

func FindPodByName

func FindPodByName(client client.Client, namespace string, name string) *corev1.Pod

func FindReplicaSetByName

func FindReplicaSetByName(client client.Client, namespace string, name string) *appsv1.ReplicaSet

func FindSecretByName

func FindSecretByName(client client.Client, namespace string, name string) *corev1.Secret

func FindVolume

func FindVolume(volumeName string, volumes []corev1.Volume) corev1.Volume

func FindVolumeProjection

func FindVolumeProjection(volumeProjectionName string, volumeProjections []corev1.VolumeProjection) corev1.VolumeProjection

func OperatorNodeAffinityArchValues

func OperatorNodeAffinityArchValues(deployment *appsv1.Deployment, client client.Client) []string

func SetDeploymentNodeAffinity

func SetDeploymentNodeAffinity(deployment *appsv1.Deployment, client client.Client)

func SetKafkaNodeAffinity

func SetKafkaNodeAffinity(kafkaCRSpec map[string]interface{}, archs []string) map[string]interface{}