kubernetes: github.com/K-A-Z/kubernetes/pkg/registry/controller Index | Files

package controller

import "github.com/K-A-Z/kubernetes/pkg/registry/controller"

Package controller provides Registry interface and it's RESTStorage implementation for storing ReplicationController api objects.


Package Files

doc.go registry.go storage.go

func NewRegistryStorage Uses

func NewRegistryStorage(registry Registry, podRegistry pod.Registry) apiserver.RESTStorage

NewRegistryStorage returns a new apiserver.RESTStorage for the given registry and podRegistry.

type Registry Uses

type Registry interface {
    ListControllers() (*api.ReplicationControllerList, error)
    WatchControllers(resourceVersion uint64) (watch.Interface, error)
    GetController(controllerID string) (*api.ReplicationController, error)
    CreateController(controller api.ReplicationController) error
    UpdateController(controller api.ReplicationController) error
    DeleteController(controllerID string) error

Registry is an interface for things that know how to store ReplicationControllers.

type RegistryStorage Uses

type RegistryStorage struct {
    // contains filtered or unexported fields

RegistryStorage stores data for the replication controller service. It implements apiserver.RESTStorage.

func (*RegistryStorage) Create Uses

func (rs *RegistryStorage) Create(obj interface{}) (<-chan interface{}, error)

Create registers the given ReplicationController.

func (*RegistryStorage) Delete Uses

func (rs *RegistryStorage) Delete(id string) (<-chan interface{}, error)

Delete asynchronously deletes the ReplicationController specified by its id.

func (*RegistryStorage) Get Uses

func (rs *RegistryStorage) Get(id string) (interface{}, error)

Get obtains the ReplicationController specified by its id.

func (*RegistryStorage) List Uses

func (rs *RegistryStorage) List(selector labels.Selector) (interface{}, error)

List obtains a list of ReplicationControllers that match selector.

func (RegistryStorage) New Uses

func (rs RegistryStorage) New() interface{}

New creates a new ReplicationController for use with Create and Update.

func (*RegistryStorage) Update Uses

func (rs *RegistryStorage) Update(obj interface{}) (<-chan interface{}, error)

Update replaces a given ReplicationController instance with an existing instance in storage.registry.

func (*RegistryStorage) Watch Uses

func (rs *RegistryStorage) Watch(label, field labels.Selector, resourceVersion uint64) (watch.Interface, error)

Watch returns ReplicationController events via a watch.Interface. It implements apiserver.ResourceWatcher.

Package controller imports 11 packages (graph). Updated 2017-03-09. Refresh now. Tools for package owners.