registrytest

package

v1.1.0-alpha.0....-2321d9e Latest Latest Go to latest Published: Aug 28, 2015 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rajnmithun/kubernetes

Documentation ¶

Overview ¶

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

Index ¶

func GetObject(fakeClient *tools.FakeEtcdClient, keyFn keyFunc, newFn newFunc, ...) (runtime.Object, error)
func MakeMinionList(minions []string, nodeResources api.NodeResources) *api.NodeList
func NewEtcdStorage(t *testing.T) (storage.Interface, *tools.FakeEtcdClient)
func SetObject(fakeClient *tools.FakeEtcdClient, keyFn keyFunc, ctx api.Context, ...) error
func SetObjectsForKey(fakeClient *tools.FakeEtcdClient, key string, objects []runtime.Object) []runtime.Object
func SetResourceVersion(fakeClient *tools.FakeEtcdClient, resourceVersion uint64)
type EndpointRegistry
type MinionRegistry
- func NewMinionRegistry(minions []string, nodeResources api.NodeResources) *MinionRegistry
type ServiceRegistry
- func NewServiceRegistry() *ServiceRegistry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetObject ¶

func GetObject(fakeClient *tools.FakeEtcdClient, keyFn keyFunc, newFn newFunc, ctx api.Context, obj runtime.Object) (runtime.Object, error)

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) (storage.Interface, *tools.FakeEtcdClient)

func SetObject ¶

func SetObject(fakeClient *tools.FakeEtcdClient, keyFn keyFunc, ctx api.Context, obj runtime.Object) error

func SetObjectsForKey ¶

func SetObjectsForKey(fakeClient *tools.FakeEtcdClient, key string, objects []runtime.Object) []runtime.Object

func SetResourceVersion ¶

func SetResourceVersion(fakeClient *tools.FakeEtcdClient, resourceVersion uint64)

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)

Source Files ¶

View all Source files

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