Version: v0.0.0-...-e6272b8 Latest Latest

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

Go to latest
Published: Mar 19, 2019 License: Apache-2.0 Imports: 18 Imported by: 0



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



This section is empty.


This section is empty.


func AssertCategories

func AssertCategories(t *testing.T, storage rest.CategoriesProvider, expected []string)

func AssertShortNames

func AssertShortNames(t *testing.T, storage rest.ShortNamesProvider, expected []string)

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)

func ValidateStorageStrategies

func ValidateStorageStrategies(storageMap map[string]rest.Storage, exceptions StrategyExceptions) []error

ValidateStorageStrategies ensures any instances of the generic registry.Store in the given storage map have expected strategies defined.


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) Create

func (e *EndpointRegistry) Create(ctx context.Context, endpoints runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)

func (*EndpointRegistry) Delete

func (e *EndpointRegistry) Delete(ctx context.Context, name string, options *metav1.DeleteOptions) (runtime.Object, bool, error)

func (*EndpointRegistry) DeleteCollection

func (*EndpointRegistry) Get

func (e *EndpointRegistry) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

func (*EndpointRegistry) List

func (*EndpointRegistry) New

func (e *EndpointRegistry) New() runtime.Object

func (*EndpointRegistry) NewList

func (e *EndpointRegistry) NewList() runtime.Object

func (*EndpointRegistry) Update

func (e *EndpointRegistry) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc, forceAllowCreateOnUpdate bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)

func (*EndpointRegistry) Watch

type NodeRegistry

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


NodeRegistry implements node.Registry interface.

func NewNodeRegistry

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

func (*NodeRegistry) CreateNode

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

func (*NodeRegistry) DeleteNode

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

func (*NodeRegistry) GetNode

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

func (*NodeRegistry) ListNodes

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

func (*NodeRegistry) SetError

func (r *NodeRegistry) SetError(err error)

func (*NodeRegistry) UpdateNode

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

func (*NodeRegistry) WatchNodes

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 context.Context, svc *api.Service, createValidation rest.ValidateObjectFunc) (*api.Service, error)

func (*ServiceRegistry) DeleteService

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

func (*ServiceRegistry) ExportService

func (r *ServiceRegistry) ExportService(ctx context.Context, name string, options metav1.ExportOptions) (*api.Service, error)

func (*ServiceRegistry) GetService

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

func (*ServiceRegistry) ListServices

func (*ServiceRegistry) SetError

func (r *ServiceRegistry) SetError(err error)

func (*ServiceRegistry) UpdateService

func (r *ServiceRegistry) UpdateService(ctx context.Context, svc *api.Service, createValidation rest.ValidateObjectFunc, updateValidation rest.ValidateObjectUpdateFunc) (*api.Service, error)

func (*ServiceRegistry) WatchServices

type StrategyExceptions

type StrategyExceptions struct {
	// HasExportStrategy is a list of the resource keys whose store should have a custom export strategy.
	HasExportStrategy []string

StrategyExceptions carries information on what exceptions to default strategy expectations are expected.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL