client/

Versions in this module

v1

v1.14.0-rc.1

Mar 19, 2019

v1.13.9

Aug 1, 2019

v1.13.3

Feb 1, 2019

v1.13.2-beta.0

Dec 13, 2018

v1.13.0-alpha.0

Aug 14, 2018

v1.12.9-beta.0

Apr 23, 2019

v1.11.9-beta.0

Feb 28, 2019

v1.11.8

Feb 23, 2019

v1.11.6

Dec 14, 2018

v1.11.0-alpha.1

Apr 19, 2018

v1.10.11-beta.0

Nov 13, 2018

v1.10.8

Sep 13, 2018

v1.9.7-beta.0

Mar 21, 2018

v1.9.0

Dec 14, 2017

v1.8.12

Apr 23, 2018

v1.8.8

Feb 4, 2018

v1.7.0

Jun 29, 2017

v1.6.13-beta.0

Oct 25, 2017

v1.6.12-beta.0

Sep 28, 2017

v1.6.9-beta.0

Aug 3, 2017

v1.6.8-beta.0

Jul 5, 2017

v1.6.3-beta.0

Apr 19, 2017

v1.4.5

Oct 29, 2016

v1.4.0-alpha.1

Jul 11, 2016

v1.3.6-beta.0

Aug 11, 2016

v1.3.0

Jul 1, 2016

v1.3.0-alpha.3

Apr 26, 2016

v1.2.0-beta.0

Mar 4, 2016

v1.2.0-alpha.3

Nov 3, 2015

v1.1.7-beta.0

Jan 27, 2016

v1.1.4-beta.0

Dec 7, 2015

v1.1.0-beta

Sep 25, 2015

v1.0.8-beta

Oct 27, 2015

v1.0.2

Aug 1, 2015

v0

v0.21.2

Jul 11, 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 RequestHeaders

+ const ResponseHeaders

+ const ResponseStatus

+ const SecretType

+ const URLTiming

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

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

type Client

+ func NewInCluster() (*Client, error)

+ func (c *Client) ComponentStatuses() ComponentStatusInterface

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

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

+ 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

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

+ func InClusterConfig() (*Config, 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

+ Delete func(name string) error

type FakeRESTClient

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

type HTTPKubeletClient

+ Config *KubeletConfig

type KubeletConfig

+ Dial func(net, addr string) (net.Conn, 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 Request

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

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

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

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

+ 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

v0.15.0

Apr 13, 2015

Changes in this version

+ const ObjectNameField

+ const PodHost

+ var ErrPodInfoNotAvailable = errors.New("no pod info available")

+ 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 MatchesServerVersion(c *Config) 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 NewOrDie(c *Config) *Client

+ 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) 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) Services(namespace string) ServiceInterface

+ type Config struct

+ BearerToken string

+ Burst int

+ Codec runtime.Codec

+ Host string

+ Insecure bool

+ LegacyBehavior bool

+ Password string

+ Prefix string

+ QPS float32

+ Transport http.RoundTripper

+ UserAgent string

+ Username string

+ Version string

+ type ConnectionInfoGetter interface

+ GetConnectionInfo func(host string) (scheme string, port uint, transport http.RoundTripper, error 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 EndpointsInterface interface

+ Create func(endpoints *api.Endpoints) (*api.Endpoints, 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) GetPodStatus(host, podNamespace string, podID string) (api.PodStatusResult, error)

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

+ type FakeRESTClient struct

+ Client HTTPClient

+ Codec runtime.Codec

+ Err error

+ Legacy bool

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

+ EnableHttps bool

+ Port uint

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

+ func (c *HTTPKubeletClient) GetPodStatus(host, podNamespace, podID string) (api.PodStatusResult, error)

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

+ type Interface interface

+ type KubeletClient interface

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

+ type KubeletConfig struct

+ EnableHttps bool

+ HTTPTimeout time.Duration

+ Port uint

+ type KubeletHealthChecker interface

+ HealthCheck func(host string) (probe.Result, 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 PodInfoGetter interface

+ GetPodStatus func(host, podNamespace, podID string) (api.PodStatusResult, error)

+ type PodInterface interface

+ Bind func(binding *api.Binding) error

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

+ Delete func(name string) error

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

+ List func(selector labels.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 PodsNamespacer interface

+ Pods func(namespace string) PodInterface

+ type RESTClient struct

+ Client HTTPClient

+ Codec runtime.Codec

+ LegacyBehavior bool

+ Throttle util.RateLimiter

+ Timeout time.Duration

+ func NewRESTClient(baseURL *url.URL, apiVersion string, c runtime.Codec, legacyBehavior bool, ...) *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) UintParam(paramName string, u uint64) *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 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) 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 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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL