Package kube provides helper utilities common for kubernetes



    View Source
    const (
    	ServiceKind    = "Service"
    	EndpointsKind  = "Endpoints"
    	DeploymentKind = "Deployment"


    This section is empty.


    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 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


                          This section is empty.

                          Source Files