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

package etcd

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

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

Index

Package Files

doc.go etcd.go

Constants

const (
    // ServicePath is the path to service resources in etcd
    ServicePath string = "/services/specs"
)

func MakeEtcdItemKey Uses

func MakeEtcdItemKey(ctx api.Context, prefix string, id string) (string, error)

MakeEtcdItemKey constructs etcd paths to a resource relative to prefix enforcing namespace rules. If no namespace is on context, it errors.

func MakeEtcdListKey Uses

func MakeEtcdListKey(ctx api.Context, prefix string) string

MakeEtcdListKey constructs etcd paths to resource directories enforcing namespace rules

type Registry Uses

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

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

func NewRegistry Uses

func NewRegistry(helper tools.EtcdHelper, pods pod.Registry, endpoints endpoint.Registry) *Registry

NewRegistry creates an etcd registry.

func (*Registry) CreateService Uses

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

CreateService creates a new Service.

func (*Registry) DeleteService Uses

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

DeleteService deletes a Service specified by its name.

func (*Registry) GetService Uses

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

GetService obtains a Service specified by its name.

func (*Registry) ListServices Uses

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

ListServices obtains a list of Services.

func (*Registry) UpdateService Uses

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

UpdateService replaces an existing Service.

func (*Registry) WatchServices Uses

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

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

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