registrytest

package
v1.1.0-alpha.0....-2e2def3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 5, 2015 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.