registrytest

Documentation

Overview

Package registrytest provides tests for Registry implementations for storing Minions, Pods, Schedulers and Services.

Index

• func MakeMinionList(minions []string, nodeResources api.NodeResources) *api.NodeList
• func NewEtcdStorage(t *testing.T, group string) (storage.Interface, *tools.FakeEtcdClient)
• type EndpointRegistry
  • 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 MinionRegistry
  • 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 ServiceRegistry
  • 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
  • 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

Functions

func MakeMinionList

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

MakeMinionList constructs api.MinionList from list of minion names and a NodeResource.

func NewEtcdStorage

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

Types

type EndpointRegistry

type EndpointRegistry struct {
	Endpoints *api.EndpointsList
	Updates   []api.Endpoints
	Err       error
	// contains filtered or unexported fields
}

Registry is an interface for things that know how to store endpoints.

func (*EndpointRegistry) DeleteEndpoints

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

func (*EndpointRegistry) GetEndpoints

func (e *EndpointRegistry) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error)

func (*EndpointRegistry) ListEndpoints

func (e *EndpointRegistry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error)

func (*EndpointRegistry) UpdateEndpoints

func (e *EndpointRegistry) UpdateEndpoints(ctx api.Context, endpoints *api.Endpoints) error

func (*EndpointRegistry) WatchEndpoints

func (e *EndpointRegistry) WatchEndpoints(ctx api.Context, labels labels.Selector, fields fields.Selector, resourceVersion string) (watch.Interface, error)

type MinionRegistry

type MinionRegistry struct {
	Err     error
	Minion  string
	Minions api.NodeList

	sync.Mutex
}

MinionRegistry implements minion.Registry interface.

func NewMinionRegistry

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

func (*MinionRegistry) CreateMinion

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

func (*MinionRegistry) DeleteMinion

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

func (*MinionRegistry) GetMinion

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

func (*MinionRegistry) ListMinions

func (r *MinionRegistry) ListMinions(ctx api.Context, label labels.Selector, field fields.Selector) (*api.NodeList, error)

func (*MinionRegistry) SetError

func (r *MinionRegistry) SetError(err error)

func (*MinionRegistry) UpdateMinion

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

func (*MinionRegistry) WatchMinions

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

type ServiceRegistry

type ServiceRegistry struct {
	List    api.ServiceList
	Service *api.Service
	Err     error

	DeletedID string
	GottenID  string
	UpdatedID string
	// contains filtered or unexported fields
}

func NewServiceRegistry

func NewServiceRegistry() *ServiceRegistry

func (*ServiceRegistry) CreateService

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

func (*ServiceRegistry) DeleteService

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

func (*ServiceRegistry) GetService

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

func (*ServiceRegistry) ListServices

func (r *ServiceRegistry) ListServices(ctx api.Context, label labels.Selector, field fields.Selector) (*api.ServiceList, error)

func (*ServiceRegistry) SetError

func (r *ServiceRegistry) SetError(err error)

func (*ServiceRegistry) UpdateService

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

func (*ServiceRegistry) WatchServices

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

type Tester

type Tester struct {
	// contains filtered or unexported fields
}

func New

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

func (*Tester) AllowCreateOnUpdate

func (t *Tester) AllowCreateOnUpdate() *Tester

func (*Tester) ClusterScope

func (t *Tester) ClusterScope() *Tester

func (*Tester) GeneratesName

func (t *Tester) GeneratesName() *Tester

func (*Tester) ReturnDeletedObject

func (t *Tester) ReturnDeletedObject() *Tester

func (*Tester) TestCreate

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

func (*Tester) TestDelete

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

func (*Tester) TestDeleteGraceful

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

func (*Tester) TestGet

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

func (*Tester) TestList

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

func (*Tester) TestNamespace

func (t *Tester) TestNamespace() string

func (*Tester) TestUpdate

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

func (*Tester) TestWatch

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

type UpdateFunc

type UpdateFunc func(runtime.Object) runtime.Object