utils

Documentation

Index

• Constants
• func BytesToFile(path, name string, data []byte) error
• func ClusterRoleBindingFromSubjects(clusterRoleBindingName, clusterRoleName string, sub []rbacv1.Subject, ...) *rbacv1.ClusterRoleBinding
• func ClusterRoleFromRules(name string, rules []rbacv1.PolicyRule, annotations map[string]string, ...) *rbacv1.ClusterRole
• func CreateBasic(serverURL, userName, clusterName string, caCert []byte) *clientcmdapi.Config
• func CreateDeployAndWait(kubeClientSet kubernetes.Interface, deployment *appsv1.Deployment, ...) error
• 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 IsExist(path string) bool
• func ListFiles(path string) []string
• func MapToString(labels map[string]string) string
• func ParseIP(s string) (net.IP, int, error)
• func PathExists(path string) (bool, 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
  • func (d *Downloader) Read(p []byte) (n int, err error)

Constants

const (

	// MaxRespBodyLength is the max length of http response body
	MaxRespBodyLength = 1 << 20 // 1 MiB
)

Functions

func BytesToFile

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

BytesToFile Bytes Conversion File

func ClusterRoleBindingFromSubjects

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

ClusterRoleBindingFromSubjects ClusterRoleBinding Subjects

func ClusterRoleFromRules

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

ClusterRoleFromRules ClusterRole Rules

func CreateBasic

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

CreateBasic creates a basic, general KubeConfig object that then can be extended

func CreateDeployAndWait

func CreateDeployAndWait(kubeClientSet kubernetes.Interface, deployment *appsv1.Deployment, waitComponentReadyTimeout int) error

CreateDeployAndWait Create deployment and then waiting for ready

func CreateWithCerts

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

CreateWithCerts creates a KubeConfig object with access to the API server with client certificates

func DeCompress

func DeCompress(file, targetPath string) error

DeCompress decompress tar.gz

func DownloadFile

func DownloadFile(url, filePath string) error

DownloadFile Download files via URL

func FileToBytes

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

FileToBytes File Conversion Bytes

func FlagsDNS

func FlagsDNS(dns string) []string

FlagsDNS Receive master external DNS from command flags

func FlagsIP

func FlagsIP(ip string) []net.IP

FlagsIP Receive master external IP from command flags

func GenExamples

func GenExamples(path, parentCommand string)

GenExamples Generate sample files

func InternetIP

func InternetIP() (net.IP, error)

InternetIP Current host Internet IP.

func IsExist

func IsExist(path string) bool

IsExist Determine whether the path exists

func ListFiles

func ListFiles(path string) []string

ListFiles traverse directory files

func MapToString

func MapToString(labels map[string]string) string

MapToString labels to string

func ParseIP

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

ParseIP parses an IP address and returns whether it is a v4 or v6 IP address

func PathExists

func PathExists(path string) (bool, error)

PathExists check whether the path is exist

func StaticYamlToJSONByte

func StaticYamlToJSONByte(staticYaml string) []byte

StaticYamlToJSONByte Static yaml file conversion JSON Byte

func StringToMap

func StringToMap(labels string) map[string]string

StringToMap string to label

func StringToNetIP

func StringToNetIP(addr string) net.IP

StringToNetIP String To NetIP

func WriteKubeConfigFromSpec

func WriteKubeConfigFromSpec(serverURL, userName, clusterName, kubeconfigPath, kubeconfigName string, caCert []byte, clientKey []byte, clientCert []byte) error

WriteKubeConfigFromSpec creates a kubeconfig object from a kubeConfigSpec and writes it to the given writer.

Types

type Downloader

type Downloader struct {
	io.Reader
	Total   int64
	Current int64
}

Downloader Download progress

func (*Downloader) Read

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

Read Implementation of Downloader