client

package

Go to main page

Versions in this module

v0

v0.17.0

Jul 29, 2015

v0.16.1

Aug 5, 2015

v0.16.0

Jul 7, 2015

v0.15.0

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

+ func NegotiateVersion(c *Config, version string) (string, 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 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

v0.14.3

Jun 19, 2015

v0.14.2

Jun 17, 2015

Changes in this version

+ const NodeUnschedulable

+ const SecretType

+ func MakeTransport(config *KubeletConfig) (http.RoundTripper, 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 EndpointsInterface

+ Delete func(name string) error

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 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.14.0

Jun 10, 2015

v0.13.0

May 29, 2015

Changes in this version

+ func NewKubeletHttpClient(config *KubeletConfig) (*http.Client, error)

v0.12.1

May 14, 2015

v0.12.0

May 12, 2015

v0.11.0

Apr 29, 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 ConnectionInfoGetter interface

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

type FakeKubeletClient

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

type FlagSet

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

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

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

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

type ResourceQuotaInterface

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

v0.10.0

Apr 1, 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 IsUnexpectedStatusError(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) 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

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

+ ResourceQuotaStatus api.ResourceQuota

+ ResourceQuotasList api.ResourceQuotaList

+ Secret api.Secret

+ SecretList api.SecretList

+ 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) ResourceQuotas(namespace string) ResourceQuotaInterface

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

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

+ type FakeEvents struct

+ Fake *Fake

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

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

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

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

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

+ type FakeKubeletClient struct

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

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

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

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

+ func (c *FakePods) UpdateStatus(name string, status *api.PodStatus) (*api.Pod, error)

+ func (c *FakePods) Watch(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, 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 labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, 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) Status(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error)

+ func (c *FakeResourceQuotas) Update(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 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 labels.Selector, field fields.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 *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) GetNodeInfo(host string) (api.NodeInfo, 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

+ 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

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

+ type NamespacesInterface interface

+ Namespaces func() NamespaceInterface

+ type NodeInfoGetter interface

+ GetNodeInfo func(host string) (api.NodeInfo, 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)

+ 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

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

+ 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() *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(paramName string, s fields.Selector) *Request

+ func (r *Request) LabelsSelectorParam(paramName string, 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) 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) 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)

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

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