registrytest

package
v0.0.0-...-da10ef3 Latest Latest
Warning

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

Go to latest
Published: Feb 6, 2016 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 MakeNodeList

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

MakeNodeList constructs api.NodeList from list of node names and a NodeResource.

func NewEtcdStorage

func NewEtcdStorage(t *testing.T, group string) (storage.Interface, *etcdtesting.EtcdTestServer)

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, options *api.ListOptions) (*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, options *api.ListOptions) (watch.Interface, error)

type NodeRegistry

type NodeRegistry struct {
	Err   error
	Node  string
	Nodes api.NodeList

	sync.Mutex
}

NodeRegistry implements node.Registry interface.

func NewNodeRegistry

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

func (*NodeRegistry) CreateNode

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

func (*NodeRegistry) DeleteNode

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

func (*NodeRegistry) GetNode

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

func (*NodeRegistry) ListNodes

func (r *NodeRegistry) ListNodes(ctx api.Context, options *api.ListOptions) (*api.NodeList, error)

func (*NodeRegistry) SetError

func (r *NodeRegistry) SetError(err error)

func (*NodeRegistry) UpdateNode

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

func (*NodeRegistry) WatchNodes

func (r *NodeRegistry) WatchNodes(ctx api.Context, options *api.ListOptions) (watch.Interface, error)

type ServiceRegistry

type ServiceRegistry struct {
	List    api.ServiceList
	Service *api.Service
	Updates []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, options *api.ListOptions) (*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, options *api.ListOptions) (watch.Interface, error)

type Tester

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

func New

func New(t *testing.T, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL