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.

Index

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.