Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client/

directory

Go to main page

Versions in this module

v0

v0.19.1

Dec 15, 2015

v0.19.0

Dec 10, 2015

v0.18.2

Oct 2, 2015

v0.18.1

Sep 21, 2015

v0.18.0

Sep 15, 2015

Changes in this version

+ const CurlCommand

+ const EventInvolvedAPIVersion

+ const EventInvolvedFieldPath

+ const EventInvolvedKind

+ const EventInvolvedName

+ const EventInvolvedNamespace

+ const EventInvolvedResourceVersion

+ const EventInvolvedUID

+ const EventReason

+ const EventSource

+ const JustURL

+ const NodeUnschedulable

+ const ObjectNameField

+ const PodHost

+ const RequestHeaders

+ const ResponseHeaders

+ const ResponseStatus

+ const SecretType

+ const URLTiming

+ func BindClientConfigFlags(flags FlagSet, config *Config)

+ func BindKubeletClientConfigFlags(flags FlagSet, config *KubeletConfig)

+ func ControllerHasDesiredReplicas(c Interface, controller *api.ReplicationController) wait.ConditionFunc

+ func DefaultKubernetesUserAgent() string

+ func DefaultServerURL(host, prefix, version string, defaultTLS bool) (*url.URL, error)

+ func HTTPWrappersForConfig(config *Config, rt http.RoundTripper) (http.RoundTripper, error)

+ func IsConfigTransportTLS(config Config) bool

+ func IsTimeout(err error) bool

+ func LoadTLSFiles(config *Config) error

+ func MakeTransport(config *KubeletConfig) (http.RoundTripper, error)

+ func MatchesServerVersion(client *Client, c *Config) error

+ func NegotiateVersion(client *Client, c *Config, version string, clientRegisteredVersions []string) (string, error)

+ func NewBasicAuthRoundTripper(username, password string, rt http.RoundTripper) http.RoundTripper

+ func NewBearerAuthRoundTripper(bearer string, rt http.RoundTripper) http.RoundTripper

+ func NewClientCertTLSConfig(certData, keyData, caData []byte) (*tls.Config, error)

+ func NewTLSConfig(caData []byte) (*tls.Config, error)

+ func NewUnsafeTLSConfig() *tls.Config

+ func NewUserAgentRoundTripper(agent string, rt http.RoundTripper) http.RoundTripper

+ func SetKubernetesDefaults(config *Config) error

+ func TLSConfigFor(config *Config) (*tls.Config, error)

+ func TransportFor(config *Config) (http.RoundTripper, error)

+ type APIStatus interface

+ Status func() api.Status

+ type Client struct

+ func New(c *Config) (*Client, error)

+ func NewInCluster() (*Client, error)

+ func NewOrDie(c *Config) *Client

+ func (c *Client) ComponentStatuses() ComponentStatusInterface

+ func (c *Client) Endpoints(namespace string) EndpointsInterface

+ func (c *Client) Events(namespace string) EventInterface

+ func (c *Client) LimitRanges(namespace string) LimitRangeInterface

+ func (c *Client) Namespaces() NamespaceInterface

+ func (c *Client) Nodes() NodeInterface

+ func (c *Client) PersistentVolumeClaims(namespace string) PersistentVolumeClaimInterface

+ func (c *Client) PersistentVolumes() PersistentVolumeInterface

+ func (c *Client) PodTemplates(namespace string) PodTemplateInterface

+ func (c *Client) Pods(namespace string) PodInterface

+ func (c *Client) ReplicationControllers(namespace string) ReplicationControllerInterface

+ func (c *Client) ResourceQuotas(namespace string) ResourceQuotaInterface

+ func (c *Client) Secrets(namespace string) SecretsInterface

+ func (c *Client) ServerAPIVersions() (*api.APIVersions, error)

+ func (c *Client) ServerVersion() (*version.Info, error)

+ func (c *Client) ServiceAccounts(namespace string) ServiceAccountsInterface

+ func (c *Client) Services(namespace string) ServiceInterface

+ func (c *Client) ValidateComponents() (*api.ComponentStatusList, error)

+ type ComponentStatusInterface interface

+ Get func(name string) (*api.ComponentStatus, error)

+ List func(label labels.Selector, field fields.Selector) (*api.ComponentStatusList, error)

+ type ComponentStatusesInterface interface

+ ComponentStatuses func() ComponentStatusInterface

+ type ComponentValidatorInterface interface

+ ValidateComponents func() (*api.ComponentStatusList, error)

+ type Config struct

+ BearerToken string

+ Burst int

+ Codec runtime.Codec

+ Host string

+ Insecure bool

+ Password string

+ Prefix string

+ QPS float32

+ Transport http.RoundTripper

+ UserAgent string

+ Username string

+ Version string

+ WrapTransport func(rt http.RoundTripper) http.RoundTripper

+ func InClusterConfig() (*Config, error)

+ type ConnectionInfoGetter interface

+ GetConnectionInfo func(host string) (scheme string, port uint, transport http.RoundTripper, err error)

+ type ContainerInfoGetter interface

+ GetContainerInfo func(host, podID, containerID string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ GetMachineInfo func(host string) (*cadvisorApi.MachineInfo, error)

+ GetRootInfo func(host string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ type DebuggingRoundTripper struct

+ Levels util.StringSet

+ func NewDebuggingRoundTripper(rt http.RoundTripper, levels ...string) *DebuggingRoundTripper

+ func (rt *DebuggingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

+ type EndpointsInterface interface

+ Create func(endpoints *api.Endpoints) (*api.Endpoints, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Endpoints, error)

+ List func(selector labels.Selector) (*api.EndpointsList, error)

+ Update func(endpoints *api.Endpoints) (*api.Endpoints, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type EndpointsNamespacer interface

+ Endpoints func(namespace string) EndpointsInterface

+ type EventInterface interface

+ Create func(event *api.Event) (*api.Event, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Event, error)

+ GetFieldSelector func(involvedObjectName, involvedObjectNamespace, involvedObjectKind, ... *string) fields.Selector

+ List func(label labels.Selector, field fields.Selector) (*api.EventList, error)

+ Search func(objOrRef runtime.Object) (*api.EventList, error)

+ Update func(event *api.Event) (*api.Event, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type EventNamespacer interface

+ Events func(namespace string) EventInterface

+ type FakeKubeletClient struct

+ func (c FakeKubeletClient) GetConnectionInfo(host string) (string, uint, http.RoundTripper, error)

+ func (c FakeKubeletClient) HealthCheck(host string) (probe.Result, string, error)

+ type FakeRESTClient struct

+ Client HTTPClient

+ Codec runtime.Codec

+ Err error

+ Req *http.Request

+ Resp *http.Response

+ func (c *FakeRESTClient) Delete() *Request

+ func (c *FakeRESTClient) Do(req *http.Request) (*http.Response, error)

+ func (c *FakeRESTClient) Get() *Request

+ func (c *FakeRESTClient) Patch(_ api.PatchType) *Request

+ func (c *FakeRESTClient) Post() *Request

+ func (c *FakeRESTClient) Put() *Request

+ type FlagSet interface

+ BoolVar func(p *bool, name string, value bool, usage string)

+ DurationVar func(p *time.Duration, name string, value time.Duration, usage string)

+ Float32Var func(p *float32, name string, value float32, usage string)

+ IntVar func(p *int, name string, value int, usage string)

+ StringVar func(p *string, name, value, usage string)

+ UintVar func(p *uint, name string, value uint, usage string)

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type HTTPClientFunc func(*http.Request) (*http.Response, error)

+ func (f HTTPClientFunc) Do(req *http.Request) (*http.Response, error)

+ type HTTPContainerInfoGetter struct

+ Client *http.Client

+ Port int

+ func (self *HTTPContainerInfoGetter) GetContainerInfo(host, podID, containerID string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ func (self *HTTPContainerInfoGetter) GetMachineInfo(host string) (*cadvisorApi.MachineInfo, error)

+ func (self *HTTPContainerInfoGetter) GetRootInfo(host string, req *cadvisorApi.ContainerInfoRequest) (*cadvisorApi.ContainerInfo, error)

+ type HTTPKubeletClient struct

+ Client *http.Client

+ Config *KubeletConfig

+ func (c *HTTPKubeletClient) GetConnectionInfo(host string) (string, uint, http.RoundTripper, error)

+ func (c *HTTPKubeletClient) HealthCheck(host string) (probe.Result, string, error)

+ type Interface interface

+ type KubeletClient interface

+ func NewKubeletClient(config *KubeletConfig) (KubeletClient, error)

+ type KubeletConfig struct

+ Dial func(net, addr string) (net.Conn, error)

+ EnableHttps bool

+ HTTPTimeout time.Duration

+ Port uint

+ type KubeletHealthChecker interface

+ HealthCheck func(host string) (result probe.Result, output string, err error)

+ type LimitRangeInterface interface

+ Create func(limitRange *api.LimitRange) (*api.LimitRange, error)

+ Delete func(name string) error

+ Get func(name string) (*api.LimitRange, error)

+ List func(selector labels.Selector) (*api.LimitRangeList, error)

+ Update func(limitRange *api.LimitRange) (*api.LimitRange, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type LimitRangesNamespacer interface

+ LimitRanges func(namespace string) LimitRangeInterface

+ type NamespaceInterface interface

+ Create func(item *api.Namespace) (*api.Namespace, error)

+ Delete func(name string) error

+ Finalize func(item *api.Namespace) (*api.Namespace, error)

+ Get func(name string) (result *api.Namespace, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.NamespaceList, error)

+ Status func(item *api.Namespace) (*api.Namespace, error)

+ Update func(item *api.Namespace) (*api.Namespace, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type NamespacesInterface interface

+ Namespaces func() NamespaceInterface

+ type NodeInterface interface

+ Create func(node *api.Node) (*api.Node, error)

+ Delete func(name string) error

+ Get func(name string) (result *api.Node, err error)

+ List func(label labels.Selector, field fields.Selector) (*api.NodeList, error)

+ Update func(*api.Node) (*api.Node, error)

+ UpdateStatus func(*api.Node) (*api.Node, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type NodesInterface interface

+ Nodes func() NodeInterface

+ type PersistentVolumeClaimInterface interface

+ Create func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ Delete func(name string) error

+ Get func(name string) (*api.PersistentVolumeClaim, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PersistentVolumeClaimList, error)

+ Update func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ UpdateStatus func(claim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PersistentVolumeClaimsNamespacer interface

+ PersistentVolumeClaims func(namespace string) PersistentVolumeClaimInterface

+ type PersistentVolumeInterface interface

+ Create func(volume *api.PersistentVolume) (*api.PersistentVolume, error)

+ Delete func(name string) error

+ Get func(name string) (*api.PersistentVolume, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PersistentVolumeList, error)

+ Update func(volume *api.PersistentVolume) (*api.PersistentVolume, error)

+ UpdateStatus func(persistentVolume *api.PersistentVolume) (*api.PersistentVolume, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PersistentVolumesInterface interface

+ PersistentVolumes func() PersistentVolumeInterface

+ type PodInterface interface

+ Bind func(binding *api.Binding) error

+ Create func(pod *api.Pod) (*api.Pod, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*api.Pod, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PodList, error)

+ Update func(pod *api.Pod) (*api.Pod, error)

+ UpdateStatus func(pod *api.Pod) (*api.Pod, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PodTemplateInterface interface

+ Create func(podTemplate *api.PodTemplate) (*api.PodTemplate, error)

+ Delete func(name string, options *api.DeleteOptions) error

+ Get func(name string) (*api.PodTemplate, error)

+ List func(label labels.Selector, field fields.Selector) (*api.PodTemplateList, error)

+ Update func(podTemplate *api.PodTemplate) (*api.PodTemplate, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type PodTemplatesNamespacer interface

+ PodTemplates func(namespace string) PodTemplateInterface

+ type PodsNamespacer interface

+ Pods func(namespace string) PodInterface

+ type RESTClient struct

+ Client HTTPClient

+ Codec runtime.Codec

+ Throttle util.RateLimiter

+ Timeout time.Duration

+ func NewRESTClient(baseURL *url.URL, apiVersion string, c runtime.Codec, maxQPS float32, ...) *RESTClient

+ func RESTClientFor(config *Config) (*RESTClient, error)

+ func (c *RESTClient) APIVersion() string

+ func (c *RESTClient) Delete() *Request

+ func (c *RESTClient) Get() *Request

+ func (c *RESTClient) Patch(pt api.PatchType) *Request

+ func (c *RESTClient) Post() *Request

+ func (c *RESTClient) Put() *Request

+ func (c *RESTClient) Verb(verb string) *Request

+ type ReplicationControllerInterface interface

+ Create func(ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ReplicationController, error)

+ List func(selector labels.Selector) (*api.ReplicationControllerList, error)

+ Update func(ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ReplicationControllersNamespacer interface

+ ReplicationControllers func(namespace string) ReplicationControllerInterface

+ type Request struct

+ func NewRequest(client HTTPClient, verb string, baseURL *url.URL, apiVersion string, ...) *Request

+ func (r *Request) AbsPath(segments ...string) *Request

+ func (r *Request) Body(obj interface{}) *Request

+ func (r *Request) Do() Result

+ func (r *Request) DoRaw() ([]byte, error)

+ func (r *Request) FieldsSelectorParam(s fields.Selector) *Request

+ func (r *Request) LabelsSelectorParam(s labels.Selector) *Request

+ func (r *Request) Name(resourceName string) *Request

+ func (r *Request) Namespace(namespace string) *Request

+ func (r *Request) NamespaceIfScoped(namespace string, scoped bool) *Request

+ func (r *Request) Param(paramName, s string) *Request

+ func (r *Request) Prefix(segments ...string) *Request

+ func (r *Request) RequestURI(uri string) *Request

+ func (r *Request) Resource(resource string) *Request

+ func (r *Request) SetHeader(key, value string) *Request

+ func (r *Request) Stream() (io.ReadCloser, error)

+ func (r *Request) SubResource(subresources ...string) *Request

+ func (r *Request) Suffix(segments ...string) *Request

+ func (r *Request) Timeout(d time.Duration) *Request

+ func (r *Request) URL() *url.URL

+ func (r *Request) UintParam(paramName string, u uint64) *Request

+ func (r *Request) UnversionedPath(segments ...string) *Request

+ func (r *Request) Upgrade(config *Config, ...) (httpstream.Connection, error)

+ func (r *Request) Watch() (watch.Interface, error)

+ type RequestConstructionError struct

+ Err error

+ func (r *RequestConstructionError) Error() string

+ type RequestInfo struct

+ Duration time.Duration

+ RequestHeaders http.Header

+ RequestURL string

+ RequestVerb string

+ ResponseErr error

+ ResponseHeaders http.Header

+ ResponseStatus string

+ func NewRequestInfo(req *http.Request) *RequestInfo

+ func (r *RequestInfo) Complete(response *http.Response, err error)

+ func (r RequestInfo) ToCurl() string

+ type ResourceQuotaInterface interface

+ Create func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ResourceQuota, error)

+ List func(selector labels.Selector) (*api.ResourceQuotaList, error)

+ Update func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ UpdateStatus func(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ResourceQuotasNamespacer interface

+ ResourceQuotas func(namespace string) ResourceQuotaInterface

+ type Result struct

+ func (r Result) Error() error

+ func (r Result) Get() (runtime.Object, error)

+ func (r Result) Into(obj runtime.Object) error

+ func (r Result) Raw() ([]byte, error)

+ func (r Result) StatusCode(statusCode *int) Result

+ func (r Result) WasCreated(wasCreated *bool) Result

+ type SecretsInterface interface

+ Create func(secret *api.Secret) (*api.Secret, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Secret, error)

+ List func(label labels.Selector, field fields.Selector) (*api.SecretList, error)

+ Update func(secret *api.Secret) (*api.Secret, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type SecretsNamespacer interface

+ Secrets func(namespace string) SecretsInterface

+ type ServiceAccountsInterface interface

+ Create func(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

+ Delete func(name string) error

+ Get func(name string) (*api.ServiceAccount, error)

+ List func(label labels.Selector, field fields.Selector) (*api.ServiceAccountList, error)

+ Update func(serviceAccount *api.ServiceAccount) (*api.ServiceAccount, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ServiceAccountsNamespacer interface

+ ServiceAccounts func(namespace string) ServiceAccountsInterface

+ type ServiceInterface interface

+ Create func(srv *api.Service) (*api.Service, error)

+ Delete func(name string) error

+ Get func(name string) (*api.Service, error)

+ List func(selector labels.Selector) (*api.ServiceList, error)

+ Update func(srv *api.Service) (*api.Service, error)

+ Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

+ type ServicesNamespacer interface

+ Services func(namespace string) ServiceInterface

+ type TLSClientConfig struct

+ CAData []byte

+ CAFile string

+ CertData []byte

+ CertFile string

+ KeyData []byte

+ KeyFile string

+ type VersionInterface interface

+ ServerAPIVersions func() (*api.APIVersions, error)

+ ServerVersion func() (*version.Info, error)