k8sutil

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

func CreateK8sEndpoints(name string, namespace string, addresses []corev1.EndpointAddress, ports []corev1.EndpointPort) *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, icpNetworkName string, namespace string) ([]corev1.EndpointAddress, error)

func GetIstiodEndpointPorts(ctx context.Context, kubeClient client.Client, serviceName string, serviceNamespace 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, clusterName string, secretRef types.NamespacedName, saRef types.NamespacedName, apiServerEndpointAddress string, clusterRegistryAPIEnabled bool) (*corev1.Secret, error)

func GetResourceRevisionLabel(obj client.Object) string

func GetService(ctx context.Context, kubeClient client.Client, serviceName string, serviceNamespace 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)