registrytest

Jul 1, 2016

Changes in this version

type Tester

+ func (t *Tester) Namer(namer func(int) string) *Tester

Mar 16, 2016

Changes in this version

type ServiceRegistry

+ Updates []api.Service

+ func (r *ServiceRegistry) ExportService(ctx api.Context, name string, options unversioned.ExportOptions) (*api.Service, error)

Sep 25, 2015

Changes in this version

+ func MakeNodeList(nodes []string, nodeResources api.NodeResources) *api.NodeList

+ func NewEtcdStorage(t *testing.T, group string) (storage.Interface, *tools.FakeEtcdClient)

+ type NodeRegistry struct

+ Err error

+ Node string

+ Nodes api.NodeList

+ func NewNodeRegistry(nodes []string, nodeResources api.NodeResources) *NodeRegistry

+ func (r *NodeRegistry) CreateNode(ctx api.Context, node *api.Node) error

+ func (r *NodeRegistry) DeleteNode(ctx api.Context, nodeID string) error

+ func (r *NodeRegistry) GetNode(ctx api.Context, nodeID string) (*api.Node, error)

+ func (r *NodeRegistry) ListNodes(ctx api.Context, label labels.Selector, field fields.Selector) (*api.NodeList, error)

+ func (r *NodeRegistry) SetError(err error)

+ func (r *NodeRegistry) UpdateNode(ctx api.Context, node *api.Node) error

+ func (r *NodeRegistry) WatchNodes(ctx api.Context, label labels.Selector, field fields.Selector, ...) (watch.Interface, error)

+ type Tester struct

+ func New(t *testing.T, fakeClient *tools.FakeEtcdClient, storage *etcdgeneric.Etcd) *Tester

+ func (t *Tester) AllowCreateOnUpdate() *Tester

+ func (t *Tester) ClusterScope() *Tester

+ func (t *Tester) GeneratesName() *Tester

+ func (t *Tester) ReturnDeletedObject() *Tester

+ func (t *Tester) TestCreate(valid runtime.Object, invalid ...runtime.Object)

+ func (t *Tester) TestDelete(valid runtime.Object)

+ func (t *Tester) TestDeleteGraceful(valid runtime.Object, expectedGrace int64)

+ func (t *Tester) TestGet(valid runtime.Object)

+ func (t *Tester) TestList(valid runtime.Object)

+ func (t *Tester) TestNamespace() string

+ func (t *Tester) TestUpdate(valid runtime.Object, validUpdateFunc UpdateFunc, ...)

+ func (t *Tester) TestWatch(valid runtime.Object, labelsPass, labelsFail []labels.Set, ...)

+ type UpdateFunc func(runtime.Object) runtime.Object

Mar 30, 2015

Changes in this version

type EndpointRegistry

+ func (e *EndpointRegistry) DeleteEndpoints(ctx api.Context, name string) error

Mar 16, 2015

Changes in this version

+ type EndpointRegistry struct

+ Endpoints *api.EndpointsList

+ Err error

+ Updates []api.Endpoints

+ 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

+ func (r *GenericRegistry) ListPredicate(ctx api.Context, m generic.Matcher) (runtime.Object, error)

+ func (r *GenericRegistry) WatchPredicate(ctx api.Context, m generic.Matcher, resourceVersion string) (watch.Interface, error)

Feb 18, 2015

Changes in this version

type GenericRegistry

+ func (r *GenericRegistry) CreateWithName(ctx api.Context, id string, obj runtime.Object) error

+ func (r *GenericRegistry) UpdateWithName(ctx api.Context, id string, obj runtime.Object) error

Feb 3, 2015

Changes in this version

type ControllerRegistry

+ func (r *ControllerRegistry) SetError(err error)

type MinionRegistry

+ func (r *MinionRegistry) SetError(err error)

type PodRegistry

+ func (r *PodRegistry) SetError(err error)

type ServiceRegistry

+ func (r *ServiceRegistry) SetError(err error)

Jan 7, 2015

Changes in this version

type MinionRegistry

+ func (r *MinionRegistry) WatchMinions(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

Dec 16, 2014

Changes in this version

type GenericRegistry

+ Broadcaster *watch.Broadcaster

Nov 18, 2014

Changes in this version

type MinionRegistry

+ func (r *MinionRegistry) UpdateMinion(ctx api.Context, minion *api.Minion) error

Oct 17, 2014

Changes in this version

+ func MakeMinionList(minions []string, nodeResources api.NodeResources) *api.MinionList

+ type ControllerRegistry struct

+ Controllers *api.ReplicationControllerList

+ Err error

+ func (r *ControllerRegistry) CreateController(ctx api.Context, controller *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) UpdateController(ctx api.Context, controller *api.ReplicationController) error

+ func (r *ControllerRegistry) WatchControllers(ctx api.Context, resourceVersion string) (watch.Interface, error)

+ type GenericRegistry struct

+ Err error

+ Mux *watch.Mux

+ Object runtime.Object

+ ObjectList runtime.Object

+ func NewGeneric(list runtime.Object) *GenericRegistry

+ func (r *GenericRegistry) Create(ctx api.Context, id string, obj runtime.Object) error

+ func (r *GenericRegistry) Delete(ctx api.Context, id string) error

+ func (r *GenericRegistry) Get(ctx api.Context, id string) (runtime.Object, error)

+ func (r *GenericRegistry) List(ctx api.Context, m generic.Matcher) (runtime.Object, error)

+ func (r *GenericRegistry) Update(ctx api.Context, id string, obj runtime.Object) error

+ func (r *GenericRegistry) Watch(ctx api.Context, m generic.Matcher, resourceVersion uint64) (watch.Interface, error)

+ type MinionRegistry struct

+ Err error

+ Minion string

+ Minions api.MinionList

+ func NewMinionRegistry(minions []string, nodeResources api.NodeResources) *MinionRegistry

+ func (r *MinionRegistry) CreateMinion(ctx api.Context, minion *api.Minion) error

+ func (r *MinionRegistry) DeleteMinion(ctx api.Context, minionID string) error

+ func (r *MinionRegistry) GetMinion(ctx api.Context, minionID string) (*api.Minion, error)

+ func (r *MinionRegistry) ListMinions(ctx api.Context) (*api.MinionList, 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) UpdatePod(ctx api.Context, pod *api.Pod) error

+ func (r *PodRegistry) WatchPods(ctx api.Context, resourceVersion string, filter func(*api.Pod) bool) (watch.Interface, error)

+ type Scheduler struct

+ Err error

+ Machine string

+ Pod api.Pod

+ func (s *Scheduler) Schedule(pod api.Pod, lister scheduler.MinionLister) (string, error)

+ type ServiceRegistry struct

+ DeletedID string

+ Endpoints api.Endpoints

+ EndpointsList api.EndpointsList

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

+ func (r *ServiceRegistry) DeleteService(ctx api.Context, id string) error

+ func (r *ServiceRegistry) GetEndpoints(ctx api.Context, id string) (*api.Endpoints, error)

+ func (r *ServiceRegistry) GetService(ctx api.Context, id string) (*api.Service, error)

+ func (r *ServiceRegistry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error)

+ func (r *ServiceRegistry) ListServices(ctx api.Context) (*api.ServiceList, error)

+ func (r *ServiceRegistry) UpdateEndpoints(ctx api.Context, e *api.Endpoints) error

+ func (r *ServiceRegistry) UpdateService(ctx api.Context, svc *api.Service) error

+ func (r *ServiceRegistry) WatchEndpoints(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

+ func (r *ServiceRegistry) WatchServices(ctx api.Context, label labels.Selector, field labels.Selector, ...) (watch.Interface, error)