k8s

package module
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 17, 2017 License: MIT Imports: 40 Imported by: 0

README

A simple Go client for Kubernetes

GoDoc

A slimmed down Go client generated using Kubernetes' new protocol buffer support. This package behaves similarly to official Kubernetes' Go client, but only imports two external dependencies.

import (
    "context"
    "fmt"
    "log"

    "github.com/ericchiang/k8s"
)

func main() {
    client, err := k8s.NewInClusterClient()
    if err != nil {
        log.Fatal(err)
    }

    nodes, err := client.CoreV1().ListNodes(context.Background())
    if err != nil {
        log.Fatal(err)
    }
    for _, node := range nodes.Items {
        fmt.Printf("name=%q schedulable=%t\n", node.Metadata.Name, !node.Spec.Unschedulable)
    }
}

Requirements

Versioned supported

This client supports every API group version present since 1.3.

Usage

Namespaces

Clients are initialized with a default namespace. For in-cluster clients, this is the namespace the pod was deployed in.

pods, err := client.ListPods(ctx, "") // Pods in the current namespace.

This can be overridden by explicitly passing a namespace.

pods, err := client.ListPods(ctx, "custom-namespace") // Pods from the "custom-namespace"
Label selectors

Label selectors can be provided to any list operation.

l := new(k8s.LabelSelector)
l.Eq("tier", "production")
l.In("app", "database", "frontend")

pods, err := client.CoreV1().ListPods(ctx, "", l.Selector())
Working with resources

Use the generated API types directly to create and modify resources.

import (
    "context"

    "github.com/ericchiang/k8s"
    "github.com/ericchiang/k8s/api/v1"
)

func createConfigMap(client *k8s.Client, name string, values map[string]string) error {
    cm := &v1.ConfigMap{
        Metadata: &v1.ObjectMeta{
            Name:      &name,
        },
        Data: values,
    }
    // Will return the created configmap as well.
    _, err := client.CoreV1().Create(context.TODO(), cm, client.Namespace)
    return err
}

API structs use pointers to int, bool, and string types to differentiate between the zero value and an unsupplied one. This package provides convenience methods for creating pointers to literals of basic types.

Creating out-of-cluster clients

Out-of-cluster clients can be constructed by either creating an http.Client manually or parsing a Config object. The following is an example of creating a client from a kubeconfig:

import (
    "io/ioutil"

    "github.com/ericchiang/k8s"
    "github.com/ghodss/yaml"
)

func loadClient(kubeconfigPath string) (*k8s.Client, error) {
    data, err := ioutil.ReadFile(kubeconfigPath)
    if err != nil {
        return nil, fmt.Errorf("read kubeconfig: %v", err)
    }

    var config k8s.Config
    if err := yaml.Unmarshal(data, &config); err != nil {
        return nil, fmt.Errorf("unmarshal kubeconfig: %v", err)
    }
    return k8s.NewClient(&config)
}
Errors

Errors returned by the Kubernetes API are formatted as unversioned.Status objects and surfaced by clients as *k8s.APIErrors. Programs that need to inspect error codes or failure details can use a type cast to access this information.

configMap := &v1.ConfigMap{
    Metadata: &v1.ObjectMeta{
        Name:      "test",
        Namespace: "default",
    },
    Data: map[string]string{"foo": "bar"},
}

_, err := client.CoreV1().CreateConfigMap(ctx, configMap)
if err != nil {
    if apiErr, ok := err.(*k8s.APIError); ok {
        // Resource already exists. Carry on.
        if apiErr.Status.Code == http.StatusConflict {
            return nil
        }
    }
    return fmt.Errorf("create configmap: %v", err)
}
return nil

Documentation

Overview

Package k8s implements a Kubernetes client. 

c, err := k8s.NewInClusterClient()
if err != nil {
	// handle error
}
extensions := c.ExtensionsV1Beta1()

ingresses, err := extensions.ListIngresses(ctx, c.Namespace)
if err != nil {
	// handle error
}

Index

Constants

View Source 
const (
	// Types for watch events.
	EventAdded    = "ADDED"
	EventDeleted  = "DELETED"
	EventModified = "MODIFIED"
	EventError    = "ERROR"
)

Variables

This section is empty.

Functions

func Bool 

func Bool(b bool) *bool

func Int 

func Int(i int) *int

func String 

func String(s string) *string

String returns a pointer to a string. Useful for creating API objects that take pointers instead of literals. 

cm := &v1.ConfigMap{
	Metadata: &v1.ObjectMeta{
		Name:      k8s.String("myconfigmap"),
		Namespace: k8s.String("default"),
	},
	Data: map[string]string{
		"foo": "bar",
	},
}

Types

type APIError 

type APIError struct {
	// The status object returned by the Kubernetes API,
	Status *unversioned.Status

	// Status code returned by the HTTP request.
	Code int
}

APIError is an error from a unexpected status code.

func (*APIError) Error 

func (e *APIError) Error() string

type AppsV1Alpha1 

type AppsV1Alpha1 struct {
	// contains filtered or unexported fields
}

AppsV1Alpha1 is a client for interacting with the apps/v1alpha1 API group.

func (*AppsV1Alpha1) CreatePetSet 

func (c *AppsV1Alpha1) CreatePetSet(ctx context.Context, obj *appsv1alpha1.PetSet) (*appsv1alpha1.PetSet, error)

func (*AppsV1Alpha1) DeletePetSet 

func (c *AppsV1Alpha1) DeletePetSet(ctx context.Context, name string, namespace string) error

func (*AppsV1Alpha1) GetPetSet 

func (c *AppsV1Alpha1) GetPetSet(ctx context.Context, name, namespace string) (*appsv1alpha1.PetSet, error)

func (*AppsV1Alpha1) ListPetSets 

func (c *AppsV1Alpha1) ListPetSets(ctx context.Context, namespace string, options ...Option) (*appsv1alpha1.PetSetList, error)

func (*AppsV1Alpha1) UpdatePetSet 

func (c *AppsV1Alpha1) UpdatePetSet(ctx context.Context, obj *appsv1alpha1.PetSet) (*appsv1alpha1.PetSet, error)

func (*AppsV1Alpha1) WatchPetSets 

func (c *AppsV1Alpha1) WatchPetSets(ctx context.Context, namespace string, options ...Option) (*AppsV1Alpha1PetSetWatcher, error)

type AppsV1Alpha1PetSetWatcher 

type AppsV1Alpha1PetSetWatcher struct {
	// contains filtered or unexported fields
}

func (*AppsV1Alpha1PetSetWatcher) Close 

func (w *AppsV1Alpha1PetSetWatcher) Close() error

func (*AppsV1Alpha1PetSetWatcher) Next 

func (w *AppsV1Alpha1PetSetWatcher) Next() (*versioned.Event, *appsv1alpha1.PetSet, error)

type AppsV1Beta1 

type AppsV1Beta1 struct {
	// contains filtered or unexported fields
}

AppsV1Beta1 is a client for interacting with the apps/v1beta1 API group.

func (*AppsV1Beta1) CreateStatefulSet 

func (c *AppsV1Beta1) CreateStatefulSet(ctx context.Context, obj *appsv1beta1.StatefulSet) (*appsv1beta1.StatefulSet, error)

func (*AppsV1Beta1) DeleteStatefulSet 

func (c *AppsV1Beta1) DeleteStatefulSet(ctx context.Context, name string, namespace string) error

func (*AppsV1Beta1) GetStatefulSet 

func (c *AppsV1Beta1) GetStatefulSet(ctx context.Context, name, namespace string) (*appsv1beta1.StatefulSet, error)

func (*AppsV1Beta1) ListStatefulSets 

func (c *AppsV1Beta1) ListStatefulSets(ctx context.Context, namespace string, options ...Option) (*appsv1beta1.StatefulSetList, error)

func (*AppsV1Beta1) UpdateStatefulSet 

func (c *AppsV1Beta1) UpdateStatefulSet(ctx context.Context, obj *appsv1beta1.StatefulSet) (*appsv1beta1.StatefulSet, error)

func (*AppsV1Beta1) WatchStatefulSets 

func (c *AppsV1Beta1) WatchStatefulSets(ctx context.Context, namespace string, options ...Option) (*AppsV1Beta1StatefulSetWatcher, error)

type AppsV1Beta1StatefulSetWatcher 

type AppsV1Beta1StatefulSetWatcher struct {
	// contains filtered or unexported fields
}

func (*AppsV1Beta1StatefulSetWatcher) Close 

func (w *AppsV1Beta1StatefulSetWatcher) Close() error

func (*AppsV1Beta1StatefulSetWatcher) Next 

func (w *AppsV1Beta1StatefulSetWatcher) Next() (*versioned.Event, *appsv1beta1.StatefulSet, error)

type AuthInfo 

type AuthInfo struct {
	// ClientCertificate is the path to a client cert file for TLS.
	// +optional
	ClientCertificate string `json:"client-certificate,omitempty"`
	// ClientCertificateData contains PEM-encoded data from a client cert file for TLS. Overrides ClientCertificate
	// +optional
	ClientCertificateData []byte `json:"client-certificate-data,omitempty"`
	// ClientKey is the path to a client key file for TLS.
	// +optional
	ClientKey string `json:"client-key,omitempty"`
	// ClientKeyData contains PEM-encoded data from a client key file for TLS. Overrides ClientKey
	// +optional
	ClientKeyData []byte `json:"client-key-data,omitempty"`
	// Token is the bearer token for authentication to the kubernetes cluster.
	// +optional
	Token string `json:"token,omitempty"`
	// TokenFile is a pointer to a file that contains a bearer token (as described above).  If both Token and TokenFile are present, Token takes precedence.
	// +optional
	TokenFile string `json:"tokenFile,omitempty"`
	// Impersonate is the username to imperonate.  The name matches the flag.
	// +optional
	Impersonate string `json:"as,omitempty"`
	// Username is the username for basic authentication to the kubernetes cluster.
	// +optional
	Username string `json:"username,omitempty"`
	// Password is the password for basic authentication to the kubernetes cluster.
	// +optional
	Password string `json:"password,omitempty"`
	// AuthProvider specifies a custom authentication plugin for the kubernetes cluster.
	// +optional
	AuthProvider *AuthProviderConfig `json:"auth-provider,omitempty"`
	// Extensions holds additional information. This is useful for extenders so that reads and writes don't clobber unknown fields
	// +optional
	Extensions []NamedExtension `json:"extensions,omitempty"`
}

AuthInfo contains information that describes identity information. This is use to tell the kubernetes cluster who you are.

type AuthProviderConfig 

type AuthProviderConfig struct {
	Name   string            `json:"name"`
	Config map[string]string `json:"config"`
}

AuthProviderConfig holds the configuration for a specified auth provider.

type AuthenticationV1Beta1 

type AuthenticationV1Beta1 struct {
	// contains filtered or unexported fields
}

AuthenticationV1Beta1 is a client for interacting with the authentication.k8s.io/v1beta1 API group.

func (*AuthenticationV1Beta1) CreateTokenReview 

func (c *AuthenticationV1Beta1) CreateTokenReview(ctx context.Context, obj *authenticationv1beta1.TokenReview) (*authenticationv1beta1.TokenReview, error)

func (*AuthenticationV1Beta1) DeleteTokenReview 

func (c *AuthenticationV1Beta1) DeleteTokenReview(ctx context.Context, name string) error

func (*AuthenticationV1Beta1) GetTokenReview 

func (c *AuthenticationV1Beta1) GetTokenReview(ctx context.Context, name string) (*authenticationv1beta1.TokenReview, error)

func (*AuthenticationV1Beta1) UpdateTokenReview 

func (c *AuthenticationV1Beta1) UpdateTokenReview(ctx context.Context, obj *authenticationv1beta1.TokenReview) (*authenticationv1beta1.TokenReview, error)

type AuthorizationV1Beta1 

type AuthorizationV1Beta1 struct {
	// contains filtered or unexported fields
}

AuthorizationV1Beta1 is a client for interacting with the authorization.k8s.io/v1beta1 API group.

func (*AuthorizationV1Beta1) CreateLocalSubjectAccessReview 

func (c *AuthorizationV1Beta1) CreateLocalSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.LocalSubjectAccessReview) (*authorizationv1beta1.LocalSubjectAccessReview, error)

func (*AuthorizationV1Beta1) CreateSelfSubjectAccessReview 

func (c *AuthorizationV1Beta1) CreateSelfSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.SelfSubjectAccessReview) (*authorizationv1beta1.SelfSubjectAccessReview, error)

func (*AuthorizationV1Beta1) CreateSubjectAccessReview 

func (c *AuthorizationV1Beta1) CreateSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.SubjectAccessReview) (*authorizationv1beta1.SubjectAccessReview, error)

func (*AuthorizationV1Beta1) DeleteLocalSubjectAccessReview 

func (c *AuthorizationV1Beta1) DeleteLocalSubjectAccessReview(ctx context.Context, name string, namespace string) error

func (*AuthorizationV1Beta1) DeleteSelfSubjectAccessReview 

func (c *AuthorizationV1Beta1) DeleteSelfSubjectAccessReview(ctx context.Context, name string) error

func (*AuthorizationV1Beta1) DeleteSubjectAccessReview 

func (c *AuthorizationV1Beta1) DeleteSubjectAccessReview(ctx context.Context, name string) error

func (*AuthorizationV1Beta1) GetLocalSubjectAccessReview 

func (c *AuthorizationV1Beta1) GetLocalSubjectAccessReview(ctx context.Context, name, namespace string) (*authorizationv1beta1.LocalSubjectAccessReview, error)

func (*AuthorizationV1Beta1) GetSelfSubjectAccessReview 

func (c *AuthorizationV1Beta1) GetSelfSubjectAccessReview(ctx context.Context, name string) (*authorizationv1beta1.SelfSubjectAccessReview, error)

func (*AuthorizationV1Beta1) GetSubjectAccessReview 

func (c *AuthorizationV1Beta1) GetSubjectAccessReview(ctx context.Context, name string) (*authorizationv1beta1.SubjectAccessReview, error)

func (*AuthorizationV1Beta1) UpdateLocalSubjectAccessReview 

func (c *AuthorizationV1Beta1) UpdateLocalSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.LocalSubjectAccessReview) (*authorizationv1beta1.LocalSubjectAccessReview, error)

func (*AuthorizationV1Beta1) UpdateSelfSubjectAccessReview 

func (c *AuthorizationV1Beta1) UpdateSelfSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.SelfSubjectAccessReview) (*authorizationv1beta1.SelfSubjectAccessReview, error)

func (*AuthorizationV1Beta1) UpdateSubjectAccessReview 

func (c *AuthorizationV1Beta1) UpdateSubjectAccessReview(ctx context.Context, obj *authorizationv1beta1.SubjectAccessReview) (*authorizationv1beta1.SubjectAccessReview, error)

type AutoscalingV1 

type AutoscalingV1 struct {
	// contains filtered or unexported fields
}

AutoscalingV1 is a client for interacting with the autoscaling/v1 API group.

func (*AutoscalingV1) CreateHorizontalPodAutoscaler 

func (c *AutoscalingV1) CreateHorizontalPodAutoscaler(ctx context.Context, obj *autoscalingv1.HorizontalPodAutoscaler) (*autoscalingv1.HorizontalPodAutoscaler, error)

func (*AutoscalingV1) CreateScale 

func (c *AutoscalingV1) CreateScale(ctx context.Context, obj *autoscalingv1.Scale) (*autoscalingv1.Scale, error)

func (*AutoscalingV1) DeleteHorizontalPodAutoscaler 

func (c *AutoscalingV1) DeleteHorizontalPodAutoscaler(ctx context.Context, name string, namespace string) error

func (*AutoscalingV1) DeleteScale 

func (c *AutoscalingV1) DeleteScale(ctx context.Context, name string, namespace string) error

func (*AutoscalingV1) GetHorizontalPodAutoscaler 

func (c *AutoscalingV1) GetHorizontalPodAutoscaler(ctx context.Context, name, namespace string) (*autoscalingv1.HorizontalPodAutoscaler, error)

func (*AutoscalingV1) GetScale 

func (c *AutoscalingV1) GetScale(ctx context.Context, name, namespace string) (*autoscalingv1.Scale, error)

func (*AutoscalingV1) ListHorizontalPodAutoscalers 

func (c *AutoscalingV1) ListHorizontalPodAutoscalers(ctx context.Context, namespace string, options ...Option) (*autoscalingv1.HorizontalPodAutoscalerList, error)

func (*AutoscalingV1) UpdateHorizontalPodAutoscaler 

func (c *AutoscalingV1) UpdateHorizontalPodAutoscaler(ctx context.Context, obj *autoscalingv1.HorizontalPodAutoscaler) (*autoscalingv1.HorizontalPodAutoscaler, error)

func (*AutoscalingV1) UpdateScale 

func (c *AutoscalingV1) UpdateScale(ctx context.Context, obj *autoscalingv1.Scale) (*autoscalingv1.Scale, error)

func (*AutoscalingV1) WatchHorizontalPodAutoscalers 

func (c *AutoscalingV1) WatchHorizontalPodAutoscalers(ctx context.Context, namespace string, options ...Option) (*AutoscalingV1HorizontalPodAutoscalerWatcher, error)

type AutoscalingV1HorizontalPodAutoscalerWatcher 

type AutoscalingV1HorizontalPodAutoscalerWatcher struct {
	// contains filtered or unexported fields
}

func (*AutoscalingV1HorizontalPodAutoscalerWatcher) Close 

func (w *AutoscalingV1HorizontalPodAutoscalerWatcher) Close() error

func (*AutoscalingV1HorizontalPodAutoscalerWatcher) Next 

func (w *AutoscalingV1HorizontalPodAutoscalerWatcher) Next() (*versioned.Event, *autoscalingv1.HorizontalPodAutoscaler, error)

type BatchV1 

type BatchV1 struct {
	// contains filtered or unexported fields
}

BatchV1 is a client for interacting with the batch/v1 API group.

func (*BatchV1) CreateJob 

func (c *BatchV1) CreateJob(ctx context.Context, obj *batchv1.Job) (*batchv1.Job, error)

func (*BatchV1) DeleteJob 

func (c *BatchV1) DeleteJob(ctx context.Context, name string, namespace string) error

func (*BatchV1) GetJob 

func (c *BatchV1) GetJob(ctx context.Context, name, namespace string) (*batchv1.Job, error)

func (*BatchV1) ListJobs 

func (c *BatchV1) ListJobs(ctx context.Context, namespace string, options ...Option) (*batchv1.JobList, error)

func (*BatchV1) UpdateJob 

func (c *BatchV1) UpdateJob(ctx context.Context, obj *batchv1.Job) (*batchv1.Job, error)

func (*BatchV1) WatchJobs 

func (c *BatchV1) WatchJobs(ctx context.Context, namespace string, options ...Option) (*BatchV1JobWatcher, error)

type BatchV1JobWatcher 

type BatchV1JobWatcher struct {
	// contains filtered or unexported fields
}

func (*BatchV1JobWatcher) Close 

func (w *BatchV1JobWatcher) Close() error

func (*BatchV1JobWatcher) Next 

func (w *BatchV1JobWatcher) Next() (*versioned.Event, *batchv1.Job, error)

type BatchV2Alpha1 

type BatchV2Alpha1 struct {
	// contains filtered or unexported fields
}

BatchV2Alpha1 is a client for interacting with the batch/v2alpha1 API group.

func (*BatchV2Alpha1) CreateCronJob 

func (c *BatchV2Alpha1) CreateCronJob(ctx context.Context, obj *batchv2alpha1.CronJob) (*batchv2alpha1.CronJob, error)

func (*BatchV2Alpha1) CreateJob 

func (c *BatchV2Alpha1) CreateJob(ctx context.Context, obj *batchv2alpha1.Job) (*batchv2alpha1.Job, error)

func (*BatchV2Alpha1) CreateJobTemplate 

func (c *BatchV2Alpha1) CreateJobTemplate(ctx context.Context, obj *batchv2alpha1.JobTemplate) (*batchv2alpha1.JobTemplate, error)

func (*BatchV2Alpha1) DeleteCronJob 

func (c *BatchV2Alpha1) DeleteCronJob(ctx context.Context, name string, namespace string) error

func (*BatchV2Alpha1) DeleteJob 

func (c *BatchV2Alpha1) DeleteJob(ctx context.Context, name string, namespace string) error

func (*BatchV2Alpha1) DeleteJobTemplate 

func (c *BatchV2Alpha1) DeleteJobTemplate(ctx context.Context, name string, namespace string) error

func (*BatchV2Alpha1) GetCronJob 

func (c *BatchV2Alpha1) GetCronJob(ctx context.Context, name, namespace string) (*batchv2alpha1.CronJob, error)

func (*BatchV2Alpha1) GetJob 

func (c *BatchV2Alpha1) GetJob(ctx context.Context, name, namespace string) (*batchv2alpha1.Job, error)

func (*BatchV2Alpha1) GetJobTemplate 

func (c *BatchV2Alpha1) GetJobTemplate(ctx context.Context, name, namespace string) (*batchv2alpha1.JobTemplate, error)

func (*BatchV2Alpha1) ListCronJobs 

func (c *BatchV2Alpha1) ListCronJobs(ctx context.Context, namespace string, options ...Option) (*batchv2alpha1.CronJobList, error)

func (*BatchV2Alpha1) ListJobs 

func (c *BatchV2Alpha1) ListJobs(ctx context.Context, namespace string, options ...Option) (*batchv2alpha1.JobList, error)

func (*BatchV2Alpha1) UpdateCronJob 

func (c *BatchV2Alpha1) UpdateCronJob(ctx context.Context, obj *batchv2alpha1.CronJob) (*batchv2alpha1.CronJob, error)

func (*BatchV2Alpha1) UpdateJob 

func (c *BatchV2Alpha1) UpdateJob(ctx context.Context, obj *batchv2alpha1.Job) (*batchv2alpha1.Job, error)

func (*BatchV2Alpha1) UpdateJobTemplate 

func (c *BatchV2Alpha1) UpdateJobTemplate(ctx context.Context, obj *batchv2alpha1.JobTemplate) (*batchv2alpha1.JobTemplate, error)

func (*BatchV2Alpha1) WatchCronJobs 

func (c *BatchV2Alpha1) WatchCronJobs(ctx context.Context, namespace string, options ...Option) (*BatchV2Alpha1CronJobWatcher, error)

func (*BatchV2Alpha1) WatchJobs 

func (c *BatchV2Alpha1) WatchJobs(ctx context.Context, namespace string, options ...Option) (*BatchV2Alpha1JobWatcher, error)

type BatchV2Alpha1CronJobWatcher 

type BatchV2Alpha1CronJobWatcher struct {
	// contains filtered or unexported fields
}

func (*BatchV2Alpha1CronJobWatcher) Close 

func (w *BatchV2Alpha1CronJobWatcher) Close() error

func (*BatchV2Alpha1CronJobWatcher) Next 

func (w *BatchV2Alpha1CronJobWatcher) Next() (*versioned.Event, *batchv2alpha1.CronJob, error)

type BatchV2Alpha1JobWatcher 

type BatchV2Alpha1JobWatcher struct {
	// contains filtered or unexported fields
}

func (*BatchV2Alpha1JobWatcher) Close 

func (w *BatchV2Alpha1JobWatcher) Close() error

func (*BatchV2Alpha1JobWatcher) Next 

func (w *BatchV2Alpha1JobWatcher) Next() (*versioned.Event, *batchv2alpha1.Job, error)

type CertificatesV1Alpha1 

type CertificatesV1Alpha1 struct {
	// contains filtered or unexported fields
}

CertificatesV1Alpha1 is a client for interacting with the certificates.k8s.io/v1alpha1 API group.

func (*CertificatesV1Alpha1) CreateCertificateSigningRequest 

func (c *CertificatesV1Alpha1) CreateCertificateSigningRequest(ctx context.Context, obj *certificatesv1alpha1.CertificateSigningRequest) (*certificatesv1alpha1.CertificateSigningRequest, error)

func (*CertificatesV1Alpha1) DeleteCertificateSigningRequest 

func (c *CertificatesV1Alpha1) DeleteCertificateSigningRequest(ctx context.Context, name string) error

func (*CertificatesV1Alpha1) GetCertificateSigningRequest 

func (c *CertificatesV1Alpha1) GetCertificateSigningRequest(ctx context.Context, name string) (*certificatesv1alpha1.CertificateSigningRequest, error)

func (*CertificatesV1Alpha1) ListCertificateSigningRequests 

func (c *CertificatesV1Alpha1) ListCertificateSigningRequests(ctx context.Context, options ...Option) (*certificatesv1alpha1.CertificateSigningRequestList, error)

func (*CertificatesV1Alpha1) UpdateCertificateSigningRequest 

func (c *CertificatesV1Alpha1) UpdateCertificateSigningRequest(ctx context.Context, obj *certificatesv1alpha1.CertificateSigningRequest) (*certificatesv1alpha1.CertificateSigningRequest, error)

func (*CertificatesV1Alpha1) WatchCertificateSigningRequests 

func (c *CertificatesV1Alpha1) WatchCertificateSigningRequests(ctx context.Context, options ...Option) (*CertificatesV1Alpha1CertificateSigningRequestWatcher, error)

type CertificatesV1Alpha1CertificateSigningRequestWatcher 

type CertificatesV1Alpha1CertificateSigningRequestWatcher struct {
	// contains filtered or unexported fields
}

func (*CertificatesV1Alpha1CertificateSigningRequestWatcher) Close 

func (w *CertificatesV1Alpha1CertificateSigningRequestWatcher) Close() error

func (*CertificatesV1Alpha1CertificateSigningRequestWatcher) Next 

func (w *CertificatesV1Alpha1CertificateSigningRequestWatcher) Next() (*versioned.Event, *certificatesv1alpha1.CertificateSigningRequest, error)

type Client 

type Client struct {
	// The URL of the API server.
	Endpoint string

	// Default namespaces for objects that don't supply a namespace in
	// their object metadata.
	Namespace string

	// SetHeaders provides a hook for modifying the HTTP headers of all requests.
	//
	//		client, err := k8s.NewClient(config)
	//		if err != nil {
	//			// handle error
	//		}
	//		client.SetHeaders = func(h http.Header) error {
	//			h.Set("Authorization", "Bearer "+mytoken)
	//			return nil
	//		}
	//
	SetHeaders func(h http.Header) error

	Client *http.Client
}

Client is a Kuberntes client.

func NewClient 

func NewClient(config *Config) (*Client, error)

NewClient initializes a client from a client config.

func NewInClusterClient 

func NewInClusterClient() (*Client, error)

NewInClusterClient returns a client that uses the service account bearer token mounted into Kubernetes pods.

func (*Client) AppsV1Alpha1 

func (c *Client) AppsV1Alpha1() *AppsV1Alpha1

AppsV1Alpha1 returns a client for interacting with the apps/v1alpha1 API group.

func (*Client) AppsV1Beta1 

func (c *Client) AppsV1Beta1() *AppsV1Beta1

AppsV1Beta1 returns a client for interacting with the apps/v1beta1 API group.

func (*Client) AuthenticationV1Beta1 

func (c *Client) AuthenticationV1Beta1() *AuthenticationV1Beta1

AuthenticationV1Beta1 returns a client for interacting with the authentication.k8s.io/v1beta1 API group.

func (*Client) AuthorizationV1Beta1 

func (c *Client) AuthorizationV1Beta1() *AuthorizationV1Beta1

AuthorizationV1Beta1 returns a client for interacting with the authorization.k8s.io/v1beta1 API group.

func (*Client) AutoscalingV1 

func (c *Client) AutoscalingV1() *AutoscalingV1

AutoscalingV1 returns a client for interacting with the autoscaling/v1 API group.

func (*Client) BatchV1 

func (c *Client) BatchV1() *BatchV1

BatchV1 returns a client for interacting with the batch/v1 API group.

func (*Client) BatchV2Alpha1 

func (c *Client) BatchV2Alpha1() *BatchV2Alpha1

BatchV2Alpha1 returns a client for interacting with the batch/v2alpha1 API group.

func (*Client) CertificatesV1Alpha1 

func (c *Client) CertificatesV1Alpha1() *CertificatesV1Alpha1

CertificatesV1Alpha1 returns a client for interacting with the certificates.k8s.io/v1alpha1 API group.

func (*Client) CoreV1 

func (c *Client) CoreV1() *CoreV1

CoreV1 returns a client for interacting with the /v1 API group.

func (*Client) Discovery 

func (c *Client) Discovery() *Discovery

func (*Client) ExtensionsV1Beta1 

func (c *Client) ExtensionsV1Beta1() *ExtensionsV1Beta1

ExtensionsV1Beta1 returns a client for interacting with the extensions/v1beta1 API group.

func (*Client) ImagepolicyV1Alpha1 

func (c *Client) ImagepolicyV1Alpha1() *ImagepolicyV1Alpha1

ImagepolicyV1Alpha1 returns a client for interacting with the imagepolicy/v1alpha1 API group.

func (*Client) PolicyV1Alpha1 

func (c *Client) PolicyV1Alpha1() *PolicyV1Alpha1

PolicyV1Alpha1 returns a client for interacting with the policy/v1alpha1 API group.

func (*Client) PolicyV1Beta1 

func (c *Client) PolicyV1Beta1() *PolicyV1Beta1

PolicyV1Beta1 returns a client for interacting with the policy/v1beta1 API group.

func (*Client) RBACV1Alpha1 

func (c *Client) RBACV1Alpha1() *RBACV1Alpha1

RBACV1Alpha1 returns a client for interacting with the rbac.authorization.k8s.io/v1alpha1 API group.

func (*Client) StorageV1Beta1 

func (c *Client) StorageV1Beta1() *StorageV1Beta1

StorageV1Beta1 returns a client for interacting with the storage.k8s.io/v1beta1 API group.

func (*Client) ThirdPartyResources 

func (c *Client) ThirdPartyResources(apiGroup, apiVersion string) *ThirdPartyResources

ThirdPartyResources returns a client for interacting with a ThirdPartyResource API group.

type Cluster 

type Cluster struct {
	// Server is the address of the kubernetes cluster (https://hostname:port).
	Server string `json:"server"`
	// APIVersion is the preferred api version for communicating with the kubernetes cluster (v1, v2, etc).
	// +optional
	APIVersion string `json:"api-version,omitempty"`
	// InsecureSkipTLSVerify skips the validity check for the server's certificate. This will make your HTTPS connections insecure.
	// +optional
	InsecureSkipTLSVerify bool `json:"insecure-skip-tls-verify,omitempty"`
	// CertificateAuthority is the path to a cert file for the certificate authority.
	// +optional
	CertificateAuthority string `json:"certificate-authority,omitempty"`
	// CertificateAuthorityData contains PEM-encoded certificate authority certificates. Overrides CertificateAuthority
	// +optional
	CertificateAuthorityData []byte `json:"certificate-authority-data,omitempty"`
	// Extensions holds additional information. This is useful for extenders so that reads and writes don't clobber unknown fields
	// +optional
	Extensions []NamedExtension `json:"extensions,omitempty"`
}

Cluster contains information about how to communicate with a kubernetes cluster

type Config 

type Config struct {
	// Legacy field from pkg/api/types.go TypeMeta.
	// TODO(jlowdermilk): remove this after eliminating downstream dependencies.
	// +optional
	Kind string `json:"kind,omitempty"`
	// DEPRECATED: APIVersion is the preferred api version for communicating with the kubernetes cluster (v1, v2, etc).
	// Because a cluster can run multiple API groups and potentially multiple versions of each, it no longer makes sense to specify
	// a single value for the cluster version.
	// This field isn't really needed anyway, so we are deprecating it without replacement.
	// It will be ignored if it is present.
	// +optional
	APIVersion string `json:"apiVersion,omitempty"`
	// Preferences holds general information to be use for cli interactions
	Preferences Preferences `json:"preferences"`
	// Clusters is a map of referencable names to cluster configs
	Clusters []NamedCluster `json:"clusters"`
	// AuthInfos is a map of referencable names to user configs
	AuthInfos []NamedAuthInfo `json:"users"`
	// Contexts is a map of referencable names to context configs
	Contexts []NamedContext `json:"contexts"`
	// CurrentContext is the name of the context that you would like to use by default
	CurrentContext string `json:"current-context"`
	// Extensions holds additional information. This is useful for extenders so that reads and writes don't clobber unknown fields
	// +optional
	Extensions []NamedExtension `json:"extensions,omitempty"`
}

Config holds the information needed to build connect to remote kubernetes clusters as a given user

type Context 

type Context struct {
	// Cluster is the name of the cluster for this context
	Cluster string `json:"cluster"`
	// AuthInfo is the name of the authInfo for this context
	AuthInfo string `json:"user"`
	// Namespace is the default namespace to use on unspecified requests
	// +optional
	Namespace string `json:"namespace,omitempty"`
	// Extensions holds additional information. This is useful for extenders so that reads and writes don't clobber unknown fields
	// +optional
	Extensions []NamedExtension `json:"extensions,omitempty"`
}

Context is a tuple of references to a cluster (how do I communicate with a kubernetes cluster), a user (how do I identify myself), and a namespace (what subset of resources do I want to work with)

type CoreV1 

type CoreV1 struct {
	// contains filtered or unexported fields
}

CoreV1 is a client for interacting with the /v1 API group.

func (*CoreV1) CreateBinding 

func (c *CoreV1) CreateBinding(ctx context.Context, obj *apiv1.Binding) (*apiv1.Binding, error)

func (*CoreV1) CreateComponentStatus 

func (c *CoreV1) CreateComponentStatus(ctx context.Context, obj *apiv1.ComponentStatus) (*apiv1.ComponentStatus, error)

func (*CoreV1) CreateConfigMap 

func (c *CoreV1) CreateConfigMap(ctx context.Context, obj *apiv1.ConfigMap) (*apiv1.ConfigMap, error)

func (*CoreV1) CreateEndpoints 

func (c *CoreV1) CreateEndpoints(ctx context.Context, obj *apiv1.Endpoints) (*apiv1.Endpoints, error)

func (*CoreV1) CreateEvent 

func (c *CoreV1) CreateEvent(ctx context.Context, obj *apiv1.Event) (*apiv1.Event, error)

func (*CoreV1) CreateLimitRange 

func (c *CoreV1) CreateLimitRange(ctx context.Context, obj *apiv1.LimitRange) (*apiv1.LimitRange, error)

func (*CoreV1) CreateNamespace 

func (c *CoreV1) CreateNamespace(ctx context.Context, obj *apiv1.Namespace) (*apiv1.Namespace, error)

func (*CoreV1) CreateNode 

func (c *CoreV1) CreateNode(ctx context.Context, obj *apiv1.Node) (*apiv1.Node, error)

func (*CoreV1) CreatePersistentVolume 

func (c *CoreV1) CreatePersistentVolume(ctx context.Context, obj *apiv1.PersistentVolume) (*apiv1.PersistentVolume, error)

func (*CoreV1) CreatePersistentVolumeClaim 

func (c *CoreV1) CreatePersistentVolumeClaim(ctx context.Context, obj *apiv1.PersistentVolumeClaim) (*apiv1.PersistentVolumeClaim, error)

func (*CoreV1) CreatePod 

func (c *CoreV1) CreatePod(ctx context.Context, obj *apiv1.Pod) (*apiv1.Pod, error)

func (*CoreV1) CreatePodStatusResult 

func (c *CoreV1) CreatePodStatusResult(ctx context.Context, obj *apiv1.PodStatusResult) (*apiv1.PodStatusResult, error)

func (*CoreV1) CreatePodTemplate 

func (c *CoreV1) CreatePodTemplate(ctx context.Context, obj *apiv1.PodTemplate) (*apiv1.PodTemplate, error)

func (*CoreV1) CreatePodTemplateSpec 

func (c *CoreV1) CreatePodTemplateSpec(ctx context.Context, obj *apiv1.PodTemplateSpec) (*apiv1.PodTemplateSpec, error)

func (*CoreV1) CreateRangeAllocation 

func (c *CoreV1) CreateRangeAllocation(ctx context.Context, obj *apiv1.RangeAllocation) (*apiv1.RangeAllocation, error)

func (*CoreV1) CreateReplicationController 

func (c *CoreV1) CreateReplicationController(ctx context.Context, obj *apiv1.ReplicationController) (*apiv1.ReplicationController, error)

func (*CoreV1) CreateResourceQuota 

func (c *CoreV1) CreateResourceQuota(ctx context.Context, obj *apiv1.ResourceQuota) (*apiv1.ResourceQuota, error)

func (*CoreV1) CreateSecret 

func (c *CoreV1) CreateSecret(ctx context.Context, obj *apiv1.Secret) (*apiv1.Secret, error)

func (*CoreV1) CreateService 

func (c *CoreV1) CreateService(ctx context.Context, obj *apiv1.Service) (*apiv1.Service, error)

func (*CoreV1) CreateServiceAccount 

func (c *CoreV1) CreateServiceAccount(ctx context.Context, obj *apiv1.ServiceAccount) (*apiv1.ServiceAccount, error)

func (*CoreV1) DeleteBinding 

func (c *CoreV1) DeleteBinding(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteComponentStatus 

func (c *CoreV1) DeleteComponentStatus(ctx context.Context, name string) error

func (*CoreV1) DeleteConfigMap 

func (c *CoreV1) DeleteConfigMap(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteEndpoints 

func (c *CoreV1) DeleteEndpoints(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteEvent 

func (c *CoreV1) DeleteEvent(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteLimitRange 

func (c *CoreV1) DeleteLimitRange(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteNamespace 

func (c *CoreV1) DeleteNamespace(ctx context.Context, name string) error

func (*CoreV1) DeleteNode 

func (c *CoreV1) DeleteNode(ctx context.Context, name string) error

func (*CoreV1) DeletePersistentVolume 

func (c *CoreV1) DeletePersistentVolume(ctx context.Context, name string) error

func (*CoreV1) DeletePersistentVolumeClaim 

func (c *CoreV1) DeletePersistentVolumeClaim(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeletePod 

func (c *CoreV1) DeletePod(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeletePodStatusResult 

func (c *CoreV1) DeletePodStatusResult(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeletePodTemplate 

func (c *CoreV1) DeletePodTemplate(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeletePodTemplateSpec 

func (c *CoreV1) DeletePodTemplateSpec(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteRangeAllocation 

func (c *CoreV1) DeleteRangeAllocation(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteReplicationController 

func (c *CoreV1) DeleteReplicationController(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteResourceQuota 

func (c *CoreV1) DeleteResourceQuota(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteSecret 

func (c *CoreV1) DeleteSecret(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteService 

func (c *CoreV1) DeleteService(ctx context.Context, name string, namespace string) error

func (*CoreV1) DeleteServiceAccount 

func (c *CoreV1) DeleteServiceAccount(ctx context.Context, name string, namespace string) error

func (*CoreV1) GetBinding 

func (c *CoreV1) GetBinding(ctx context.Context, name, namespace string) (*apiv1.Binding, error)

func (*CoreV1) GetComponentStatus 

func (c *CoreV1) GetComponentStatus(ctx context.Context, name string) (*apiv1.ComponentStatus, error)

func (*CoreV1) GetConfigMap 

func (c *CoreV1) GetConfigMap(ctx context.Context, name, namespace string) (*apiv1.ConfigMap, error)

func (*CoreV1) GetEndpoints 

func (c *CoreV1) GetEndpoints(ctx context.Context, name, namespace string) (*apiv1.Endpoints, error)

func (*CoreV1) GetEvent 

func (c *CoreV1) GetEvent(ctx context.Context, name, namespace string) (*apiv1.Event, error)

func (*CoreV1) GetLimitRange 

func (c *CoreV1) GetLimitRange(ctx context.Context, name, namespace string) (*apiv1.LimitRange, error)

func (*CoreV1) GetNamespace 

func (c *CoreV1) GetNamespace(ctx context.Context, name string) (*apiv1.Namespace, error)

func (*CoreV1) GetNode 

func (c *CoreV1) GetNode(ctx context.Context, name string) (*apiv1.Node, error)

func (*CoreV1) GetPersistentVolume 

func (c *CoreV1) GetPersistentVolume(ctx context.Context, name string) (*apiv1.PersistentVolume, error)

func (*CoreV1) GetPersistentVolumeClaim 

func (c *CoreV1) GetPersistentVolumeClaim(ctx context.Context, name, namespace string) (*apiv1.PersistentVolumeClaim, error)

func (*CoreV1) GetPod 

func (c *CoreV1) GetPod(ctx context.Context, name, namespace string) (*apiv1.Pod, error)

func (*CoreV1) GetPodStatusResult 

func (c *CoreV1) GetPodStatusResult(ctx context.Context, name, namespace string) (*apiv1.PodStatusResult, error)

func (*CoreV1) GetPodTemplate 

func (c *CoreV1) GetPodTemplate(ctx context.Context, name, namespace string) (*apiv1.PodTemplate, error)

func (*CoreV1) GetPodTemplateSpec 

func (c *CoreV1) GetPodTemplateSpec(ctx context.Context, name, namespace string) (*apiv1.PodTemplateSpec, error)

func (*CoreV1) GetRangeAllocation 

func (c *CoreV1) GetRangeAllocation(ctx context.Context, name, namespace string) (*apiv1.RangeAllocation, error)

func (*CoreV1) GetReplicationController 

func (c *CoreV1) GetReplicationController(ctx context.Context, name, namespace string) (*apiv1.ReplicationController, error)

func (*CoreV1) GetResourceQuota 

func (c *CoreV1) GetResourceQuota(ctx context.Context, name, namespace string) (*apiv1.ResourceQuota, error)

func (*CoreV1) GetSecret 

func (c *CoreV1) GetSecret(ctx context.Context, name, namespace string) (*apiv1.Secret, error)

func (*CoreV1) GetService 

func (c *CoreV1) GetService(ctx context.Context, name, namespace string) (*apiv1.Service, error)

func (*CoreV1) GetServiceAccount 

func (c *CoreV1) GetServiceAccount(ctx context.Context, name, namespace string) (*apiv1.ServiceAccount, error)

func (*CoreV1) ListComponentStatuses 

func (c *CoreV1) ListComponentStatuses(ctx context.Context, options ...Option) (*apiv1.ComponentStatusList, error)

func (*CoreV1) ListConfigMaps 

func (c *CoreV1) ListConfigMaps(ctx context.Context, namespace string, options ...Option) (*apiv1.ConfigMapList, error)

func (*CoreV1) ListEndpointses 

func (c *CoreV1) ListEndpointses(ctx context.Context, namespace string, options ...Option) (*apiv1.EndpointsList, error)

func (*CoreV1) ListEvents 

func (c *CoreV1) ListEvents(ctx context.Context, namespace string, options ...Option) (*apiv1.EventList, error)

func (*CoreV1) ListLimitRanges 

func (c *CoreV1) ListLimitRanges(ctx context.Context, namespace string, options ...Option) (*apiv1.LimitRangeList, error)

func (*CoreV1) ListNamespaces 

func (c *CoreV1) ListNamespaces(ctx context.Context, options ...Option) (*apiv1.NamespaceList, error)

func (*CoreV1) ListNodes 

func (c *CoreV1) ListNodes(ctx context.Context, options ...Option) (*apiv1.NodeList, error)

func (*CoreV1) ListPersistentVolumeClaims 

func (c *CoreV1) ListPersistentVolumeClaims(ctx context.Context, namespace string, options ...Option) (*apiv1.PersistentVolumeClaimList, error)

func (*CoreV1) ListPersistentVolumes 

func (c *CoreV1) ListPersistentVolumes(ctx context.Context, options ...Option) (*apiv1.PersistentVolumeList, error)

func (*CoreV1) ListPodTemplates 

func (c *CoreV1) ListPodTemplates(ctx context.Context, namespace string, options ...Option) (*apiv1.PodTemplateList, error)

func (*CoreV1) ListPods 

func (c *CoreV1) ListPods(ctx context.Context, namespace string, options ...Option) (*apiv1.PodList, error)

func (*CoreV1) ListReplicationControllers 

func (c *CoreV1) ListReplicationControllers(ctx context.Context, namespace string, options ...Option) (*apiv1.ReplicationControllerList, error)

func (*CoreV1) ListResourceQuotas 

func (c *CoreV1) ListResourceQuotas(ctx context.Context, namespace string, options ...Option) (*apiv1.ResourceQuotaList, error)

func (*CoreV1) ListSecrets 

func (c *CoreV1) ListSecrets(ctx context.Context, namespace string, options ...Option) (*apiv1.SecretList, error)

func (*CoreV1) ListServiceAccounts 

func (c *CoreV1) ListServiceAccounts(ctx context.Context, namespace string, options ...Option) (*apiv1.ServiceAccountList, error)

func (*CoreV1) ListServices 

func (c *CoreV1) ListServices(ctx context.Context, namespace string, options ...Option) (*apiv1.ServiceList, error)

func (*CoreV1) UpdateBinding 

func (c *CoreV1) UpdateBinding(ctx context.Context, obj *apiv1.Binding) (*apiv1.Binding, error)

func (*CoreV1) UpdateComponentStatus 

func (c *CoreV1) UpdateComponentStatus(ctx context.Context, obj *apiv1.ComponentStatus) (*apiv1.ComponentStatus, error)

func (*CoreV1) UpdateConfigMap 

func (c *CoreV1) UpdateConfigMap(ctx context.Context, obj *apiv1.ConfigMap) (*apiv1.ConfigMap, error)

func (*CoreV1) UpdateEndpoints 

func (c *CoreV1) UpdateEndpoints(ctx context.Context, obj *apiv1.Endpoints) (*apiv1.Endpoints, error)

func (*CoreV1) UpdateEvent 

func (c *CoreV1) UpdateEvent(ctx context.Context, obj *apiv1.Event) (*apiv1.Event, error)

func (*CoreV1) UpdateLimitRange 

func (c *CoreV1) UpdateLimitRange(ctx context.Context, obj *apiv1.LimitRange) (*apiv1.LimitRange, error)

func (*CoreV1) UpdateNamespace 

func (c *CoreV1) UpdateNamespace(ctx context.Context, obj *apiv1.Namespace) (*apiv1.Namespace, error)

func (*CoreV1) UpdateNode 

func (c *CoreV1) UpdateNode(ctx context.Context, obj *apiv1.Node) (*apiv1.Node, error)

func (*CoreV1) UpdatePersistentVolume 

func (c *CoreV1) UpdatePersistentVolume(ctx context.Context, obj *apiv1.PersistentVolume) (*apiv1.PersistentVolume, error)

func (*CoreV1) UpdatePersistentVolumeClaim 

func (c *CoreV1) UpdatePersistentVolumeClaim(ctx context.Context, obj *apiv1.PersistentVolumeClaim) (*apiv1.PersistentVolumeClaim, error)

func (*CoreV1) UpdatePod 

func (c *CoreV1) UpdatePod(ctx context.Context, obj *apiv1.Pod) (*apiv1.Pod, error)

func (*CoreV1) UpdatePodStatusResult 

func (c *CoreV1) UpdatePodStatusResult(ctx context.Context, obj *apiv1.PodStatusResult) (*apiv1.PodStatusResult, error)

func (*CoreV1) UpdatePodTemplate 

func (c *CoreV1) UpdatePodTemplate(ctx context.Context, obj *apiv1.PodTemplate) (*apiv1.PodTemplate, error)

func (*CoreV1) UpdatePodTemplateSpec 

func (c *CoreV1) UpdatePodTemplateSpec(ctx context.Context, obj *apiv1.PodTemplateSpec) (*apiv1.PodTemplateSpec, error)

func (*CoreV1) UpdateRangeAllocation 

func (c *CoreV1) UpdateRangeAllocation(ctx context.Context, obj *apiv1.RangeAllocation) (*apiv1.RangeAllocation, error)

func (*CoreV1) UpdateReplicationController 

func (c *CoreV1) UpdateReplicationController(ctx context.Context, obj *apiv1.ReplicationController) (*apiv1.ReplicationController, error)

func (*CoreV1) UpdateResourceQuota 

func (c *CoreV1) UpdateResourceQuota(ctx context.Context, obj *apiv1.ResourceQuota) (*apiv1.ResourceQuota, error)

func (*CoreV1) UpdateSecret 

func (c *CoreV1) UpdateSecret(ctx context.Context, obj *apiv1.Secret) (*apiv1.Secret, error)

func (*CoreV1) UpdateService 

func (c *CoreV1) UpdateService(ctx context.Context, obj *apiv1.Service) (*apiv1.Service, error)

func (*CoreV1) UpdateServiceAccount 

func (c *CoreV1) UpdateServiceAccount(ctx context.Context, obj *apiv1.ServiceAccount) (*apiv1.ServiceAccount, error)

func (*CoreV1) WatchComponentStatuses 

func (c *CoreV1) WatchComponentStatuses(ctx context.Context, options ...Option) (*CoreV1ComponentStatusWatcher, error)

func (*CoreV1) WatchConfigMaps 

func (c *CoreV1) WatchConfigMaps(ctx context.Context, namespace string, options ...Option) (*CoreV1ConfigMapWatcher, error)

func (*CoreV1) WatchEndpointses 

func (c *CoreV1) WatchEndpointses(ctx context.Context, namespace string, options ...Option) (*CoreV1EndpointsWatcher, error)

func (*CoreV1) WatchEvents 

func (c *CoreV1) WatchEvents(ctx context.Context, namespace string, options ...Option) (*CoreV1EventWatcher, error)

func (*CoreV1) WatchLimitRanges 

func (c *CoreV1) WatchLimitRanges(ctx context.Context, namespace string, options ...Option) (*CoreV1LimitRangeWatcher, error)

func (*CoreV1) WatchNamespaces 

func (c *CoreV1) WatchNamespaces(ctx context.Context, options ...Option) (*CoreV1NamespaceWatcher, error)

func (*CoreV1) WatchNodes 

func (c *CoreV1) WatchNodes(ctx context.Context, options ...Option) (*CoreV1NodeWatcher, error)

func (*CoreV1) WatchPersistentVolumeClaims 

func (c *CoreV1) WatchPersistentVolumeClaims(ctx context.Context, namespace string, options ...Option) (*CoreV1PersistentVolumeClaimWatcher, error)

func (*CoreV1) WatchPersistentVolumes 

func (c *CoreV1) WatchPersistentVolumes(ctx context.Context, options ...Option) (*CoreV1PersistentVolumeWatcher, error)

func (*CoreV1) WatchPodTemplates 

func (c *CoreV1) WatchPodTemplates(ctx context.Context, namespace string, options ...Option) (*CoreV1PodTemplateWatcher, error)

func (*CoreV1) WatchPods 

func (c *CoreV1) WatchPods(ctx context.Context, namespace string, options ...Option) (*CoreV1PodWatcher, error)

func (*CoreV1) WatchReplicationControllers 

func (c *CoreV1) WatchReplicationControllers(ctx context.Context, namespace string, options ...Option) (*CoreV1ReplicationControllerWatcher, error)

func (*CoreV1) WatchResourceQuotas 

func (c *CoreV1) WatchResourceQuotas(ctx context.Context, namespace string, options ...Option) (*CoreV1ResourceQuotaWatcher, error)

func (*CoreV1) WatchSecrets 

func (c *CoreV1) WatchSecrets(ctx context.Context, namespace string, options ...Option) (*CoreV1SecretWatcher, error)

func (*CoreV1) WatchServiceAccounts 

func (c *CoreV1) WatchServiceAccounts(ctx context.Context, namespace string, options ...Option) (*CoreV1ServiceAccountWatcher, error)

func (*CoreV1) WatchServices 

func (c *CoreV1) WatchServices(ctx context.Context, namespace string, options ...Option) (*CoreV1ServiceWatcher, error)

type CoreV1ComponentStatusWatcher 

type CoreV1ComponentStatusWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ComponentStatusWatcher) Close 

func (w *CoreV1ComponentStatusWatcher) Close() error

func (*CoreV1ComponentStatusWatcher) Next 

func (w *CoreV1ComponentStatusWatcher) Next() (*versioned.Event, *apiv1.ComponentStatus, error)

type CoreV1ConfigMapWatcher 

type CoreV1ConfigMapWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ConfigMapWatcher) Close 

func (w *CoreV1ConfigMapWatcher) Close() error

func (*CoreV1ConfigMapWatcher) Next 

func (w *CoreV1ConfigMapWatcher) Next() (*versioned.Event, *apiv1.ConfigMap, error)

type CoreV1EndpointsWatcher 

type CoreV1EndpointsWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1EndpointsWatcher) Close 

func (w *CoreV1EndpointsWatcher) Close() error

func (*CoreV1EndpointsWatcher) Next 

func (w *CoreV1EndpointsWatcher) Next() (*versioned.Event, *apiv1.Endpoints, error)

type CoreV1EventWatcher 

type CoreV1EventWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1EventWatcher) Close 

func (w *CoreV1EventWatcher) Close() error

func (*CoreV1EventWatcher) Next 

func (w *CoreV1EventWatcher) Next() (*versioned.Event, *apiv1.Event, error)

type CoreV1LimitRangeWatcher 

type CoreV1LimitRangeWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1LimitRangeWatcher) Close 

func (w *CoreV1LimitRangeWatcher) Close() error

func (*CoreV1LimitRangeWatcher) Next 

func (w *CoreV1LimitRangeWatcher) Next() (*versioned.Event, *apiv1.LimitRange, error)

type CoreV1NamespaceWatcher 

type CoreV1NamespaceWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1NamespaceWatcher) Close 

func (w *CoreV1NamespaceWatcher) Close() error

func (*CoreV1NamespaceWatcher) Next 

func (w *CoreV1NamespaceWatcher) Next() (*versioned.Event, *apiv1.Namespace, error)

type CoreV1NodeWatcher 

type CoreV1NodeWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1NodeWatcher) Close 

func (w *CoreV1NodeWatcher) Close() error

func (*CoreV1NodeWatcher) Next 

func (w *CoreV1NodeWatcher) Next() (*versioned.Event, *apiv1.Node, error)

type CoreV1PersistentVolumeClaimWatcher 

type CoreV1PersistentVolumeClaimWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1PersistentVolumeClaimWatcher) Close 

func (w *CoreV1PersistentVolumeClaimWatcher) Close() error

func (*CoreV1PersistentVolumeClaimWatcher) Next 

func (w *CoreV1PersistentVolumeClaimWatcher) Next() (*versioned.Event, *apiv1.PersistentVolumeClaim, error)

type CoreV1PersistentVolumeWatcher 

type CoreV1PersistentVolumeWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1PersistentVolumeWatcher) Close 

func (w *CoreV1PersistentVolumeWatcher) Close() error

func (*CoreV1PersistentVolumeWatcher) Next 

func (w *CoreV1PersistentVolumeWatcher) Next() (*versioned.Event, *apiv1.PersistentVolume, error)

type CoreV1PodTemplateWatcher 

type CoreV1PodTemplateWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1PodTemplateWatcher) Close 

func (w *CoreV1PodTemplateWatcher) Close() error

func (*CoreV1PodTemplateWatcher) Next 

func (w *CoreV1PodTemplateWatcher) Next() (*versioned.Event, *apiv1.PodTemplate, error)

type CoreV1PodWatcher 

type CoreV1PodWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1PodWatcher) Close 

func (w *CoreV1PodWatcher) Close() error

func (*CoreV1PodWatcher) Next 

func (w *CoreV1PodWatcher) Next() (*versioned.Event, *apiv1.Pod, error)

type CoreV1ReplicationControllerWatcher 

type CoreV1ReplicationControllerWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ReplicationControllerWatcher) Close 

func (w *CoreV1ReplicationControllerWatcher) Close() error

func (*CoreV1ReplicationControllerWatcher) Next 

func (w *CoreV1ReplicationControllerWatcher) Next() (*versioned.Event, *apiv1.ReplicationController, error)

type CoreV1ResourceQuotaWatcher 

type CoreV1ResourceQuotaWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ResourceQuotaWatcher) Close 

func (w *CoreV1ResourceQuotaWatcher) Close() error

func (*CoreV1ResourceQuotaWatcher) Next 

func (w *CoreV1ResourceQuotaWatcher) Next() (*versioned.Event, *apiv1.ResourceQuota, error)

type CoreV1SecretWatcher 

type CoreV1SecretWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1SecretWatcher) Close 

func (w *CoreV1SecretWatcher) Close() error

func (*CoreV1SecretWatcher) Next 

func (w *CoreV1SecretWatcher) Next() (*versioned.Event, *apiv1.Secret, error)

type CoreV1ServiceAccountWatcher 

type CoreV1ServiceAccountWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ServiceAccountWatcher) Close 

func (w *CoreV1ServiceAccountWatcher) Close() error

func (*CoreV1ServiceAccountWatcher) Next 

func (w *CoreV1ServiceAccountWatcher) Next() (*versioned.Event, *apiv1.ServiceAccount, error)

type CoreV1ServiceWatcher 

type CoreV1ServiceWatcher struct {
	// contains filtered or unexported fields
}

func (*CoreV1ServiceWatcher) Close 

func (w *CoreV1ServiceWatcher) Close() error

func (*CoreV1ServiceWatcher) Next 

func (w *CoreV1ServiceWatcher) Next() (*versioned.Event, *apiv1.Service, error)

type Discovery 

type Discovery struct {
	// contains filtered or unexported fields
}

Discovery is a client used to determine the API version and supported resources of the server.

func (*Discovery) APIGroup 

func (d *Discovery) APIGroup(ctx context.Context, name string) (*unversioned.APIGroup, error)

func (*Discovery) APIGroups 

func (d *Discovery) APIGroups(ctx context.Context) (*unversioned.APIGroupList, error)

func (*Discovery) APIResources 

func (d *Discovery) APIResources(ctx context.Context, groupName, groupVersion string) (*unversioned.APIResourceList, error)

func (*Discovery) Version 

func (d *Discovery) Version(ctx context.Context) (*Version, error)

type ExtensionsV1Beta1 

type ExtensionsV1Beta1 struct {
	// contains filtered or unexported fields
}

ExtensionsV1Beta1 is a client for interacting with the extensions/v1beta1 API group.

func (*ExtensionsV1Beta1) CreateDaemonSet 

func (c *ExtensionsV1Beta1) CreateDaemonSet(ctx context.Context, obj *extensionsv1beta1.DaemonSet) (*extensionsv1beta1.DaemonSet, error)

func (*ExtensionsV1Beta1) CreateDeployment 

func (c *ExtensionsV1Beta1) CreateDeployment(ctx context.Context, obj *extensionsv1beta1.Deployment) (*extensionsv1beta1.Deployment, error)

func (*ExtensionsV1Beta1) CreateHorizontalPodAutoscaler 

func (c *ExtensionsV1Beta1) CreateHorizontalPodAutoscaler(ctx context.Context, obj *extensionsv1beta1.HorizontalPodAutoscaler) (*extensionsv1beta1.HorizontalPodAutoscaler, error)

func (*ExtensionsV1Beta1) CreateIngress 

func (c *ExtensionsV1Beta1) CreateIngress(ctx context.Context, obj *extensionsv1beta1.Ingress) (*extensionsv1beta1.Ingress, error)

func (*ExtensionsV1Beta1) CreateJob 

func (c *ExtensionsV1Beta1) CreateJob(ctx context.Context, obj *extensionsv1beta1.Job) (*extensionsv1beta1.Job, error)

func (*ExtensionsV1Beta1) CreateNetworkPolicy 

func (c *ExtensionsV1Beta1) CreateNetworkPolicy(ctx context.Context, obj *extensionsv1beta1.NetworkPolicy) (*extensionsv1beta1.NetworkPolicy, error)

func (*ExtensionsV1Beta1) CreatePodSecurityPolicy 

func (c *ExtensionsV1Beta1) CreatePodSecurityPolicy(ctx context.Context, obj *extensionsv1beta1.PodSecurityPolicy) (*extensionsv1beta1.PodSecurityPolicy, error)

func (*ExtensionsV1Beta1) CreateReplicaSet 

func (c *ExtensionsV1Beta1) CreateReplicaSet(ctx context.Context, obj *extensionsv1beta1.ReplicaSet) (*extensionsv1beta1.ReplicaSet, error)

func (*ExtensionsV1Beta1) CreateScale 

func (c *ExtensionsV1Beta1) CreateScale(ctx context.Context, obj *extensionsv1beta1.Scale) (*extensionsv1beta1.Scale, error)

func (*ExtensionsV1Beta1) CreateThirdPartyResource 

func (c *ExtensionsV1Beta1) CreateThirdPartyResource(ctx context.Context, obj *extensionsv1beta1.ThirdPartyResource) (*extensionsv1beta1.ThirdPartyResource, error)

func (*ExtensionsV1Beta1) CreateThirdPartyResourceData 

func (c *ExtensionsV1Beta1) CreateThirdPartyResourceData(ctx context.Context, obj *extensionsv1beta1.ThirdPartyResourceData) (*extensionsv1beta1.ThirdPartyResourceData, error)

func (*ExtensionsV1Beta1) DeleteDaemonSet 

func (c *ExtensionsV1Beta1) DeleteDaemonSet(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteDeployment 

func (c *ExtensionsV1Beta1) DeleteDeployment(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteHorizontalPodAutoscaler 

func (c *ExtensionsV1Beta1) DeleteHorizontalPodAutoscaler(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteIngress 

func (c *ExtensionsV1Beta1) DeleteIngress(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteJob 

func (c *ExtensionsV1Beta1) DeleteJob(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteNetworkPolicy 

func (c *ExtensionsV1Beta1) DeleteNetworkPolicy(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeletePodSecurityPolicy 

func (c *ExtensionsV1Beta1) DeletePodSecurityPolicy(ctx context.Context, name string) error

func (*ExtensionsV1Beta1) DeleteReplicaSet 

func (c *ExtensionsV1Beta1) DeleteReplicaSet(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteScale 

func (c *ExtensionsV1Beta1) DeleteScale(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) DeleteThirdPartyResource 

func (c *ExtensionsV1Beta1) DeleteThirdPartyResource(ctx context.Context, name string) error

func (*ExtensionsV1Beta1) DeleteThirdPartyResourceData 

func (c *ExtensionsV1Beta1) DeleteThirdPartyResourceData(ctx context.Context, name string, namespace string) error

func (*ExtensionsV1Beta1) GetDaemonSet 

func (c *ExtensionsV1Beta1) GetDaemonSet(ctx context.Context, name, namespace string) (*extensionsv1beta1.DaemonSet, error)

func (*ExtensionsV1Beta1) GetDeployment 

func (c *ExtensionsV1Beta1) GetDeployment(ctx context.Context, name, namespace string) (*extensionsv1beta1.Deployment, error)

func (*ExtensionsV1Beta1) GetHorizontalPodAutoscaler 

func (c *ExtensionsV1Beta1) GetHorizontalPodAutoscaler(ctx context.Context, name, namespace string) (*extensionsv1beta1.HorizontalPodAutoscaler, error)

func (*ExtensionsV1Beta1) GetIngress 

func (c *ExtensionsV1Beta1) GetIngress(ctx context.Context, name, namespace string) (*extensionsv1beta1.Ingress, error)

func (*ExtensionsV1Beta1) GetJob 

func (c *ExtensionsV1Beta1) GetJob(ctx context.Context, name, namespace string) (*extensionsv1beta1.Job, error)

func (*ExtensionsV1Beta1) GetNetworkPolicy 

func (c *ExtensionsV1Beta1) GetNetworkPolicy(ctx context.Context, name, namespace string) (*extensionsv1beta1.NetworkPolicy, error)

func (*ExtensionsV1Beta1) GetPodSecurityPolicy 

func (c *ExtensionsV1Beta1) GetPodSecurityPolicy(ctx context.Context, name string) (*extensionsv1beta1.PodSecurityPolicy, error)

func (*ExtensionsV1Beta1) GetReplicaSet 

func (c *ExtensionsV1Beta1) GetReplicaSet(ctx context.Context, name, namespace string) (*extensionsv1beta1.ReplicaSet, error)

func (*ExtensionsV1Beta1) GetScale 

func (c *ExtensionsV1Beta1) GetScale(ctx context.Context, name, namespace string) (*extensionsv1beta1.Scale, error)

func (*ExtensionsV1Beta1) GetThirdPartyResource 

func (c *ExtensionsV1Beta1) GetThirdPartyResource(ctx context.Context, name string) (*extensionsv1beta1.ThirdPartyResource, error)

func (*ExtensionsV1Beta1) GetThirdPartyResourceData 

func (c *ExtensionsV1Beta1) GetThirdPartyResourceData(ctx context.Context, name, namespace string) (*extensionsv1beta1.ThirdPartyResourceData, error)

func (*ExtensionsV1Beta1) ListDaemonSets 

func (c *ExtensionsV1Beta1) ListDaemonSets(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.DaemonSetList, error)

func (*ExtensionsV1Beta1) ListDeployments 

func (c *ExtensionsV1Beta1) ListDeployments(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.DeploymentList, error)

func (*ExtensionsV1Beta1) ListHorizontalPodAutoscalers 

func (c *ExtensionsV1Beta1) ListHorizontalPodAutoscalers(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.HorizontalPodAutoscalerList, error)

func (*ExtensionsV1Beta1) ListIngresses 

func (c *ExtensionsV1Beta1) ListIngresses(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.IngressList, error)

func (*ExtensionsV1Beta1) ListJobs 

func (c *ExtensionsV1Beta1) ListJobs(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.JobList, error)

func (*ExtensionsV1Beta1) ListNetworkPolicies 

func (c *ExtensionsV1Beta1) ListNetworkPolicies(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.NetworkPolicyList, error)

func (*ExtensionsV1Beta1) ListPodSecurityPolicies 

func (c *ExtensionsV1Beta1) ListPodSecurityPolicies(ctx context.Context, options ...Option) (*extensionsv1beta1.PodSecurityPolicyList, error)

func (*ExtensionsV1Beta1) ListReplicaSets 

func (c *ExtensionsV1Beta1) ListReplicaSets(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.ReplicaSetList, error)

func (*ExtensionsV1Beta1) ListThirdPartyResourceDatas 

func (c *ExtensionsV1Beta1) ListThirdPartyResourceDatas(ctx context.Context, namespace string, options ...Option) (*extensionsv1beta1.ThirdPartyResourceDataList, error)

func (*ExtensionsV1Beta1) ListThirdPartyResources 

func (c *ExtensionsV1Beta1) ListThirdPartyResources(ctx context.Context, options ...Option) (*extensionsv1beta1.ThirdPartyResourceList, error)

func (*ExtensionsV1Beta1) UpdateDaemonSet 

func (c *ExtensionsV1Beta1) UpdateDaemonSet(ctx context.Context, obj *extensionsv1beta1.DaemonSet) (*extensionsv1beta1.DaemonSet, error)

func (*ExtensionsV1Beta1) UpdateDeployment 

func (c *ExtensionsV1Beta1) UpdateDeployment(ctx context.Context, obj *extensionsv1beta1.Deployment) (*extensionsv1beta1.Deployment, error)

func (*ExtensionsV1Beta1) UpdateHorizontalPodAutoscaler 

func (c *ExtensionsV1Beta1) UpdateHorizontalPodAutoscaler(ctx context.Context, obj *extensionsv1beta1.HorizontalPodAutoscaler) (*extensionsv1beta1.HorizontalPodAutoscaler, error)

func (*ExtensionsV1Beta1) UpdateIngress 

func (c *ExtensionsV1Beta1) UpdateIngress(ctx context.Context, obj *extensionsv1beta1.Ingress) (*extensionsv1beta1.Ingress, error)

func (*ExtensionsV1Beta1) UpdateJob 

func (c *ExtensionsV1Beta1) UpdateJob(ctx context.Context, obj *extensionsv1beta1.Job) (*extensionsv1beta1.Job, error)

func (*ExtensionsV1Beta1) UpdateNetworkPolicy 

func (c *ExtensionsV1Beta1) UpdateNetworkPolicy(ctx context.Context, obj *extensionsv1beta1.NetworkPolicy) (*extensionsv1beta1.NetworkPolicy, error)

func (*ExtensionsV1Beta1) UpdatePodSecurityPolicy 

func (c *ExtensionsV1Beta1) UpdatePodSecurityPolicy(ctx context.Context, obj *extensionsv1beta1.PodSecurityPolicy) (*extensionsv1beta1.PodSecurityPolicy, error)

func (*ExtensionsV1Beta1) UpdateReplicaSet 

func (c *ExtensionsV1Beta1) UpdateReplicaSet(ctx context.Context, obj *extensionsv1beta1.ReplicaSet) (*extensionsv1beta1.ReplicaSet, error)

func (*ExtensionsV1Beta1) UpdateScale 

func (c *ExtensionsV1Beta1) UpdateScale(ctx context.Context, obj *extensionsv1beta1.Scale) (*extensionsv1beta1.Scale, error)

func (*ExtensionsV1Beta1) UpdateThirdPartyResource 

func (c *ExtensionsV1Beta1) UpdateThirdPartyResource(ctx context.Context, obj *extensionsv1beta1.ThirdPartyResource) (*extensionsv1beta1.ThirdPartyResource, error)

func (*ExtensionsV1Beta1) UpdateThirdPartyResourceData 

func (c *ExtensionsV1Beta1) UpdateThirdPartyResourceData(ctx context.Context, obj *extensionsv1beta1.ThirdPartyResourceData) (*extensionsv1beta1.ThirdPartyResourceData, error)

func (*ExtensionsV1Beta1) WatchDaemonSets 

func (c *ExtensionsV1Beta1) WatchDaemonSets(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1DaemonSetWatcher, error)

func (*ExtensionsV1Beta1) WatchDeployments 

func (c *ExtensionsV1Beta1) WatchDeployments(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1DeploymentWatcher, error)

func (*ExtensionsV1Beta1) WatchHorizontalPodAutoscalers 

func (c *ExtensionsV1Beta1) WatchHorizontalPodAutoscalers(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1HorizontalPodAutoscalerWatcher, error)

func (*ExtensionsV1Beta1) WatchIngresses 

func (c *ExtensionsV1Beta1) WatchIngresses(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1IngressWatcher, error)

func (*ExtensionsV1Beta1) WatchJobs 

func (c *ExtensionsV1Beta1) WatchJobs(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1JobWatcher, error)

func (*ExtensionsV1Beta1) WatchNetworkPolicies 

func (c *ExtensionsV1Beta1) WatchNetworkPolicies(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1NetworkPolicyWatcher, error)

func (*ExtensionsV1Beta1) WatchPodSecurityPolicies 

func (c *ExtensionsV1Beta1) WatchPodSecurityPolicies(ctx context.Context, options ...Option) (*ExtensionsV1Beta1PodSecurityPolicyWatcher, error)

func (*ExtensionsV1Beta1) WatchReplicaSets 

func (c *ExtensionsV1Beta1) WatchReplicaSets(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1ReplicaSetWatcher, error)

func (*ExtensionsV1Beta1) WatchThirdPartyResourceDatas 

func (c *ExtensionsV1Beta1) WatchThirdPartyResourceDatas(ctx context.Context, namespace string, options ...Option) (*ExtensionsV1Beta1ThirdPartyResourceDataWatcher, error)

func (*ExtensionsV1Beta1) WatchThirdPartyResources 

func (c *ExtensionsV1Beta1) WatchThirdPartyResources(ctx context.Context, options ...Option) (*ExtensionsV1Beta1ThirdPartyResourceWatcher, error)

type ExtensionsV1Beta1DaemonSetWatcher 

type ExtensionsV1Beta1DaemonSetWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1DaemonSetWatcher) Close 

func (w *ExtensionsV1Beta1DaemonSetWatcher) Close() error

func (*ExtensionsV1Beta1DaemonSetWatcher) Next 

func (w *ExtensionsV1Beta1DaemonSetWatcher) Next() (*versioned.Event, *extensionsv1beta1.DaemonSet, error)

type ExtensionsV1Beta1DeploymentWatcher 

type ExtensionsV1Beta1DeploymentWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1DeploymentWatcher) Close 

func (w *ExtensionsV1Beta1DeploymentWatcher) Close() error

func (*ExtensionsV1Beta1DeploymentWatcher) Next 

func (w *ExtensionsV1Beta1DeploymentWatcher) Next() (*versioned.Event, *extensionsv1beta1.Deployment, error)

type ExtensionsV1Beta1HorizontalPodAutoscalerWatcher 

type ExtensionsV1Beta1HorizontalPodAutoscalerWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1HorizontalPodAutoscalerWatcher) Close 

func (w *ExtensionsV1Beta1HorizontalPodAutoscalerWatcher) Close() error

func (*ExtensionsV1Beta1HorizontalPodAutoscalerWatcher) Next 

func (w *ExtensionsV1Beta1HorizontalPodAutoscalerWatcher) Next() (*versioned.Event, *extensionsv1beta1.HorizontalPodAutoscaler, error)

type ExtensionsV1Beta1IngressWatcher 

type ExtensionsV1Beta1IngressWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1IngressWatcher) Close 

func (w *ExtensionsV1Beta1IngressWatcher) Close() error

func (*ExtensionsV1Beta1IngressWatcher) Next 

func (w *ExtensionsV1Beta1IngressWatcher) Next() (*versioned.Event, *extensionsv1beta1.Ingress, error)

type ExtensionsV1Beta1JobWatcher 

type ExtensionsV1Beta1JobWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1JobWatcher) Close 

func (w *ExtensionsV1Beta1JobWatcher) Close() error

func (*ExtensionsV1Beta1JobWatcher) Next 

func (w *ExtensionsV1Beta1JobWatcher) Next() (*versioned.Event, *extensionsv1beta1.Job, error)

type ExtensionsV1Beta1NetworkPolicyWatcher 

type ExtensionsV1Beta1NetworkPolicyWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1NetworkPolicyWatcher) Close 

func (w *ExtensionsV1Beta1NetworkPolicyWatcher) Close() error

func (*ExtensionsV1Beta1NetworkPolicyWatcher) Next 

func (w *ExtensionsV1Beta1NetworkPolicyWatcher) Next() (*versioned.Event, *extensionsv1beta1.NetworkPolicy, error)

type ExtensionsV1Beta1PodSecurityPolicyWatcher 

type ExtensionsV1Beta1PodSecurityPolicyWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1PodSecurityPolicyWatcher) Close 

func (w *ExtensionsV1Beta1PodSecurityPolicyWatcher) Close() error

func (*ExtensionsV1Beta1PodSecurityPolicyWatcher) Next 

func (w *ExtensionsV1Beta1PodSecurityPolicyWatcher) Next() (*versioned.Event, *extensionsv1beta1.PodSecurityPolicy, error)

type ExtensionsV1Beta1ReplicaSetWatcher 

type ExtensionsV1Beta1ReplicaSetWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1ReplicaSetWatcher) Close 

func (w *ExtensionsV1Beta1ReplicaSetWatcher) Close() error

func (*ExtensionsV1Beta1ReplicaSetWatcher) Next 

func (w *ExtensionsV1Beta1ReplicaSetWatcher) Next() (*versioned.Event, *extensionsv1beta1.ReplicaSet, error)

type ExtensionsV1Beta1ThirdPartyResourceDataWatcher 

type ExtensionsV1Beta1ThirdPartyResourceDataWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1ThirdPartyResourceDataWatcher) Close 

func (w *ExtensionsV1Beta1ThirdPartyResourceDataWatcher) Close() error

func (*ExtensionsV1Beta1ThirdPartyResourceDataWatcher) Next 

func (w *ExtensionsV1Beta1ThirdPartyResourceDataWatcher) Next() (*versioned.Event, *extensionsv1beta1.ThirdPartyResourceData, error)

type ExtensionsV1Beta1ThirdPartyResourceWatcher 

type ExtensionsV1Beta1ThirdPartyResourceWatcher struct {
	// contains filtered or unexported fields
}

func (*ExtensionsV1Beta1ThirdPartyResourceWatcher) Close 

func (w *ExtensionsV1Beta1ThirdPartyResourceWatcher) Close() error

func (*ExtensionsV1Beta1ThirdPartyResourceWatcher) Next 

func (w *ExtensionsV1Beta1ThirdPartyResourceWatcher) Next() (*versioned.Event, *extensionsv1beta1.ThirdPartyResource, error)

type ImagepolicyV1Alpha1 

type ImagepolicyV1Alpha1 struct {
	// contains filtered or unexported fields
}

ImagepolicyV1Alpha1 is a client for interacting with the imagepolicy/v1alpha1 API group.

func (*ImagepolicyV1Alpha1) CreateImageReview 

func (c *ImagepolicyV1Alpha1) CreateImageReview(ctx context.Context, obj *imagepolicyv1alpha1.ImageReview) (*imagepolicyv1alpha1.ImageReview, error)

func (*ImagepolicyV1Alpha1) DeleteImageReview 

func (c *ImagepolicyV1Alpha1) DeleteImageReview(ctx context.Context, name string) error

func (*ImagepolicyV1Alpha1) GetImageReview 

func (c *ImagepolicyV1Alpha1) GetImageReview(ctx context.Context, name string) (*imagepolicyv1alpha1.ImageReview, error)

func (*ImagepolicyV1Alpha1) UpdateImageReview 

func (c *ImagepolicyV1Alpha1) UpdateImageReview(ctx context.Context, obj *imagepolicyv1alpha1.ImageReview) (*imagepolicyv1alpha1.ImageReview, error)

type LabelSelector 

type LabelSelector struct {
	// contains filtered or unexported fields
}

LabelSelector represents a Kubernetes label selector.

Any values that don't conform to Kubernetes label value restrictions will be silently dropped. 

l := new(k8s.LabelSelector)
l.Eq("component", "frontend")
l.In("type", "prod", "staging")

func (*LabelSelector) Eq 

func (l *LabelSelector) Eq(key, val string)

Eq selects labels which have the key and the key has the provide value.

func (*LabelSelector) In 

func (l *LabelSelector) In(key string, vals ...string)

In selects labels which have the key and the key has one of the provided values.

func (*LabelSelector) NotEq 

func (l *LabelSelector) NotEq(key, val string)

NotEq selects labels where the key is present and has a different value than the value provided.

func (*LabelSelector) NotIn 

func (l *LabelSelector) NotIn(key string, vals ...string)

NotIn selects labels which have the key and the key is not one of the provided values.

func (*LabelSelector) Selector 

func (l *LabelSelector) Selector() Option

type NamedAuthInfo 

type NamedAuthInfo struct {
	// Name is the nickname for this AuthInfo
	Name string `json:"name"`
	// AuthInfo holds the auth information
	AuthInfo AuthInfo `json:"user"`
}

NamedAuthInfo relates nicknames to auth information

type NamedCluster 

type NamedCluster struct {
	// Name is the nickname for this Cluster
	Name string `json:"name"`
	// Cluster holds the cluster information
	Cluster Cluster `json:"cluster"`
}

NamedCluster relates nicknames to cluster information

type NamedContext 

type NamedContext struct {
	// Name is the nickname for this Context
	Name string `json:"name"`
	// Context holds the context information
	Context Context `json:"context"`
}

NamedContext relates nicknames to context information

type NamedExtension 

type NamedExtension struct {
	// Name is the nickname for this Extension
	Name string `json:"name"`
	// Extension holds the extension information
	Extension runtime.RawExtension `json:"extension"`
}

NamedExtension relates nicknames to extension information

type Option 

type Option interface {
	// contains filtered or unexported methods
}

Option represents optional call parameters, such as label selectors.

func ResourceVersion 

func ResourceVersion(resourceVersion string) Option

ResourceVersion causes watch operations to only show changes since a particular version of a resource.

func Timeout 

func Timeout(d time.Duration) Option

Timeout declares the timeout for list and watch operations. Timeout is only accurate to the second.

type PolicyV1Alpha1 

type PolicyV1Alpha1 struct {
	// contains filtered or unexported fields
}

PolicyV1Alpha1 is a client for interacting with the policy/v1alpha1 API group.

func (*PolicyV1Alpha1) CreateEviction 

func (c *PolicyV1Alpha1) CreateEviction(ctx context.Context, obj *policyv1alpha1.Eviction) (*policyv1alpha1.Eviction, error)

func (*PolicyV1Alpha1) CreatePodDisruptionBudget 

func (c *PolicyV1Alpha1) CreatePodDisruptionBudget(ctx context.Context, obj *policyv1alpha1.PodDisruptionBudget) (*policyv1alpha1.PodDisruptionBudget, error)

func (*PolicyV1Alpha1) DeleteEviction 

func (c *PolicyV1Alpha1) DeleteEviction(ctx context.Context, name string, namespace string) error

func (*PolicyV1Alpha1) DeletePodDisruptionBudget 

func (c *PolicyV1Alpha1) DeletePodDisruptionBudget(ctx context.Context, name string, namespace string) error

func (*PolicyV1Alpha1) GetEviction 

func (c *PolicyV1Alpha1) GetEviction(ctx context.Context, name, namespace string) (*policyv1alpha1.Eviction, error)

func (*PolicyV1Alpha1) GetPodDisruptionBudget 

func (c *PolicyV1Alpha1) GetPodDisruptionBudget(ctx context.Context, name, namespace string) (*policyv1alpha1.PodDisruptionBudget, error)

func (*PolicyV1Alpha1) ListPodDisruptionBudgets 

func (c *PolicyV1Alpha1) ListPodDisruptionBudgets(ctx context.Context, namespace string, options ...Option) (*policyv1alpha1.PodDisruptionBudgetList, error)

func (*PolicyV1Alpha1) UpdateEviction 

func (c *PolicyV1Alpha1) UpdateEviction(ctx context.Context, obj *policyv1alpha1.Eviction) (*policyv1alpha1.Eviction, error)

func (*PolicyV1Alpha1) UpdatePodDisruptionBudget 

func (c *PolicyV1Alpha1) UpdatePodDisruptionBudget(ctx context.Context, obj *policyv1alpha1.PodDisruptionBudget) (*policyv1alpha1.PodDisruptionBudget, error)

func (*PolicyV1Alpha1) WatchPodDisruptionBudgets 

func (c *PolicyV1Alpha1) WatchPodDisruptionBudgets(ctx context.Context, namespace string, options ...Option) (*PolicyV1Alpha1PodDisruptionBudgetWatcher, error)

type PolicyV1Alpha1PodDisruptionBudgetWatcher 

type PolicyV1Alpha1PodDisruptionBudgetWatcher struct {
	// contains filtered or unexported fields
}

func (*PolicyV1Alpha1PodDisruptionBudgetWatcher) Close 

func (w *PolicyV1Alpha1PodDisruptionBudgetWatcher) Close() error

func (*PolicyV1Alpha1PodDisruptionBudgetWatcher) Next 

func (w *PolicyV1Alpha1PodDisruptionBudgetWatcher) Next() (*versioned.Event, *policyv1alpha1.PodDisruptionBudget, error)

type PolicyV1Beta1 

type PolicyV1Beta1 struct {
	// contains filtered or unexported fields
}

PolicyV1Beta1 is a client for interacting with the policy/v1beta1 API group.

func (*PolicyV1Beta1) CreateEviction 

func (c *PolicyV1Beta1) CreateEviction(ctx context.Context, obj *policyv1beta1.Eviction) (*policyv1beta1.Eviction, error)

func (*PolicyV1Beta1) CreatePodDisruptionBudget 

func (c *PolicyV1Beta1) CreatePodDisruptionBudget(ctx context.Context, obj *policyv1beta1.PodDisruptionBudget) (*policyv1beta1.PodDisruptionBudget, error)

func (*PolicyV1Beta1) DeleteEviction 

func (c *PolicyV1Beta1) DeleteEviction(ctx context.Context, name string, namespace string) error

func (*PolicyV1Beta1) DeletePodDisruptionBudget 

func (c *PolicyV1Beta1) DeletePodDisruptionBudget(ctx context.Context, name string, namespace string) error

func (*PolicyV1Beta1) GetEviction 

func (c *PolicyV1Beta1) GetEviction(ctx context.Context, name, namespace string) (*policyv1beta1.Eviction, error)

func (*PolicyV1Beta1) GetPodDisruptionBudget 

func (c *PolicyV1Beta1) GetPodDisruptionBudget(ctx context.Context, name, namespace string) (*policyv1beta1.PodDisruptionBudget, error)

func (*PolicyV1Beta1) ListPodDisruptionBudgets 

func (c *PolicyV1Beta1) ListPodDisruptionBudgets(ctx context.Context, namespace string, options ...Option) (*policyv1beta1.PodDisruptionBudgetList, error)

func (*PolicyV1Beta1) UpdateEviction 

func (c *PolicyV1Beta1) UpdateEviction(ctx context.Context, obj *policyv1beta1.Eviction) (*policyv1beta1.Eviction, error)

func (*PolicyV1Beta1) UpdatePodDisruptionBudget 

func (c *PolicyV1Beta1) UpdatePodDisruptionBudget(ctx context.Context, obj *policyv1beta1.PodDisruptionBudget) (*policyv1beta1.PodDisruptionBudget, error)

func (*PolicyV1Beta1) WatchPodDisruptionBudgets 

func (c *PolicyV1Beta1) WatchPodDisruptionBudgets(ctx context.Context, namespace string, options ...Option) (*PolicyV1Beta1PodDisruptionBudgetWatcher, error)

type PolicyV1Beta1PodDisruptionBudgetWatcher 

type PolicyV1Beta1PodDisruptionBudgetWatcher struct {
	// contains filtered or unexported fields
}

func (*PolicyV1Beta1PodDisruptionBudgetWatcher) Close 

func (w *PolicyV1Beta1PodDisruptionBudgetWatcher) Close() error

func (*PolicyV1Beta1PodDisruptionBudgetWatcher) Next 

func (w *PolicyV1Beta1PodDisruptionBudgetWatcher) Next() (*versioned.Event, *policyv1beta1.PodDisruptionBudget, error)

type Preferences 

type Preferences struct {
	// +optional
	Colors bool `json:"colors,omitempty"`
	// Extensions holds additional information. This is useful for extenders so that reads and writes don't clobber unknown fields
	// +optional
	Extensions []NamedExtension `json:"extensions,omitempty"`
}

type RBACV1Alpha1 

type RBACV1Alpha1 struct {
	// contains filtered or unexported fields
}

RBACV1Alpha1 is a client for interacting with the rbac.authorization.k8s.io/v1alpha1 API group.

func (*RBACV1Alpha1) CreateClusterRole 

func (c *RBACV1Alpha1) CreateClusterRole(ctx context.Context, obj *rbacv1alpha1.ClusterRole) (*rbacv1alpha1.ClusterRole, error)

func (*RBACV1Alpha1) CreateClusterRoleBinding 

func (c *RBACV1Alpha1) CreateClusterRoleBinding(ctx context.Context, obj *rbacv1alpha1.ClusterRoleBinding) (*rbacv1alpha1.ClusterRoleBinding, error)

func (*RBACV1Alpha1) CreateRole 

func (c *RBACV1Alpha1) CreateRole(ctx context.Context, obj *rbacv1alpha1.Role) (*rbacv1alpha1.Role, error)

func (*RBACV1Alpha1) CreateRoleBinding 

func (c *RBACV1Alpha1) CreateRoleBinding(ctx context.Context, obj *rbacv1alpha1.RoleBinding) (*rbacv1alpha1.RoleBinding, error)

func (*RBACV1Alpha1) DeleteClusterRole 

func (c *RBACV1Alpha1) DeleteClusterRole(ctx context.Context, name string) error

func (*RBACV1Alpha1) DeleteClusterRoleBinding 

func (c *RBACV1Alpha1) DeleteClusterRoleBinding(ctx context.Context, name string) error

func (*RBACV1Alpha1) DeleteRole 

func (c *RBACV1Alpha1) DeleteRole(ctx context.Context, name string, namespace string) error

func (*RBACV1Alpha1) DeleteRoleBinding 

func (c *RBACV1Alpha1) DeleteRoleBinding(ctx context.Context, name string, namespace string) error

func (*RBACV1Alpha1) GetClusterRole 

func (c *RBACV1Alpha1) GetClusterRole(ctx context.Context, name string) (*rbacv1alpha1.ClusterRole, error)

func (*RBACV1Alpha1) GetClusterRoleBinding 

func (c *RBACV1Alpha1) GetClusterRoleBinding(ctx context.Context, name string) (*rbacv1alpha1.ClusterRoleBinding, error)

func (*RBACV1Alpha1) GetRole 

func (c *RBACV1Alpha1) GetRole(ctx context.Context, name, namespace string) (*rbacv1alpha1.Role, error)

func (*RBACV1Alpha1) GetRoleBinding 

func (c *RBACV1Alpha1) GetRoleBinding(ctx context.Context, name, namespace string) (*rbacv1alpha1.RoleBinding, error)

func (*RBACV1Alpha1) ListClusterRoleBindings 

func (c *RBACV1Alpha1) ListClusterRoleBindings(ctx context.Context, options ...Option) (*rbacv1alpha1.ClusterRoleBindingList, error)

func (*RBACV1Alpha1) ListClusterRoles 

func (c *RBACV1Alpha1) ListClusterRoles(ctx context.Context, options ...Option) (*rbacv1alpha1.ClusterRoleList, error)

func (*RBACV1Alpha1) ListRoleBindings 

func (c *RBACV1Alpha1) ListRoleBindings(ctx context.Context, namespace string, options ...Option) (*rbacv1alpha1.RoleBindingList, error)

func (*RBACV1Alpha1) ListRoles 

func (c *RBACV1Alpha1) ListRoles(ctx context.Context, namespace string, options ...Option) (*rbacv1alpha1.RoleList, error)

func (*RBACV1Alpha1) UpdateClusterRole 

func (c *RBACV1Alpha1) UpdateClusterRole(ctx context.Context, obj *rbacv1alpha1.ClusterRole) (*rbacv1alpha1.ClusterRole, error)

func (*RBACV1Alpha1) UpdateClusterRoleBinding 

func (c *RBACV1Alpha1) UpdateClusterRoleBinding(ctx context.Context, obj *rbacv1alpha1.ClusterRoleBinding) (*rbacv1alpha1.ClusterRoleBinding, error)

func (*RBACV1Alpha1) UpdateRole 

func (c *RBACV1Alpha1) UpdateRole(ctx context.Context, obj *rbacv1alpha1.Role) (*rbacv1alpha1.Role, error)

func (*RBACV1Alpha1) UpdateRoleBinding 

func (c *RBACV1Alpha1) UpdateRoleBinding(ctx context.Context, obj *rbacv1alpha1.RoleBinding) (*rbacv1alpha1.RoleBinding, error)

func (*RBACV1Alpha1) WatchClusterRoleBindings 

func (c *RBACV1Alpha1) WatchClusterRoleBindings(ctx context.Context, options ...Option) (*RBACV1Alpha1ClusterRoleBindingWatcher, error)

func (*RBACV1Alpha1) WatchClusterRoles 

func (c *RBACV1Alpha1) WatchClusterRoles(ctx context.Context, options ...Option) (*RBACV1Alpha1ClusterRoleWatcher, error)

func (*RBACV1Alpha1) WatchRoleBindings 

func (c *RBACV1Alpha1) WatchRoleBindings(ctx context.Context, namespace string, options ...Option) (*RBACV1Alpha1RoleBindingWatcher, error)

func (*RBACV1Alpha1) WatchRoles 

func (c *RBACV1Alpha1) WatchRoles(ctx context.Context, namespace string, options ...Option) (*RBACV1Alpha1RoleWatcher, error)

type RBACV1Alpha1ClusterRoleBindingWatcher 

type RBACV1Alpha1ClusterRoleBindingWatcher struct {
	// contains filtered or unexported fields
}

func (*RBACV1Alpha1ClusterRoleBindingWatcher) Close 

func (w *RBACV1Alpha1ClusterRoleBindingWatcher) Close() error

func (*RBACV1Alpha1ClusterRoleBindingWatcher) Next 

func (w *RBACV1Alpha1ClusterRoleBindingWatcher) Next() (*versioned.Event, *rbacv1alpha1.ClusterRoleBinding, error)

type RBACV1Alpha1ClusterRoleWatcher 

type RBACV1Alpha1ClusterRoleWatcher struct {
	// contains filtered or unexported fields
}

func (*RBACV1Alpha1ClusterRoleWatcher) Close 

func (w *RBACV1Alpha1ClusterRoleWatcher) Close() error

func (*RBACV1Alpha1ClusterRoleWatcher) Next 

func (w *RBACV1Alpha1ClusterRoleWatcher) Next() (*versioned.Event, *rbacv1alpha1.ClusterRole, error)

type RBACV1Alpha1RoleBindingWatcher 

type RBACV1Alpha1RoleBindingWatcher struct {
	// contains filtered or unexported fields
}

func (*RBACV1Alpha1RoleBindingWatcher) Close 

func (w *RBACV1Alpha1RoleBindingWatcher) Close() error

func (*RBACV1Alpha1RoleBindingWatcher) Next 

func (w *RBACV1Alpha1RoleBindingWatcher) Next() (*versioned.Event, *rbacv1alpha1.RoleBinding, error)

type RBACV1Alpha1RoleWatcher 

type RBACV1Alpha1RoleWatcher struct {
	// contains filtered or unexported fields
}

func (*RBACV1Alpha1RoleWatcher) Close 

func (w *RBACV1Alpha1RoleWatcher) Close() error

func (*RBACV1Alpha1RoleWatcher) Next 

func (w *RBACV1Alpha1RoleWatcher) Next() (*versioned.Event, *rbacv1alpha1.Role, error)

type StorageV1Beta1 

type StorageV1Beta1 struct {
	// contains filtered or unexported fields
}

StorageV1Beta1 is a client for interacting with the storage.k8s.io/v1beta1 API group.

func (*StorageV1Beta1) CreateStorageClass 

func (c *StorageV1Beta1) CreateStorageClass(ctx context.Context, obj *storagev1beta1.StorageClass) (*storagev1beta1.StorageClass, error)

func (*StorageV1Beta1) DeleteStorageClass 

func (c *StorageV1Beta1) DeleteStorageClass(ctx context.Context, name string) error

func (*StorageV1Beta1) GetStorageClass 

func (c *StorageV1Beta1) GetStorageClass(ctx context.Context, name string) (*storagev1beta1.StorageClass, error)

func (*StorageV1Beta1) ListStorageClasses 

func (c *StorageV1Beta1) ListStorageClasses(ctx context.Context, options ...Option) (*storagev1beta1.StorageClassList, error)

func (*StorageV1Beta1) UpdateStorageClass 

func (c *StorageV1Beta1) UpdateStorageClass(ctx context.Context, obj *storagev1beta1.StorageClass) (*storagev1beta1.StorageClass, error)

func (*StorageV1Beta1) WatchStorageClasses 

func (c *StorageV1Beta1) WatchStorageClasses(ctx context.Context, options ...Option) (*StorageV1Beta1StorageClassWatcher, error)

type StorageV1Beta1StorageClassWatcher 

type StorageV1Beta1StorageClassWatcher struct {
	// contains filtered or unexported fields
}

func (*StorageV1Beta1StorageClassWatcher) Close 

func (w *StorageV1Beta1StorageClassWatcher) Close() error

func (*StorageV1Beta1StorageClassWatcher) Next 

func (w *StorageV1Beta1StorageClassWatcher) Next() (*versioned.Event, *storagev1beta1.StorageClass, error)

type ThirdPartyResources 

type ThirdPartyResources struct {
	// contains filtered or unexported fields
}

ThirdPartyResources is a client used for interacting with user defined API groups. It uses JSON encoding instead of protobufs which are unsupported for these APIs.

Users are expected to define their own third party resources. 

const metricsResource = "metrics"

// First, define a third party resources with TypeMeta
// and ObjectMeta fields.
type Metric struct {
	*unversioned.TypeMeta   `json:",inline"`
	*v1.ObjectMeta          `json:"metadata,omitempty"`

	Timestamp time.Time `json:"timestamp"`
	Value     []byte    `json:"value"`
}

// Define a list wrapper.
type MetricsList struct {
	*unversioned.TypeMeta `json:",inline"`
	*unversioned.ListMeta `json:"metadata,omitempty"`

	Items []Metric `json:"items"`
}

Register the new resource by creating a ThirdPartyResource type. 

// Create a ThirdPartyResource
tpr := &v1beta1.ThirdPartyResource{
	Metadata: &v1.ObjectMeta{
		Name: k8s.String("metric.metrics.example.com"),
	},
	Description: k8s.String("A custom third party resource"),
	Versions:    []*v1beta1.APIVersions{
		{Name: k8s.String("v1")},
	},
}
_, err := client.ExtensionsV1Beta1().CreateThirdPartyResource(ctx, trp)
if err != nil {
	// handle error
}

After creating the resource type, create a ThirdPartyResources client then use interact with it like any other API group. For example to create a third party resource: 

metricsClient := client.ThirdPartyResources("metrics.example.com", "v1")

metric := &Metric{
	ObjectMeta: &v1.ObjectMeta{
		Name: k8s.String("foo"),
	},
	Timestamp: time.Now(),
	Value:     42,
}

err = metricsClient.Create(ctx, metricsResource, client.Namespace, metric, metric)
if err != nil {
	// handle error
}

List a set of third party resources: 

var metrics MetricsList
metricsClient.List(ctx, metricsResource, &metrics)

Or delete: 

tprClient.Delete(ctx, metricsResource, client.Namespace, *metric.Name)

func (*ThirdPartyResources) Create 

func (t *ThirdPartyResources) Create(ctx context.Context, resource, namespace string, req, resp interface{}) error

func (*ThirdPartyResources) Delete 

func (t *ThirdPartyResources) Delete(ctx context.Context, resource, namespace, name string) error

func (*ThirdPartyResources) Get 

func (t *ThirdPartyResources) Get(ctx context.Context, resource, namespace, name string, resp interface{}) error

func (*ThirdPartyResources) List 

func (t *ThirdPartyResources) List(ctx context.Context, resource, namespace string, resp interface{}) error

func (*ThirdPartyResources) Update 

func (t *ThirdPartyResources) Update(ctx context.Context, resource, namespace, name string, req, resp interface{}) error

type Version 

type Version struct {
	Major        string `json:"major"`
	Minor        string `json:"minor"`
	GitVersion   string `json:"gitVersion"`
	GitCommit    string `json:"gitCommit"`
	GitTreeState string `json:"gitTreeState"`
	BuildDate    string `json:"buildDate"`
	GoVersion    string `json:"goVersion"`
	Compiler     string `json:"compiler"`
	Platform     string `json:"platform"`
}

Source Files

View all Source files

Directories

Path Synopsis
api
resource
Package resource is a generated protocol buffer package.
 Package resource is a generated protocol buffer package.
unversioned
Package unversioned is a generated protocol buffer package.
 Package unversioned is a generated protocol buffer package.
v1
Package v1 is a generated protocol buffer package.
 Package v1 is a generated protocol buffer package.
apis
apps/v1alpha1
Package v1alpha1 is a generated protocol buffer package.
 Package v1alpha1 is a generated protocol buffer package.
apps/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
authentication/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
authorization/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
autoscaling/v1
Package v1 is a generated protocol buffer package.
 Package v1 is a generated protocol buffer package.
batch/v1
Package v1 is a generated protocol buffer package.
 Package v1 is a generated protocol buffer package.
batch/v2alpha1
Package v2alpha1 is a generated protocol buffer package.
 Package v2alpha1 is a generated protocol buffer package.
certificates/v1alpha1
Package v1alpha1 is a generated protocol buffer package.
 Package v1alpha1 is a generated protocol buffer package.
extensions/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
imagepolicy/v1alpha1
Package v1alpha1 is a generated protocol buffer package.
 Package v1alpha1 is a generated protocol buffer package.
policy/v1alpha1
Package v1alpha1 is a generated protocol buffer package.
 Package v1alpha1 is a generated protocol buffer package.
policy/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
rbac/v1alpha1
Package v1alpha1 is a generated protocol buffer package.
 Package v1alpha1 is a generated protocol buffer package.
storage/v1beta1
Package v1beta1 is a generated protocol buffer package.
 Package v1beta1 is a generated protocol buffer package.
Package runtime is a generated protocol buffer package.
 Package runtime is a generated protocol buffer package.
util
intstr
Package intstr is a generated protocol buffer package.
 Package intstr is a generated protocol buffer package.
watch
versioned
Package versioned is a generated protocol buffer package.
 Package versioned is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.