Documentation
¶
Overview ¶
Package registrytest provides tests for Registry implementations for storing Nodes, Pods, Schedulers and Services.
Index ¶
- func AssertCategories(t *testing.T, storage rest.CategoriesProvider, expected []string)
- func AssertShortNames(t *testing.T, storage rest.ShortNamesProvider, expected []string)
- func MakeNodeList(nodes []string, nodeResources api.NodeResources) *api.NodeList
- func NewEtcdStorage(t *testing.T, group string) (*storagebackend.Config, *etcdtesting.EtcdTestServer)
- func ValidateStorageStrategies(storageMap map[string]rest.Storage, exceptions StrategyExceptions) []error
- type EndpointRegistry
- func (e *EndpointRegistry) Create(ctx context.Context, endpoints runtime.Object, ...) (runtime.Object, error)
- func (e *EndpointRegistry) Delete(ctx context.Context, name string, options *metav1.DeleteOptions) (runtime.Object, bool, error)
- func (e *EndpointRegistry) DeleteCollection(ctx context.Context, _ *metav1.DeleteOptions, ...) (runtime.Object, error)
- func (e *EndpointRegistry) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
- func (e *EndpointRegistry) List(ctx context.Context, options *metainternalversion.ListOptions) (runtime.Object, error)
- func (e *EndpointRegistry) New() runtime.Object
- func (e *EndpointRegistry) NewList() runtime.Object
- func (e *EndpointRegistry) Update(ctx context.Context, name string, objInfo rest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
- func (e *EndpointRegistry) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
- type NodeRegistry
- func (r *NodeRegistry) CreateNode(ctx context.Context, node *api.Node) error
- func (r *NodeRegistry) DeleteNode(ctx context.Context, nodeID string) error
- func (r *NodeRegistry) GetNode(ctx context.Context, nodeID string, options *metav1.GetOptions) (*api.Node, error)
- func (r *NodeRegistry) ListNodes(ctx context.Context, options *metainternalversion.ListOptions) (*api.NodeList, error)
- func (r *NodeRegistry) SetError(err error)
- func (r *NodeRegistry) UpdateNode(ctx context.Context, node *api.Node) error
- func (r *NodeRegistry) WatchNodes(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
- type ServiceRegistry
- func (r *ServiceRegistry) CreateService(ctx context.Context, svc *api.Service, ...) (*api.Service, error)
- func (r *ServiceRegistry) DeleteService(ctx context.Context, id string) error
- func (r *ServiceRegistry) ExportService(ctx context.Context, name string, options metav1.ExportOptions) (*api.Service, error)
- func (r *ServiceRegistry) GetService(ctx context.Context, id string, options *metav1.GetOptions) (*api.Service, error)
- func (r *ServiceRegistry) ListServices(ctx context.Context, options *metainternalversion.ListOptions) (*api.ServiceList, error)
- func (r *ServiceRegistry) SetError(err error)
- func (r *ServiceRegistry) UpdateService(ctx context.Context, svc *api.Service, ...) (*api.Service, error)
- func (r *ServiceRegistry) WatchServices(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
- type StrategyExceptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AssertCategories ¶ added in v1.7.0
func AssertCategories(t *testing.T, storage rest.CategoriesProvider, expected []string)
func AssertShortNames ¶ added in v1.6.0
func AssertShortNames(t *testing.T, storage rest.ShortNamesProvider, expected []string)
func MakeNodeList ¶ added in v1.2.3
func MakeNodeList(nodes []string, nodeResources api.NodeResources) *api.NodeList
MakeNodeList constructs api.NodeList from list of node names and a NodeResource.
func NewEtcdStorage ¶ added in v1.2.3
func NewEtcdStorage(t *testing.T, group string) (*storagebackend.Config, *etcdtesting.EtcdTestServer)
func ValidateStorageStrategies ¶ added in v1.8.0
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.
Types ¶
type EndpointRegistry ¶ added in v0.13.1
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 ¶ added in v1.12.0
func (e *EndpointRegistry) Create(ctx context.Context, endpoints runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error)
func (*EndpointRegistry) Delete ¶ added in v1.12.0
func (e *EndpointRegistry) Delete(ctx context.Context, name string, options *metav1.DeleteOptions) (runtime.Object, bool, error)
func (*EndpointRegistry) DeleteCollection ¶ added in v1.12.0
func (e *EndpointRegistry) DeleteCollection(ctx context.Context, _ *metav1.DeleteOptions, _ *metainternalversion.ListOptions) (runtime.Object, error)
func (*EndpointRegistry) Get ¶ added in v1.12.0
func (e *EndpointRegistry) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
func (*EndpointRegistry) List ¶ added in v1.12.0
func (e *EndpointRegistry) List(ctx context.Context, options *metainternalversion.ListOptions) (runtime.Object, error)
func (*EndpointRegistry) New ¶ added in v1.12.0
func (e *EndpointRegistry) New() runtime.Object
func (*EndpointRegistry) NewList ¶ added in v1.12.0
func (e *EndpointRegistry) NewList() runtime.Object
func (*EndpointRegistry) Update ¶ added in v1.12.0
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 ¶ added in v1.12.0
func (e *EndpointRegistry) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
type NodeRegistry ¶ added in v1.2.3
NodeRegistry implements node.Registry interface.
func NewNodeRegistry ¶ added in v1.2.3
func NewNodeRegistry(nodes []string, nodeResources api.NodeResources) *NodeRegistry
func (*NodeRegistry) CreateNode ¶ added in v1.2.3
func (*NodeRegistry) DeleteNode ¶ added in v1.2.3
func (r *NodeRegistry) DeleteNode(ctx context.Context, nodeID string) error
func (*NodeRegistry) GetNode ¶ added in v1.2.3
func (r *NodeRegistry) GetNode(ctx context.Context, nodeID string, options *metav1.GetOptions) (*api.Node, error)
func (*NodeRegistry) ListNodes ¶ added in v1.2.3
func (r *NodeRegistry) ListNodes(ctx context.Context, options *metainternalversion.ListOptions) (*api.NodeList, error)
func (*NodeRegistry) SetError ¶ added in v1.2.3
func (r *NodeRegistry) SetError(err error)
func (*NodeRegistry) UpdateNode ¶ added in v1.2.3
func (*NodeRegistry) WatchNodes ¶ added in v1.2.3
func (r *NodeRegistry) WatchNodes(ctx context.Context, options *metainternalversion.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 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 ¶ added in v1.2.3
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 (r *ServiceRegistry) ListServices(ctx context.Context, options *metainternalversion.ListOptions) (*api.ServiceList, error)
func (*ServiceRegistry) SetError ¶ added in v0.13.1
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 ¶
func (r *ServiceRegistry) WatchServices(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error)
type StrategyExceptions ¶ added in v1.8.0
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.
Click to show internal directories.
Click to hide internal directories.