client

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 5, 2015

Changes in this version

+ func IsUnexpectedStatusError(err error) bool

+ func LoadTLSFiles(config *Config) error

type Client

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

+ type ConnectionInfoGetter interface

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

type EventInterface

+ Delete func(name string) error

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

type Fake

+ ResourceQuotaStatus api.ResourceQuota

+ Secret api.Secret

+ SecretList api.SecretList

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

type FakeEvents

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

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

type FakeKubeletClient

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

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

type FakeLimitRanges

+ func (c *FakeLimitRanges) Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, 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) Bind(bind *api.Binding) error

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

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

type FakeResourceQuotas

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

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

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

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

+ func (c *FakeSecrets) Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, 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)

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

type KubeletConfig

+ HTTPTimeout time.Duration

type LimitRangeInterface

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

type NamespaceInterface

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

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

+ type NodeInfoGetter interface

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

type NodeInterface

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

type PodInterface

+ Bind func(binding *api.Binding) error

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

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

type RESTClient

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

type Request

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

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

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

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

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

type ResourceQuotaInterface

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

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

v0.4.2

Apr 1, 2015

v0.4.1

Mar 18, 2015

v0.4.0

Mar 12, 2015

Changes in this version

+ 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 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) Pods(namespace string) PodInterface

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

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

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

+ 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

+ Codec runtime.Codec

+ Host string

+ Insecure bool

+ LegacyBehavior bool

+ Password string

+ Prefix string

+ Transport http.RoundTripper

+ UserAgent string

+ 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

+ 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, 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(name string) (*api.Event, error)

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

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

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

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

+ type EventNamespacer interface

+ Events func(namespace string) EventInterface

+ type Fake struct

+ Actions []FakeAction

+ Ctrl api.ReplicationController

+ CtrlList api.ReplicationControllerList

+ EndpointsList api.EndpointsList

+ Err error

+ EventsList api.EventList

+ LimitRangesList api.LimitRangeList

+ MinionsList api.NodeList

+ NamespacesList api.NamespaceList

+ PodsList api.PodList

+ ResourceQuotasList api.ResourceQuotaList

+ ServiceList api.ServiceList

+ Watch watch.Interface

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

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

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

+ func (c *Fake) Namespaces() NamespaceInterface

+ func (c *Fake) Nodes() NodeInterface

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

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

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

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

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

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

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

+ type FakeAction struct

+ Action string

+ Value interface{}

+ 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) Update(event *api.Event) (*api.Event, error)

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

+ type FakeKubeletClient struct

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

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

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

+ func (c *FakeNodes) Update(minion *api.Node) (*api.Node, 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 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 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 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 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 interface

+ BoolVar func(p *bool, name string, value bool, 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 *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 HTTPKubeletClient struct

+ Client *http.Client

+ EnableHttps bool

+ Port uint

+ 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

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

+ type LimitRangesNamespacer interface

+ LimitRanges func(namespace string) LimitRangeInterface

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

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

+ type NodesInterface interface

+ Nodes func() NodeInterface

+ type PodInfoGetter interface

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

+ type PodInterface interface

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

+ Client HTTPClient

+ Codec runtime.Codec

+ LegacyBehavior bool

+ 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) 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, field labels.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, codec runtime.Codec, ...) *Request

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

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

+ func (r *Request) Do() Result

+ 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) ParseSelectorParam(paramName, item 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) SelectorParam(paramName string, s labels.Selector) *Request

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

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

+ 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 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 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, field labels.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 UnexpectedStatusError struct

+ Body string

+ Request *http.Request

+ Response *http.Response

+ func (u *UnexpectedStatusError) Error() 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