client

package

Go to main page

Versions in this module

v0

v0.7.0

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

v0.6.2

Dec 12, 2014

v0.6.1

Dec 9, 2014

v0.6.0

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

v0.5.6

Dec 12, 2014

v0.5.4

Nov 25, 2014

v0.5.3

Nov 24, 2014

v0.5.2

Nov 19, 2014

v0.5.1

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)

v0.4.4

Nov 19, 2014

v0.4.3

Oct 30, 2014

v0.4.2

Oct 29, 2014

v0.4.1

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)

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