client

Jun 26, 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 RequestHeaders

+ const ResponseHeaders

+ const ResponseStatus

+ const URLTiming

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

+ func (c *FakeRESTClient) Patch(_ api.PatchType) *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

Jun 19, 2015

Changes in this version

+ func NegotiateVersion(c *Config, version string) (string, error)

Jun 10, 2015

Changes in this version

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

type Client

+ func NewInCluster() (*Client, error)

type Config

+ func InClusterConfig() (*Config, error)

type HTTPKubeletClient

+ Config *KubeletConfig

type KubeletConfig

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

type Request

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

May 29, 2015

Changes in this version

type Client

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

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

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

May 12, 2015

Changes in this version

+ const SecretType

type Request

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

Apr 29, 2015

Changes in this version

+ const NodeUnschedulable

type Client

+ func (c *Client) ComponentStatuses() ComponentStatusInterface

+ 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

type EndpointsInterface

+ Delete func(name string) error

Apr 13, 2015

Changes in this version

+ const ObjectNameField

+ const PodHost

type Client

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

+ func (c *Client) PersistentVolumes() PersistentVolumeInterface

type Config

+ Burst int

+ QPS float32

type FlagSet

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

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

type NodeInterface

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

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

+ Throttle util.RateLimiter

type Request

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

Mar 30, 2015

Changes in this version

+ type ConnectionInfoGetter interface

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

type EventInterface

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

type FakeEvents

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

type FakeKubeletClient

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

type FakeNamespaces

+ func (c *FakeNamespaces) Finalize(namespace *api.Namespace) (*api.Namespace, error)

+ func (c *FakeNamespaces) Status(namespace *api.Namespace) (*api.Namespace, error)

type FakeNodes

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

type FakePods

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

type FakeResourceQuotas

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

type FlagSet

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

type HTTPKubeletClient

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

type KubeletConfig

+ HTTPTimeout time.Duration

type NamespaceInterface

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

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

type NodeInterface

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

type PodInterface

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

type Request

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

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

type ResourceQuotaInterface

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

Mar 17, 2015

Changes in this version

type EventInterface

+ Delete func(name string) error

type Fake

+ ResourceQuotaStatus api.ResourceQuota

type FakeEvents

+ func (c *FakeEvents) Delete(name string) error

type FakeResourceQuotas

+ func (c *FakeResourceQuotas) Status(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

type ResourceQuotaInterface

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

Mar 16, 2015

Changes in this version

+ func IsUnexpectedStatusError(err error) bool

type Fake

+ ResourceQuotaUsage api.ResourceQuotaUsage

type FakeKubeletClient

+ func (c FakeKubeletClient) GetNodeInfo(host string) (api.NodeInfo, error)

type FakeLimitRanges

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

type FakePods

+ func (c *FakePods) Bind(bind *api.Binding) error

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

type FakeResourceQuotas

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

type HTTPKubeletClient

+ func (c *HTTPKubeletClient) GetNodeInfo(host string) (api.NodeInfo, error)

type LimitRangeInterface

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

+ type NodeInfoGetter interface

+ GetNodeInfo func(host string) (api.NodeInfo, error)

type PodInterface

+ Bind func(binding *api.Binding) error

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

type RESTClient

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

type Request

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

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

type ResourceQuotaInterface

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

Mar 3, 2015

Changes in this version

+ func LoadTLSFiles(config *Config) error

type Client

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

type Fake

+ Secret api.Secret

+ SecretList api.SecretList

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

+ type FakeSecrets struct

+ Fake *Fake

+ Namespace string

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

+ func (c *FakeSecrets) Delete(secret string) error

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

+ func (c *FakeSecrets) List(labels, fields labels.Selector) (*api.SecretList, error)

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

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

type Request

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

+ 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, field labels.Selector) (*api.SecretList, error)

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

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

+ type SecretsNamespacer interface

+ Secrets func(namespace string) SecretsInterface

Feb 18, 2015

Changes in this version

+ func DefaultKubernetesUserAgent() string

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

type Client

+ func (c *Client) Namespaces() NamespaceInterface

type Config

+ UserAgent string

type EventInterface

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

type Fake

+ NamespacesList api.NamespaceList

+ func (c *Fake) Namespaces() NamespaceInterface

type FakeEvents

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

+ type FakeNamespaces struct

+ Fake *Fake

+ func (c *FakeNamespaces) Create(namespace *api.Namespace) (*api.Namespace, error)

+ func (c *FakeNamespaces) Delete(name string) error

+ func (c *FakeNamespaces) Get(name string) (*api.Namespace, error)

+ func (c *FakeNamespaces) List(selector labels.Selector) (*api.NamespaceList, error)

+ func (c *FakeNamespaces) Update(namespace *api.Namespace) (*api.Namespace, error)

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

+ type NamespaceInterface interface

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

+ Delete func(name string) error

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

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

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

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

+ type NamespacesInterface interface

+ Namespaces func() NamespaceInterface

type Request

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

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

Feb 3, 2015

Changes in this version

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

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

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

+ func NewUnsafeTLSConfig() *tls.Config

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

type Client

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

+ func (c *Client) ResourceQuotaUsages(namespace string) ResourceQuotaUsageInterface

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

type Fake

+ CtrlList api.ReplicationControllerList

+ LimitRangesList api.LimitRangeList

+ ResourceQuotasList api.ResourceQuotaList

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

+ func (c *Fake) ResourceQuotaUsages(namespace string) ResourceQuotaUsageInterface

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

+ type FakeLimitRanges struct

+ Fake *Fake

+ Namespace string

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

+ func (c *FakeLimitRanges) Delete(name string) error

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

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

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

type FakeNodes

+ func (c *FakeNodes) Update(minion *api.Node) (*api.Node, error)

+ type FakeResourceQuotaUsages struct

+ Fake *Fake

+ Namespace string

+ func (c *FakeResourceQuotaUsages) Create(resourceQuotaUsage *api.ResourceQuotaUsage) error

+ type FakeResourceQuotas struct

+ Fake *Fake

+ Namespace string

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

+ func (c *FakeResourceQuotas) Delete(name string) error

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

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

+ func (c *FakeResourceQuotas) Update(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, 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)

+ type LimitRangesNamespacer interface

+ LimitRanges func(namespace string) LimitRangeInterface

type NodeInterface

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

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

+ type ResourceQuotaUsageInterface interface

+ Create func(resourceQuotaUsage *api.ResourceQuotaUsage) error

+ type ResourceQuotaUsagesNamespacer interface

+ ResourceQuotaUsages func(namespace string) ResourceQuotaUsageInterface

+ type ResourceQuotasNamespacer interface

+ ResourceQuotas func(namespace string) ResourceQuotaInterface

+ type TLSClientConfig struct

+ CAData []byte

+ CAFile string

+ CertData []byte

+ CertFile string

+ KeyData []byte

+ KeyFile string

Jan 21, 2015

Changes in this version

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

+ func MatchesServerVersion(c *Config) error

+ func NewTLSTransport(caData []byte) (*http.Transport, error)

+ func SetKubernetesDefaults(config *Config) error

type Config

+ CAData []byte

+ CertData []byte

+ Codec runtime.Codec

+ KeyData []byte

+ LegacyBehavior bool

type FakeKubeletClient

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

type FakeRESTClient

+ Legacy bool

type HTTPKubeletClient

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

type KubeletConfig

+ CAData []byte

+ CertData []byte

+ KeyData []byte

type PodInfoGetter

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

type RESTClient

+ LegacyBehavior bool

+ func (c *RESTClient) APIVersion() string

Jan 7, 2015

Changes in this version

+ func IsTimeout(err error) bool

+ func NamespaceInPathFor(version string) bool

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

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

type Request

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

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

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

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

Dec 16, 2014

Changes in this version

type Client

+ func (c *Client) Nodes() NodeInterface

type Fake

+ func (c *Fake) Nodes() NodeInterface

+ type FakeNodes struct

+ Fake *Fake

+ func (c *FakeNodes) Create(minion *api.Node) (*api.Node, error)

+ func (c *FakeNodes) Delete(id string) error

+ func (c *FakeNodes) Get(name string) (*api.Node, error)

+ func (c *FakeNodes) List() (*api.NodeList, error)

+ type NodeInterface interface

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

+ Delete func(name string) error

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

+ List func() (*api.NodeList, error)

+ type NodesInterface interface

+ Nodes func() NodeInterface

Dec 2, 2014

Changes in this version

+ 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) Post() *Request

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

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

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

+ type RequestConstructionError struct

+ Err error

+ func (r *RequestConstructionError) Error() string

+ type UnexpectedStatusError struct

+ Body string

+ Request *http.Request

+ Response *http.Response

+ func (u *UnexpectedStatusError) Error() string

Nov 18, 2014

Changes in this version

+ func BindKubeletClientConfigFlags(flags FlagSet, config *KubeletConfig)

+ func IsConfigTransportTLS(config *Config) bool

type Client

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

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

+ func (c *Client) Minions() MinionInterface

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

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

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

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

type EndpointsInterface

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

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

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

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

+ Watch func(label, field labels.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)

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

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

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

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

+ type EventNamespacer interface

+ Events func(namespace string) EventInterface

type Fake

+ EventsList api.EventList

+ MinionsList api.MinionList

+ PodsList api.PodList

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

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

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

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

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

+ type FakeEndpoints struct

+ Fake *Fake

+ Namespace string

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

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

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

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

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

+ type FakeEvents struct

+ Fake *Fake

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

+ func (c *FakeEvents) Get(id string) (*api.Event, error)

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

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

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

+ type FakeKubeletClient struct

+ func (c FakeKubeletClient) GetPodInfo(host, podNamespace string, podID string) (api.PodInfo, error)

+ func (c FakeKubeletClient) HealthCheck(host string) (health.Status, error)

+ type FakeMinions struct

+ Fake *Fake

+ func (c *FakeMinions) Create(minion *api.Minion) (*api.Minion, error)

+ func (c *FakeMinions) Delete(id string) error

+ func (c *FakeMinions) Get(name string) (*api.Minion, error)

+ func (c *FakeMinions) List() (*api.MinionList, error)

+ type FakePods struct

+ Fake *Fake

+ Namespace string

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

+ func (c *FakePods) Delete(name string) error

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

+ func (c *FakePods) List(selector labels.Selector) (*api.PodList, error)

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

+ type FakeReplicationControllers struct

+ Fake *Fake

+ Namespace string

+ func (c *FakeReplicationControllers) Create(controller *api.ReplicationController) (*api.ReplicationController, error)

+ func (c *FakeReplicationControllers) Delete(controller string) error

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

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

+ func (c *FakeReplicationControllers) Update(controller *api.ReplicationController) (*api.ReplicationController, error)

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

+ type FakeServices struct

+ Fake *Fake

+ Namespace string

+ func (c *FakeServices) Create(service *api.Service) (*api.Service, error)

+ func (c *FakeServices) Delete(service string) error

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

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

+ func (c *FakeServices) Update(service *api.Service) (*api.Service, error)

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

type FlagSet

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

+ type HTTPClient interface

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

+ type HTTPKubeletClient struct

+ Client *http.Client

+ EnableHttps bool

+ Port uint

+ func (c *HTTPKubeletClient) GetPodInfo(host, podNamespace, podID string) (api.PodInfo, error)

+ func (c *HTTPKubeletClient) HealthCheck(host string) (health.Status, error)

+ type KubeletClient interface

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

+ type KubeletConfig struct

+ CAFile string

+ CertFile string

+ EnableHttps bool

+ KeyFile string

+ Port uint

+ type KubeletHealthChecker interface

+ HealthCheck func(host string) (health.Status, error)

type MinionInterface

+ Create func(minion *api.Minion) (*api.Minion, error)

+ Delete func(id string) error

+ Get func(id string) (result *api.Minion, err error)

+ List func() (*api.MinionList, error)

+ type MinionsInterface interface

+ Minions func() MinionInterface

type PodInterface

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

+ type PodsNamespacer interface

+ Pods func(namespace string) PodInterface

+ type PollFunc func(name string) (*Request, bool)

type RESTClient

+ Poller PollFunc

+ func (c *RESTClient) DefaultPoll(name string) (*Request, bool)

+ func (c *RESTClient) Operation(name string) *Request

type ReplicationControllerInterface

+ 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, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type ReplicationControllersNamespacer interface

+ ReplicationControllers func(namespace string) ReplicationControllerInterface

type Request

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

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

+ func (r *Request) NoPoll() *Request

+ func (r *Request) Poller(poller PollFunc) *Request

type Result

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

type ServiceInterface

+ 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, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type ServicesNamespacer interface

+ Services func(namespace string) ServiceInterface

type VersionInterface

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

Oct 17, 2014

Changes in this version

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

+ func BindClientConfigFlags(flags FlagSet, config *Config)

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

+ func IsConfigTransportSecure(config *Config) bool

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

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

+ func NewClientCertTLSTransport(certFile, keyFile, caFile string) (*http.Transport, error)

+ func NewUnsafeTLSTransport() *http.Transport

+ 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) ControllerHasDesiredReplicas(controller api.ReplicationController) wait.ConditionFunc

+ func (c *Client) CreateEndpoints(ctx api.Context, endpoints *api.Endpoints) (*api.Endpoints, error)

+ func (c *Client) CreatePod(ctx api.Context, pod *api.Pod) (result *api.Pod, err error)

+ func (c *Client) CreateReplicationController(ctx api.Context, controller *api.ReplicationController) (result *api.ReplicationController, err error)

+ func (c *Client) CreateService(ctx api.Context, svc *api.Service) (result *api.Service, err error)

+ func (c *Client) DeletePod(ctx api.Context, id string) error

+ func (c *Client) DeleteReplicationController(ctx api.Context, id string) error

+ func (c *Client) DeleteService(ctx api.Context, id string) error

+ func (c *Client) GetEndpoints(ctx api.Context, id string) (result *api.Endpoints, err error)

+ func (c *Client) GetMinion(id string) (result *api.Minion, err error)

+ func (c *Client) GetPod(ctx api.Context, id string) (result *api.Pod, err error)

+ func (c *Client) GetReplicationController(ctx api.Context, id string) (result *api.ReplicationController, err error)

+ func (c *Client) GetService(ctx api.Context, id string) (result *api.Service, err error)

+ func (c *Client) ListEndpoints(ctx api.Context, selector labels.Selector) (result *api.EndpointsList, err error)

+ func (c *Client) ListMinions() (result *api.MinionList, err error)

+ func (c *Client) ListPods(ctx api.Context, selector labels.Selector) (result *api.PodList, err error)

+ func (c *Client) ListReplicationControllers(ctx api.Context, selector labels.Selector) (result *api.ReplicationControllerList, err error)

+ func (c *Client) ListServices(ctx api.Context, selector labels.Selector) (result *api.ServiceList, err error)

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

+ func (c *Client) UpdateEndpoints(ctx api.Context, endpoints *api.Endpoints) (*api.Endpoints, error)

+ func (c *Client) UpdatePod(ctx api.Context, pod *api.Pod) (result *api.Pod, err error)

+ func (c *Client) UpdateReplicationController(ctx api.Context, controller *api.ReplicationController) (result *api.ReplicationController, err error)

+ func (c *Client) UpdateService(ctx api.Context, svc *api.Service) (result *api.Service, err error)

+ func (c *Client) WatchEndpoints(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ func (c *Client) WatchReplicationControllers(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ func (c *Client) WatchServices(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type Config struct

+ BearerToken string

+ CAFile string

+ CertFile string

+ Host string

+ Insecure bool

+ KeyFile string

+ Password string

+ Prefix string

+ Transport http.RoundTripper

+ Username string

+ Version string

+ type ContainerInfoGetter interface

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

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

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

+ type EndpointsInterface interface

+ GetEndpoints func(ctx api.Context, id string) (*api.Endpoints, error)

+ ListEndpoints func(ctx api.Context, selector labels.Selector) (*api.EndpointsList, error)

+ WatchEndpoints func(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type Fake struct

+ Actions []FakeAction

+ Ctrl api.ReplicationController

+ EndpointsList api.EndpointsList

+ Err error

+ Minions api.MinionList

+ Pods api.PodList

+ ServiceList api.ServiceList

+ Watch watch.Interface

+ func (c *Fake) CreatePod(ctx api.Context, pod *api.Pod) (*api.Pod, error)

+ func (c *Fake) CreateReplicationController(ctx api.Context, controller *api.ReplicationController) (*api.ReplicationController, error)

+ func (c *Fake) CreateService(ctx api.Context, service *api.Service) (*api.Service, error)

+ func (c *Fake) DeletePod(ctx api.Context, name string) error

+ func (c *Fake) DeleteReplicationController(ctx api.Context, controller string) error

+ func (c *Fake) DeleteService(ctx api.Context, service string) error

+ func (c *Fake) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error)

+ func (c *Fake) GetPod(ctx api.Context, name string) (*api.Pod, error)

+ func (c *Fake) GetReplicationController(ctx api.Context, name string) (*api.ReplicationController, error)

+ func (c *Fake) GetService(ctx api.Context, name string) (*api.Service, error)

+ func (c *Fake) ListEndpoints(ctx api.Context, selector labels.Selector) (*api.EndpointsList, error)

+ func (c *Fake) ListMinions() (*api.MinionList, error)

+ func (c *Fake) ListPods(ctx api.Context, selector labels.Selector) (*api.PodList, error)

+ func (c *Fake) ListReplicationControllers(ctx api.Context, selector labels.Selector) (*api.ReplicationControllerList, error)

+ func (c *Fake) ListServices(ctx api.Context, selector labels.Selector) (*api.ServiceList, error)

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

+ func (c *Fake) UpdatePod(ctx api.Context, pod *api.Pod) (*api.Pod, error)

+ func (c *Fake) UpdateReplicationController(ctx api.Context, controller *api.ReplicationController) (*api.ReplicationController, error)

+ func (c *Fake) UpdateService(ctx api.Context, service *api.Service) (*api.Service, error)

+ func (c *Fake) WatchEndpoints(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ func (c *Fake) WatchReplicationControllers(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ func (c *Fake) WatchServices(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type FakeAction struct

+ Action string

+ Value interface{}

+ type FakePodInfoGetter struct

+ func (c *FakePodInfoGetter) GetPodInfo(host, podNamespace string, podID string) (api.PodInfo, error)

+ type FlagSet interface

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

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

+ type HTTPContainerInfoGetter struct

+ Client *http.Client

+ Port int

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

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

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

+ type HTTPPodInfoGetter struct

+ Client *http.Client

+ Port uint

+ func (c *HTTPPodInfoGetter) GetPodInfo(host, podNamespace, podID string) (api.PodInfo, error)

+ type Interface interface

+ type MinionInterface interface

+ ListMinions func() (*api.MinionList, error)

+ type PodInfoGetter interface

+ GetPodInfo func(host, podNamespace, podID string) (api.PodInfo, error)

+ type PodInterface interface

+ CreatePod func(ctx api.Context, pod *api.Pod) (*api.Pod, error)

+ DeletePod func(ctx api.Context, id string) error

+ GetPod func(ctx api.Context, id string) (*api.Pod, error)

+ ListPods func(ctx api.Context, selector labels.Selector) (*api.PodList, error)

+ UpdatePod func(ctx api.Context, pod *api.Pod) (*api.Pod, error)

+ type RESTClient struct

+ Client *http.Client

+ Codec runtime.Codec

+ PollPeriod time.Duration

+ Sync bool

+ Timeout time.Duration

+ func NewRESTClient(baseURL *url.URL, c runtime.Codec) *RESTClient

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

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

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

+ func (c *RESTClient) PollFor(operationID string) *Request

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

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

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

+ type ReplicationControllerInterface interface

+ CreateReplicationController func(ctx api.Context, ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ DeleteReplicationController func(ctx api.Context, id string) error

+ GetReplicationController func(ctx api.Context, id string) (*api.ReplicationController, error)

+ ListReplicationControllers func(ctx api.Context, selector labels.Selector) (*api.ReplicationControllerList, error)

+ UpdateReplicationController func(ctx api.Context, ctrl *api.ReplicationController) (*api.ReplicationController, error)

+ WatchReplicationControllers func(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type Request struct

+ func (r *Request) AbsPath(path string) *Request

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

+ func (r *Request) Do() Result

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

+ func (r *Request) ParseSelectorParam(paramName, item string) *Request

+ func (r *Request) Path(item string) *Request

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

+ func (r *Request) SelectorParam(paramName string, s labels.Selector) *Request

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

+ func (r *Request) Sync(sync bool) *Request

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

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

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

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

+ type ServiceInterface interface

+ CreateService func(ctx api.Context, srv *api.Service) (*api.Service, error)

+ DeleteService func(ctx api.Context, id string) error

+ GetService func(ctx api.Context, id string) (*api.Service, error)

+ ListServices func(ctx api.Context, selector labels.Selector) (*api.ServiceList, error)

+ UpdateService func(ctx api.Context, srv *api.Service) (*api.Service, error)

+ WatchServices func(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ type VersionInterface interface

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