utils

Documentation

Index

• Variables
• func DoSSA(ctx context.Context, cfg *rest.Config, yaml []byte) error
• func DownloadFileString(url string) (string, error)
• func GetDefaultRuntime() cluster.ProviderOption
• func IsDeploymentRunning(c kubernetes.Interface, ns string, depl string) wait.ConditionFunc
• func NewClient(kubeConfigPath string) (kubernetes.Interface, error)
• func SplitYAML(resources []byte) ([][]byte, error)
• func WaitForDeployment(c kubernetes.Interface, namespace string, deployment string, ...) error

Variables

var User string = os.Getenv("SUDO_USER")

Functions

func DoSSA

func DoSSA(ctx context.Context, cfg *rest.Config, yaml []byte) error

DoSSA does service side apply with the given YAML as a []byte

func DownloadFileString

func DownloadFileString(url string) (string, error)

DownloadFileString will load the contents of a url to a string and return it

func GetDefaultRuntime

func GetDefaultRuntime() cluster.ProviderOption

GetDefault selected the default runtime from the environment override

func IsDeploymentRunning

func IsDeploymentRunning(c kubernetes.Interface, ns string, depl string) wait.ConditionFunc

check to see if the named deployment is running

func NewClient

func NewClient(kubeConfigPath string) (kubernetes.Interface, error)

NewClient returns a kubernetes.Interface

func SplitYAML

func SplitYAML(resources []byte) ([][]byte, error)

SplitYAML splits a multipart YAML and returns a slice of a slice of byte

func WaitForDeployment

func WaitForDeployment(c kubernetes.Interface, namespace string, deployment string, timeout time.Duration) error

Poll up to timeout seconds for pod to enter running state.