Versions in this module Expand all Collapse all v0 v0.4.0 Jun 23, 2016 Changes in this version type ServiceRegistry + func (r *ServiceRegistry) ExportService(ctx api.Context, name string, options unversioned.ExportOptions) (*api.Service, error) v0.3.0 Mar 16, 2016 Changes in this version type ServiceRegistry + Updates []api.Service v0.1.0 Oct 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 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 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 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, label labels.Selector, field fields.Selector) (*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) + 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