kubernetes – k8s.io/kubernetes/pkg/registry/registrytest Index | Files

package registrytest

import "k8s.io/kubernetes/pkg/registry/registrytest"

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

Index

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) (*storagebackend.Config, *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) ExportService 

func (r *ServiceRegistry) ExportService(ctx api.Context, name string, options unversioned.ExportOptions) (*api.Service, 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 *registry.Store) *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) Namer 

func (t *Tester) Namer(namer func(int) string) *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

doc.go endpoint.go etcd.go node.go service.go

Version
v1.4.12
Published
Apr 20, 2017
Platform
js/wasm
Imports
18 packages
Last checked
4 minutes ago –

Tools for package owners.