utils

Aug 31, 2022

Changes in this version

+ func CreateOrUpdateConfigMap(clientSet *kubernetes.Clientset, cm *corev1.ConfigMap) error

+ func CreateOrUpdateRole(clientSet *kubernetes.Clientset, role *rbacv1.Role) error

+ func CreateOrUpdateRoleBinding(clientSet *kubernetes.Clientset, roleBinding *rbacv1.RoleBinding) error

May 28, 2022

Changes in this version

+ func ClusterRoleBindingFromSubjects(clusterRoleBindingName, clusterRoleName string, sub []rbacv1.Subject, ...) *rbacv1.ClusterRoleBinding

+ func ClusterRoleFromRules(name string, rules []rbacv1.PolicyRule, labels map[string]string) *rbacv1.ClusterRole

+ func CreateIfNotExistClusterRole(clientSet *kubernetes.Clientset, role *rbacv1.ClusterRole) error

+ func CreateIfNotExistClusterRoleBinding(clientSet *kubernetes.Clientset, binding *rbacv1.ClusterRoleBinding) error

Nov 23, 2022

Changes in this version

+ const MaxRespBodyLength

Oct 8, 2022

Changes in this version

+ func ParseIP(s string) (net.IP, int, error)

Mar 17, 2022

Changes in this version

+ func IsExist(path string) bool

Dec 31, 2021

Changes in this version

+ func BytesToFile(path, name string, data []byte) error

+ func CreateBasic(serverURL, userName, clusterName string, caCert []byte) *clientcmdapi.Config

+ func CreateWithCerts(serverURL, userName, clusterName string, caCert []byte, clientKey []byte, ...) *clientcmdapi.Config

+ func DeCompress(file, targetPath string) error

+ func DownloadFile(url, filePath string) error

+ func FileToBytes(path, name string) ([]byte, error)

+ func FlagsDNS(dns string) []string

+ func FlagsIP(ip string) []net.IP

+ func GenExamples(path, parentCommand string)

+ func InternetIP() (net.IP, error)

+ func ListFiles(path string) []string

+ func MapToString(labels map[string]string) string

+ func NewAPIRegistrationClient(c *rest.Config) (*aggregator.Clientset, error)

+ func NewCRDsClient(c *rest.Config) (*clientset.Clientset, error)

+ func NewClientSet(c *rest.Config) (*kubernetes.Clientset, error)

+ func PathIsExist(path string) bool

+ func RestConfig(kubeconfigPath string) (*rest.Config, error)

+ func StaticYamlToJSONByte(staticYaml string) []byte

+ func StringToMap(labels string) map[string]string

+ func StringToNetIP(addr string) net.IP

+ func WriteKubeConfigFromSpec(serverURL, userName, clusterName, kubeconfigPath, kubeconfigName string, ...) error

+ type Downloader struct

+ Current int64

+ Total int64

+ func (d *Downloader) Read(p []byte) (n int, err error)