k8sutil

Documentation

Index

• func CheckResourceRevision(obj client.Object, revisionConstraint string) (bool, error)
• func CreateK8sEndpoints(name string, namespace string, addresses []corev1.EndpointAddress, ...) *corev1.Endpoints
• func DetectSupportedJWTPolicy(k8sConfig *rest.Config) (servicemeshv1alpha1.JWTPolicyType, error)
• func GetEndpointForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) clusterregistryv1alpha1.KubernetesAPIEndpoint
• func GetEndpoints(ctx context.Context, kubeClient client.Client, name string, namespace string) (*corev1.Endpoints, error)
• func GetExternalAddressOfAPIServer(kubeConfig *rest.Config) (string, error)
• func GetIPsForEndpoints(endpoints *corev1.Endpoints) []string
• func GetIstiodEndpointAddresses(ctx context.Context, kubeClient client.Client, icpName string, ...) ([]corev1.EndpointAddress, error)
• func GetIstiodEndpointPorts(ctx context.Context, kubeClient client.Client, serviceName string, ...) ([]corev1.EndpointPort, error)
• func GetKubeconfigWithSAToken(name, username, endpointURL string, caData []byte, saToken string) (string, error)
• func GetLocalCluster(ctx context.Context, kubeClient client.Client) (*clusterregistryv1alpha1.Cluster, error)
• func GetManagedByLabel(obj client.Object) string
• func GetReaderSecretForCluster(ctx context.Context, kubeClient client.Client, kubeConfig *rest.Config, ...) (*corev1.Secret, error)
• func GetResourceRevisionLabel(obj client.Object) string
• func GetService(ctx context.Context, kubeClient client.Client, serviceName string, ...) (*corev1.Service, error)
• func GetServiceEndpointIPs(service corev1.Service) ([]string, bool, error)
• func IsReqeueNeededCosNamespaceTermination(ctx context.Context, cli client.Client, obj client.Object) (bool, error)
• func SetICPMetadataOnObject(object metav1.Object, icp *v1alpha1.IstioControlPlane)
• func SetManagedByLabel(obj client.Object, owner string)
• func SetResourceRevisionLabel(obj client.Object, revision string)
• type IngressSetupPendingError
  • func (e IngressSetupPendingError) Error() string

Functions

func CheckResourceRevision

func CheckResourceRevision(obj client.Object, revisionConstraint string) (bool, error)

func CreateK8sEndpoints

func CreateK8sEndpoints(name string, namespace string, addresses []corev1.EndpointAddress, ports []corev1.EndpointPort) *corev1.Endpoints

func DetectSupportedJWTPolicy

func DetectSupportedJWTPolicy(k8sConfig *rest.Config) (servicemeshv1alpha1.JWTPolicyType, error)

func GetEndpointForClusterByNetwork

func GetEndpointForClusterByNetwork(cluster *clusterregistryv1alpha1.Cluster, networkName string) clusterregistryv1alpha1.KubernetesAPIEndpoint

func GetEndpoints

func GetEndpoints(ctx context.Context, kubeClient client.Client, name string, namespace string) (*corev1.Endpoints, error)

func GetExternalAddressOfAPIServer

func GetExternalAddressOfAPIServer(kubeConfig *rest.Config) (string, error)

func GetIPsForEndpoints

func GetIPsForEndpoints(endpoints *corev1.Endpoints) []string

func GetIstiodEndpointAddresses

func GetIstiodEndpointAddresses(ctx context.Context, kubeClient client.Client, icpName string, icpNetworkName string, namespace string) ([]corev1.EndpointAddress, error)

func GetIstiodEndpointPorts

func GetIstiodEndpointPorts(ctx context.Context, kubeClient client.Client, serviceName string, serviceNamespace string) ([]corev1.EndpointPort, error)

func GetKubeconfigWithSAToken

func GetKubeconfigWithSAToken(name, username, endpointURL string, caData []byte, saToken string) (string, error)

func GetLocalCluster

func GetLocalCluster(ctx context.Context, kubeClient client.Client) (*clusterregistryv1alpha1.Cluster, error)

func GetManagedByLabel

func GetManagedByLabel(obj client.Object) string

func GetReaderSecretForCluster

func GetReaderSecretForCluster(ctx context.Context, kubeClient client.Client, kubeConfig *rest.Config, clusterName string, secretRef types.NamespacedName, saRef types.NamespacedName, apiServerEndpointAddress string, clusterRegistryAPIEnabled bool) (*corev1.Secret, error)

func GetResourceRevisionLabel

func GetResourceRevisionLabel(obj client.Object) string

func GetService

func GetService(ctx context.Context, kubeClient client.Client, serviceName string, serviceNamespace string) (*corev1.Service, error)

func GetServiceEndpointIPs

func GetServiceEndpointIPs(service corev1.Service) ([]string, bool, error)

func IsReqeueNeededCosNamespaceTermination

func IsReqeueNeededCosNamespaceTermination(ctx context.Context, cli client.Client, obj client.Object) (bool, error)

func SetICPMetadataOnObject

func SetICPMetadataOnObject(object metav1.Object, icp *v1alpha1.IstioControlPlane)

func SetManagedByLabel

func SetManagedByLabel(obj client.Object, owner string)

func SetResourceRevisionLabel

func SetResourceRevisionLabel(obj client.Object, revision string)

Types

type IngressSetupPendingError

type IngressSetupPendingError struct{}

func (IngressSetupPendingError) Error

func (e IngressSetupPendingError) Error() string