etcd

Documentation

Overview

Package etcd provides etcd backend implementation for storing PodRegistry, ControllerRegistry and ServiceRegistry api objects.

Index

• type Registry
  • func NewRegistry(helper tools.EtcdHelper, manifestFactory pod.ManifestFactory) *Registry
  • func (r *Registry) ApplyBinding(ctx api.Context, binding *api.Binding) error
  • func (r *Registry) CreateController(ctx api.Context, controller *api.ReplicationController) error
  • func (r *Registry) CreateMinion(ctx api.Context, minion *api.Minion) error
  • func (r *Registry) CreatePod(ctx api.Context, pod *api.Pod) error
  • func (r *Registry) CreateService(ctx api.Context, svc *api.Service) error
  • func (r *Registry) DeleteController(ctx api.Context, controllerID string) error
  • func (r *Registry) DeleteMinion(ctx api.Context, minionID string) error
  • func (r *Registry) DeletePod(ctx api.Context, podID string) error
  • func (r *Registry) DeleteService(ctx api.Context, name string) error
  • func (r *Registry) GetController(ctx api.Context, controllerID string) (*api.ReplicationController, error)
  • func (r *Registry) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error)
  • func (r *Registry) GetMinion(ctx api.Context, minionID string) (*api.Minion, error)
  • func (r *Registry) GetPod(ctx api.Context, podID string) (*api.Pod, error)
  • func (r *Registry) GetService(ctx api.Context, name string) (*api.Service, error)
  • func (r *Registry) ListControllers(ctx api.Context) (*api.ReplicationControllerList, error)
  • func (r *Registry) ListEndpoints(ctx api.Context) (*api.EndpointsList, error)
  • func (r *Registry) ListMinions(ctx api.Context) (*api.MinionList, error)
  • func (r *Registry) ListPods(ctx api.Context, selector labels.Selector) (*api.PodList, error)
  • func (r *Registry) ListPodsPredicate(ctx api.Context, filter func(*api.Pod) bool) (*api.PodList, error)
  • func (r *Registry) ListServices(ctx api.Context) (*api.ServiceList, error)
  • func (r *Registry) UpdateController(ctx api.Context, controller *api.ReplicationController) error
  • func (r *Registry) UpdateEndpoints(ctx api.Context, e *api.Endpoints) error
  • func (r *Registry) UpdatePod(ctx api.Context, pod *api.Pod) error
  • func (r *Registry) UpdateService(ctx api.Context, svc *api.Service) error
  • func (r *Registry) WatchControllers(ctx api.Context, resourceVersion string) (watch.Interface, error)
  • func (r *Registry) WatchEndpoints(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)
  • func (r *Registry) WatchPods(ctx api.Context, resourceVersion string, filter func(*api.Pod) bool) (watch.Interface, error)
  • func (r *Registry) WatchServices(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

Types

type Registry

type Registry struct {
	tools.EtcdHelper
	// contains filtered or unexported fields
}

Registry implements PodRegistry, ControllerRegistry, ServiceRegistry and MinionRegistry, backed by etcd.

func NewRegistry

func NewRegistry(helper tools.EtcdHelper, manifestFactory pod.ManifestFactory) *Registry

NewRegistry creates an etcd registry.

func (*Registry) ApplyBinding

func (r *Registry) ApplyBinding(ctx api.Context, binding *api.Binding) error

ApplyBinding implements binding's registry

func (*Registry) CreateController

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

CreateController creates a new ReplicationController.

func (*Registry) CreateMinion

func (r *Registry) CreateMinion(ctx api.Context, minion *api.Minion) error

func (*Registry) CreatePod

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

CreatePod creates a pod based on a specification.

func (*Registry) CreateService

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

CreateService creates a new Service.

func (*Registry) DeleteController

func (r *Registry) DeleteController(ctx api.Context, controllerID string) error

DeleteController deletes a ReplicationController specified by its ID.

func (*Registry) DeleteMinion

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

func (*Registry) DeletePod

func (r *Registry) DeletePod(ctx api.Context, podID string) error

DeletePod deletes an existing pod specified by its ID.

func (*Registry) DeleteService

func (r *Registry) DeleteService(ctx api.Context, name string) error

DeleteService deletes a Service specified by its name.

func (*Registry) GetController

func (r *Registry) GetController(ctx api.Context, controllerID string) (*api.ReplicationController, error)

GetController gets a specific ReplicationController specified by its ID.

func (*Registry) GetEndpoints

func (r *Registry) GetEndpoints(ctx api.Context, name string) (*api.Endpoints, error)

GetEndpoints obtains the endpoints for the service identified by 'name'.

func (*Registry) GetMinion

func (r *Registry) GetMinion(ctx api.Context, minionID string) (*api.Minion, error)

func (*Registry) GetPod

func (r *Registry) GetPod(ctx api.Context, podID string) (*api.Pod, error)

GetPod gets a specific pod specified by its ID.

func (*Registry) GetService

func (r *Registry) GetService(ctx api.Context, name string) (*api.Service, error)

GetService obtains a Service specified by its name.

func (*Registry) ListControllers

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

ListControllers obtains a list of ReplicationControllers.

func (*Registry) ListEndpoints

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

ListEndpoints obtains a list of Services.

func (*Registry) ListMinions

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

func (*Registry) ListPods

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

ListPods obtains a list of pods with labels that match selector.

func (*Registry) ListPodsPredicate

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

ListPodsPredicate obtains a list of pods that match filter.

func (*Registry) ListServices

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

ListServices obtains a list of Services.

func (*Registry) UpdateController

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

UpdateController replaces an existing ReplicationController.

func (*Registry) UpdateEndpoints

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

UpdateEndpoints update Endpoints of a Service.

func (*Registry) UpdatePod

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

func (*Registry) UpdateService

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

UpdateService replaces an existing Service.

func (*Registry) WatchControllers

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

WatchControllers begins watching for new, changed, or deleted controllers.

func (*Registry) WatchEndpoints

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

WatchEndpoints begins watching for new, changed, or deleted endpoint configurations.

func (*Registry) WatchPods

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

WatchPods begins watching for new, changed, or deleted pods.

func (*Registry) WatchServices

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

WatchServices begins watching for new, changed, or deleted service configurations.