registrytest

package
v0.0.0-...-6aabd98 Latest Latest
Warning

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

Go to latest
Published: Nov 27, 2014 License: Apache-2.0 Imports: 7 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 MakeMinionList

func MakeMinionList(minions []string, nodeResources api.NodeResources) *api.MinionList

Types

type ControllerRegistry

type ControllerRegistry struct {
	Err         error
	Controllers *api.ReplicationControllerList
}

TODO: Why do we have this AND MemoryRegistry?

func (*ControllerRegistry) CreateController

func (r *ControllerRegistry) CreateController(ctx api.Context, controller *api.ReplicationController) error

func (*ControllerRegistry) DeleteController

func (r *ControllerRegistry) DeleteController(ctx api.Context, ID string) error

func (*ControllerRegistry) GetController

func (r *ControllerRegistry) GetController(ctx api.Context, ID string) (*api.ReplicationController, error)

func (*ControllerRegistry) ListControllers

func (r *ControllerRegistry) ListControllers(ctx api.Context) (*api.ReplicationControllerList, error)

func (*ControllerRegistry) UpdateController

func (r *ControllerRegistry) UpdateController(ctx api.Context, controller *api.ReplicationController) error

func (*ControllerRegistry) WatchControllers

func (r *ControllerRegistry) WatchControllers(ctx api.Context, resourceVersion string) (watch.Interface, error)

type GenericRegistry

type GenericRegistry struct {
	Err        error
	Object     runtime.Object
	ObjectList runtime.Object
	sync.Mutex

	Mux *watch.Mux
}

GenericRegistry knows how to store & list any runtime.Object. Events don't require any non-generic features from the storage layer.

func NewGeneric

func NewGeneric(list runtime.Object) *GenericRegistry

func (*GenericRegistry) Create

func (r *GenericRegistry) Create(ctx api.Context, id string, obj runtime.Object) error

func (*GenericRegistry) Delete

func (r *GenericRegistry) Delete(ctx api.Context, id string) error

func (*GenericRegistry) Get

func (r *GenericRegistry) Get(ctx api.Context, id string) (runtime.Object, error)

func (*GenericRegistry) List

func (*GenericRegistry) Update

func (r *GenericRegistry) Update(ctx api.Context, id string, obj runtime.Object) error

func (*GenericRegistry) Watch

func (r *GenericRegistry) Watch(ctx api.Context, m generic.Matcher, resourceVersion string) (watch.Interface, error)

type MinionRegistry

type MinionRegistry struct {
	Err     error
	Minion  string
	Minions api.MinionList
	sync.Mutex
}

func NewMinionRegistry

func NewMinionRegistry(minions []string, nodeResources api.NodeResources) *MinionRegistry

func (*MinionRegistry) CreateMinion

func (r *MinionRegistry) CreateMinion(ctx api.Context, minion *api.Minion) 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.Minion, error)

func (*MinionRegistry) ListMinions

func (r *MinionRegistry) ListMinions(ctx api.Context) (*api.MinionList, error)

func (*MinionRegistry) UpdateMinion

func (r *MinionRegistry) UpdateMinion(ctx api.Context, minion *api.Minion) error

type PodRegistry

type PodRegistry struct {
	Err  error
	Pod  *api.Pod
	Pods *api.PodList
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPodRegistry

func NewPodRegistry(pods *api.PodList) *PodRegistry

func (*PodRegistry) CreatePod

func (r *PodRegistry) CreatePod(ctx api.Context, pod *api.Pod) error

func (*PodRegistry) DeletePod

func (r *PodRegistry) DeletePod(ctx api.Context, podId string) error

func (*PodRegistry) GetPod

func (r *PodRegistry) GetPod(ctx api.Context, podId string) (*api.Pod, error)

func (*PodRegistry) ListPods

func (r *PodRegistry) ListPods(ctx api.Context, selector labels.Selector) (*api.PodList, error)

func (*PodRegistry) ListPodsPredicate

func (r *PodRegistry) ListPodsPredicate(ctx api.Context, filter func(*api.Pod) bool) (*api.PodList, error)

func (*PodRegistry) UpdatePod

func (r *PodRegistry) UpdatePod(ctx api.Context, pod *api.Pod) error

func (*PodRegistry) WatchPods

func (r *PodRegistry) WatchPods(ctx api.Context, resourceVersion string, filter func(*api.Pod) bool) (watch.Interface, error)

type Scheduler

type Scheduler struct {
	Err     error
	Pod     api.Pod
	Machine string
}

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(pod api.Pod, lister scheduler.MinionLister) (string, error)

type ServiceRegistry

type ServiceRegistry struct {
	List          api.ServiceList
	Service       *api.Service
	Err           error
	Endpoints     api.Endpoints
	EndpointsList api.EndpointsList

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

func (*ServiceRegistry) DeleteService

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

func (*ServiceRegistry) GetEndpoints

func (r *ServiceRegistry) GetEndpoints(ctx api.Context, id string) (*api.Endpoints, error)

func (*ServiceRegistry) GetService

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

func (*ServiceRegistry) ListEndpoints

func (r *ServiceRegistry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error)

func (*ServiceRegistry) ListServices

func (r *ServiceRegistry) ListServices(ctx api.Context) (*api.ServiceList, error)

func (*ServiceRegistry) UpdateEndpoints

func (r *ServiceRegistry) UpdateEndpoints(ctx api.Context, e *api.Endpoints) error

func (*ServiceRegistry) UpdateService

func (r *ServiceRegistry) UpdateService(ctx api.Context, svc *api.Service) error

func (*ServiceRegistry) WatchEndpoints

func (r *ServiceRegistry) WatchEndpoints(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

func (*ServiceRegistry) WatchServices

func (r *ServiceRegistry) WatchServices(ctx api.Context, label labels.Selector, field labels.Selector, resourceVersion string) (watch.Interface, error)

Jump to

Keyboard shortcuts

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