Versions in this module Expand all Collapse all v1 v1.0.4 Jul 29, 2015 Changes in this version + func MakeMinionList(minions []string, nodeResources api.NodeResources) *api.NodeList + type ControllerRegistry struct + Controllers *api.ReplicationControllerList + Err error + func (r *ControllerRegistry) CreateController(ctx api.Context, controller *api.ReplicationController) (*api.ReplicationController, error) + func (r *ControllerRegistry) DeleteController(ctx api.Context, ID string) error + func (r *ControllerRegistry) GetController(ctx api.Context, ID string) (*api.ReplicationController, error) + func (r *ControllerRegistry) ListControllers(ctx api.Context) (*api.ReplicationControllerList, error) + func (r *ControllerRegistry) SetError(err error) + func (r *ControllerRegistry) UpdateController(ctx api.Context, controller *api.ReplicationController) (*api.ReplicationController, error) + func (r *ControllerRegistry) WatchControllers(ctx api.Context, label labels.Selector, field fields.Selector, ...) (watch.Interface, error) + type EndpointRegistry struct + Endpoints *api.EndpointsList + Err error + Updates []api.Endpoints + func (e *EndpointRegistry) DeleteEndpoints(ctx api.Context, name string) error + func (e *EndpointRegistry) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error) + func (e *EndpointRegistry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error) + func (e *EndpointRegistry) UpdateEndpoints(ctx api.Context, endpoints *api.Endpoints) error + func (e *EndpointRegistry) WatchEndpoints(ctx api.Context, labels labels.Selector, fields fields.Selector, ...) (watch.Interface, error) + type GenericRegistry struct + Broadcaster *watch.Broadcaster + Err error + Object runtime.Object + ObjectList runtime.Object + func NewGeneric(list runtime.Object) *GenericRegistry + func (r *GenericRegistry) CreateWithName(ctx api.Context, id string, obj runtime.Object) error + func (r *GenericRegistry) Delete(ctx api.Context, id string, options *api.DeleteOptions) (runtime.Object, error) + func (r *GenericRegistry) Get(ctx api.Context, id string) (runtime.Object, error) + func (r *GenericRegistry) ListPredicate(ctx api.Context, m generic.Matcher) (runtime.Object, error) + func (r *GenericRegistry) UpdateWithName(ctx api.Context, id string, obj runtime.Object) error + func (r *GenericRegistry) WatchPredicate(ctx api.Context, m generic.Matcher, resourceVersion string) (watch.Interface, error) + type MinionRegistry struct + Err error + Minion string + Minions api.NodeList + func NewMinionRegistry(minions []string, nodeResources api.NodeResources) *MinionRegistry + func (r *MinionRegistry) CreateMinion(ctx api.Context, minion *api.Node) error + func (r *MinionRegistry) DeleteMinion(ctx api.Context, minionID string) error + func (r *MinionRegistry) GetMinion(ctx api.Context, minionID string) (*api.Node, error) + func (r *MinionRegistry) ListMinions(ctx api.Context, label labels.Selector, field fields.Selector) (*api.NodeList, error) + func (r *MinionRegistry) SetError(err error) + func (r *MinionRegistry) UpdateMinion(ctx api.Context, minion *api.Node) error + func (r *MinionRegistry) WatchMinions(ctx api.Context, label labels.Selector, field fields.Selector, ...) (watch.Interface, error) + type PodRegistry struct + Err error + Pod *api.Pod + Pods *api.PodList + func NewPodRegistry(pods *api.PodList) *PodRegistry + func (r *PodRegistry) CreatePod(ctx api.Context, pod *api.Pod) error + func (r *PodRegistry) DeletePod(ctx api.Context, podId string) error + func (r *PodRegistry) GetPod(ctx api.Context, podId string) (*api.Pod, error) + func (r *PodRegistry) ListPods(ctx api.Context, selector labels.Selector) (*api.PodList, error) + func (r *PodRegistry) ListPodsPredicate(ctx api.Context, filter func(*api.Pod) bool) (*api.PodList, error) + func (r *PodRegistry) SetError(err error) + func (r *PodRegistry) UpdatePod(ctx api.Context, pod *api.Pod) error + func (r *PodRegistry) WatchPods(ctx api.Context, label labels.Selector, field fields.Selector, ...) (watch.Interface, error) + type Scheduler struct + Err error + Machine string + Pod *api.Pod + func (s *Scheduler) Schedule(pod *api.Pod, lister algorithm.MinionLister) (string, error) + type ServiceRegistry struct + DeletedID string + Err error + GottenID string + List api.ServiceList + Service *api.Service + UpdatedID string + func NewServiceRegistry() *ServiceRegistry + func (r *ServiceRegistry) CreateService(ctx api.Context, svc *api.Service) (*api.Service, error) + func (r *ServiceRegistry) DeleteService(ctx api.Context, id string) error + func (r *ServiceRegistry) GetService(ctx api.Context, id string) (*api.Service, error) + func (r *ServiceRegistry) ListServices(ctx api.Context) (*api.ServiceList, error) + func (r *ServiceRegistry) SetError(err error) + func (r *ServiceRegistry) UpdateService(ctx api.Context, svc *api.Service) (*api.Service, error) + func (r *ServiceRegistry) WatchServices(ctx api.Context, label labels.Selector, field fields.Selector, ...) (watch.Interface, error)