k8sutil

Documentation

Index

• Constants
• func CreateAppCRD(clientset apiextensionsclient.Interface) error
• func CreateCRD(clientset apiextensionsclient.Interface) error
• func CreateHttpIngress(kubeApi kubernetes.Interface, ns string, name string, labels map[string]string, ...) error
• func GetAppList(restcli rest.Interface, ns string) (*deccov1beta2.AppList, error)
• func GetClusterConfigOrDie() *restclient.Config
• func GetSpaceList(restcli rest.Interface) (*deccov1beta2.SpaceList, error)
• func GetTcpIngressIpOrHostname(kubeApi kubernetes.Interface) (string, bool, error)
• func InsertStunnel(containerName string, listenPort int32, verifyChain string, ...) ([]v1.Volume, []v1.Container)
• func IsKubernetesResourceAlreadyExistError(err error) bool
• func MustNewKubeExtClient() apiextensionsclient.Interface
• func UpdateAppCustRsc(restcli rest.Interface, ns string, c deccov1beta2.App) (deccov1beta2.App, error)
• func UpdateSpaceCustRsc(restcli rest.Interface, c deccov1beta2.Space) (deccov1beta2.Space, error)
• func WaitAppCRDReady(clientset apiextensionsclient.Interface) error
• func WaitCRDReady(clientset apiextensionsclient.Interface) error
• func WatchApps(host string, ns string, httpClient *http.Client, resourceVersion string) (*http.Response, error)
• func WatchSpaces(host string, httpClient *http.Client, resourceVersion string) (*http.Response, error)

Constants

const TlsPort = 443

Functions

func CreateAppCRD

func CreateAppCRD(clientset apiextensionsclient.Interface) error

func CreateCRD

func CreateCRD(clientset apiextensionsclient.Interface) error

func CreateHttpIngress

func CreateHttpIngress(
	kubeApi kubernetes.Interface,
	ns string,
	name string,
	labels map[string]string,
	hostName string,
	path string,
	svcName string,
	svcPort int32,
	rewritePath string,
	encryptHttp bool,
	secretName string,
	localhostOnly bool,
	additionalAnnotations map[string]string,
) error

func GetAppList

func GetAppList(restcli rest.Interface,
	ns string) (*deccov1beta2.AppList, error)

func GetClusterConfigOrDie

func GetClusterConfigOrDie() *restclient.Config

func GetSpaceList

func GetSpaceList(restcli rest.Interface) (*deccov1beta2.SpaceList, error)

func GetTcpIngressIpOrHostname

func GetTcpIngressIpOrHostname(kubeApi kubernetes.Interface) (string, bool, error)

func InsertStunnel

func InsertStunnel(
	containerName string,
	listenPort int32,
	verifyChain string,
	destHostAndPort string,
	checkHost string,
	tlsSecretName string,
	isNginxIngressStyleCertSecret bool,
	isClientMode bool,
	volumes []v1.Volume,
	containers []v1.Container,
	clientModeSpringBoardDelaySeconds int32,
	index int,
) ([]v1.Volume, []v1.Container)

func IsKubernetesResourceAlreadyExistError

func IsKubernetesResourceAlreadyExistError(err error) bool

func MustNewKubeExtClient

func MustNewKubeExtClient() apiextensionsclient.Interface

func UpdateAppCustRsc

func UpdateAppCustRsc(
	restcli rest.Interface,
	ns string,
	c deccov1beta2.App,
) (deccov1beta2.App, error)

func UpdateSpaceCustRsc

func UpdateSpaceCustRsc(
	restcli rest.Interface,
	c deccov1beta2.Space,
) (deccov1beta2.Space, error)

func WaitAppCRDReady

func WaitAppCRDReady(clientset apiextensionsclient.Interface) error

func WaitCRDReady

func WaitCRDReady(clientset apiextensionsclient.Interface) error

func WatchApps

func WatchApps(host string, ns string, httpClient *http.Client, resourceVersion string) (*http.Response, error)

func WatchSpaces

func WatchSpaces(host string, httpClient *http.Client, resourceVersion string) (*http.Response, error)