Versions in this module Expand all Collapse all v0 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)