kubernetes.v0: gopkg.in/kubernetes/kubernetes.v0/pkg/registry/registrytest Index | Files

package registrytest

import "gopkg.in/kubernetes/kubernetes.v0/pkg/registry/registrytest"

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

Index

Package Files

controller.go doc.go endpoint.go generic.go minion.go pod.go scheduler.go service.go

func MakeMinionList Uses

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

MakeMinionList constructs api.MinionList from list of minion names and a NodeResource.

type ControllerRegistry Uses

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

TODO: Why do we have this AND MemoryRegistry?

func (*ControllerRegistry) CreateController Uses

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

func (*ControllerRegistry) DeleteController Uses

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

func (*ControllerRegistry) GetController Uses

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

func (*ControllerRegistry) ListControllers Uses

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

func (*ControllerRegistry) SetError Uses

func (r *ControllerRegistry) SetError(err error)

func (*ControllerRegistry) UpdateController Uses

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

func (*ControllerRegistry) WatchControllers Uses

func (r *ControllerRegistry) WatchControllers(ctx api.Context, label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

type EndpointRegistry Uses

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 Uses

func (e *EndpointRegistry) DeleteEndpoints(ctx api.Context, name string) error

func (*EndpointRegistry) GetEndpoints Uses

func (e *EndpointRegistry) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error)

func (*EndpointRegistry) ListEndpoints Uses

func (e *EndpointRegistry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error)

func (*EndpointRegistry) UpdateEndpoints Uses

func (e *EndpointRegistry) UpdateEndpoints(ctx api.Context, endpoints *api.Endpoints) error

func (*EndpointRegistry) WatchEndpoints Uses

func (e *EndpointRegistry) WatchEndpoints(ctx api.Context, labels labels.Selector, fields fields.Selector, resourceVersion string) (watch.Interface, error)

type GenericRegistry Uses

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

    Broadcaster *watch.Broadcaster
}

GenericRegistry knows how to store & list any runtime.Object.

func NewGeneric Uses

func NewGeneric(list runtime.Object) *GenericRegistry

func (*GenericRegistry) CreateWithName Uses

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

func (*GenericRegistry) Delete Uses

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

func (*GenericRegistry) Get Uses

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

func (*GenericRegistry) ListPredicate Uses

func (r *GenericRegistry) ListPredicate(ctx api.Context, m generic.Matcher) (runtime.Object, error)

func (*GenericRegistry) UpdateWithName Uses

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

func (*GenericRegistry) WatchPredicate Uses

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

type MinionRegistry Uses

type MinionRegistry struct {
    Err     error
    Minion  string
    Minions api.NodeList

    sync.Mutex
}

MinionRegistry implements minion.Registry interface.

func NewMinionRegistry Uses

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

func (*MinionRegistry) CreateMinion Uses

func (r *MinionRegistry) CreateMinion(ctx api.Context, minion *api.Node) error

func (*MinionRegistry) DeleteMinion Uses

func (r *MinionRegistry) DeleteMinion(ctx api.Context, minionID string) error

func (*MinionRegistry) GetMinion Uses

func (r *MinionRegistry) GetMinion(ctx api.Context, minionID string) (*api.Node, error)

func (*MinionRegistry) ListMinions Uses

func (r *MinionRegistry) ListMinions(ctx api.Context, label labels.Selector, field fields.Selector) (*api.NodeList, error)

func (*MinionRegistry) SetError Uses

func (r *MinionRegistry) SetError(err error)

func (*MinionRegistry) UpdateMinion Uses

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

func (*MinionRegistry) WatchMinions Uses

func (r *MinionRegistry) WatchMinions(ctx api.Context, label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

type PodRegistry Uses

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

func NewPodRegistry Uses

func NewPodRegistry(pods *api.PodList) *PodRegistry

func (*PodRegistry) CreatePod Uses

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

func (*PodRegistry) DeletePod Uses

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

func (*PodRegistry) GetPod Uses

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

func (*PodRegistry) ListPods Uses

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

func (*PodRegistry) ListPodsPredicate Uses

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

func (*PodRegistry) SetError Uses

func (r *PodRegistry) SetError(err error)

func (*PodRegistry) UpdatePod Uses

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

func (*PodRegistry) WatchPods Uses

func (r *PodRegistry) WatchPods(ctx api.Context, label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error)

type Scheduler Uses

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

func (*Scheduler) Schedule Uses

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

type ServiceRegistry Uses

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

    DeletedID string
    GottenID  string
    UpdatedID string
    // contains filtered or unexported fields
}

func NewServiceRegistry Uses

func NewServiceRegistry() *ServiceRegistry

func (*ServiceRegistry) CreateService Uses

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

func (*ServiceRegistry) DeleteService Uses

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

func (*ServiceRegistry) GetService Uses

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

func (*ServiceRegistry) ListServices Uses

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

func (*ServiceRegistry) SetError Uses

func (r *ServiceRegistry) SetError(err error)

func (*ServiceRegistry) UpdateService Uses

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

func (*ServiceRegistry) WatchServices Uses

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

Package registrytest imports 10 packages (graph). Updated 2016-07-25. Refresh now. Tools for package owners.