kube

Documentation

Overview

Package kube provides helper utilities common for kubernetes

Index

• Constants
• func ApplyResource(config *rest.Config, obj *unstructured.Unstructured, namespace string, ...) (string, error)
• func DeleteResource(config *rest.Config, obj *unstructured.Unstructured, namespace string) error
• func DeleteResourceWithLabel(config *rest.Config, namespace string, labelName string, labelValue string) error
• func GetCachedServerResources(host string, disco discovery.DiscoveryInterface) ([]*metav1.APIResourceList, error)
• func GetLiveResource(dclient dynamic.Interface, obj *unstructured.Unstructured, ...) (*unstructured.Unstructured, error)
• func GetResourcesWithLabel(config *rest.Config, namespace string, labelName string, labelValue string) ([]*unstructured.Unstructured, error)
• func ListResources(dclient dynamic.Interface, apiResource metav1.APIResource, namespace string, ...) ([]*unstructured.Unstructured, error)
• func MustToUnstructured(obj interface{}) *unstructured.Unstructured
• func ServerResourceForGroupVersionKind(disco discovery.DiscoveryInterface, gvk schema.GroupVersionKind) (*metav1.APIResource, error)
• func TestConfig(config *rest.Config) error
• func ToUnstructured(obj interface{}) (*unstructured.Unstructured, error)
• func WatchResourcesWithLabel(ctx context.Context, config *rest.Config, namespace string, labelName string) (chan watch.Event, error)
• func WriteKubeConfig(restConfig *rest.Config, namespace, filename string) error

Constants

const (
	ServiceKind    = "Service"
	EndpointsKind  = "Endpoints"
	DeploymentKind = "Deployment"
)

Functions

func ApplyResource

func ApplyResource(config *rest.Config, obj *unstructured.Unstructured, namespace string, dryRun bool) (string, error)

ApplyResource performs an apply of a unstructured resource

func DeleteResource

func DeleteResource(config *rest.Config, obj *unstructured.Unstructured, namespace string) error

DeleteResource deletes resource

func DeleteResourceWithLabel

func DeleteResourceWithLabel(config *rest.Config, namespace string, labelName string, labelValue string) error

DeleteResourceWithLabel delete all resources which match to specified label selector

func GetCachedServerResources

func GetCachedServerResources(host string, disco discovery.DiscoveryInterface) ([]*metav1.APIResourceList, error)

GetCachedServerResources discovers API resources supported by a Kube API server. Caches the results for apiResourceCacheDuration (per host)

func GetLiveResource

func GetLiveResource(dclient dynamic.Interface, obj *unstructured.Unstructured, apiResource *metav1.APIResource, namespace string) (*unstructured.Unstructured, error)

GetLiveResource returns the corresponding live resource from a unstructured object

func GetResourcesWithLabel

func GetResourcesWithLabel(config *rest.Config, namespace string, labelName string, labelValue string) ([]*unstructured.Unstructured, error)

GetResourcesWithLabel returns all kubernetes resources with specified label

func ListResources

func ListResources(dclient dynamic.Interface, apiResource metav1.APIResource, namespace string, listOpts metav1.ListOptions) ([]*unstructured.Unstructured, error)

ListResources returns a list of resources of a particular API type using the dynamic client

func MustToUnstructured

func MustToUnstructured(obj interface{}) *unstructured.Unstructured

MustToUnstructured converts a concrete K8s API type to a un unstructured object and panics if not successful

func ServerResourceForGroupVersionKind

func ServerResourceForGroupVersionKind(disco discovery.DiscoveryInterface, gvk schema.GroupVersionKind) (*metav1.APIResource, error)

See: https://github.com/ksonnet/ksonnet/blob/master/utils/client.go

func TestConfig

func TestConfig(config *rest.Config) error

TestConfig tests to make sure the REST config is usable

func ToUnstructured

func ToUnstructured(obj interface{}) (*unstructured.Unstructured, error)

ToUnstructured converts a concrete K8s API type to a un unstructured object

func WatchResourcesWithLabel

func WatchResourcesWithLabel(ctx context.Context, config *rest.Config, namespace string, labelName string) (chan watch.Event, error)

func WriteKubeConfig

func WriteKubeConfig(restConfig *rest.Config, namespace, filename string) error

WriteKubeConfig takes a rest.Config and writes it as a kubeconfig at the specified path