Versions in this module Expand all Collapse all v0 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)