client

package

Go to main page

Versions in this module

v0

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