etcd

Documentation

Overview

Package etcd provides etcd backend implementation for storing Deployment and DeploymentConfig objects

Index

• Constants
• type Etcd
  • func New(helper tools.EtcdHelper) *Etcd
  • func (r *Etcd) CreateDeployment(ctx kapi.Context, deployment *api.Deployment) error
  • func (r *Etcd) CreateDeploymentConfig(ctx kapi.Context, deploymentConfig *api.DeploymentConfig) error
  • func (r *Etcd) DeleteDeployment(ctx kapi.Context, id string) error
  • func (r *Etcd) DeleteDeploymentConfig(ctx kapi.Context, id string) error
  • func (r *Etcd) GetDeployment(ctx kapi.Context, id string) (*api.Deployment, error)
  • func (r *Etcd) GetDeploymentConfig(ctx kapi.Context, id string) (*api.DeploymentConfig, error)
  • func (r *Etcd) ListDeploymentConfigs(ctx kapi.Context, label, field labels.Selector) (*api.DeploymentConfigList, error)
  • func (r *Etcd) ListDeployments(ctx kapi.Context, label, field labels.Selector) (*api.DeploymentList, error)
  • func (r *Etcd) UpdateDeployment(ctx kapi.Context, deployment *api.Deployment) error
  • func (r *Etcd) UpdateDeploymentConfig(ctx kapi.Context, deploymentConfig *api.DeploymentConfig) error
  • func (r *Etcd) WatchDeploymentConfigs(ctx kapi.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)
  • func (r *Etcd) WatchDeployments(ctx kapi.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

Constants

const (
	// DeploymentPath is the path to deployment resources in etcd
	DeploymentPath string = "/deployments"
	// DeploymentConfigPath is the path to deploymentConfig resources in etcd
	DeploymentConfigPath string = "/deploymentConfigs"
)

Types

type Etcd

type Etcd struct {
	tools.EtcdHelper
}

Etcd implements deployment.Registry and deploymentconfig.Registry interfaces.

func New

func New(helper tools.EtcdHelper) *Etcd

New creates an etcd registry.

func (*Etcd) CreateDeployment

func (r *Etcd) CreateDeployment(ctx kapi.Context, deployment *api.Deployment) error

CreateDeployment creates a new Deployment.

func (*Etcd) CreateDeploymentConfig

func (r *Etcd) CreateDeploymentConfig(ctx kapi.Context, deploymentConfig *api.DeploymentConfig) error

CreateDeploymentConfig creates a new DeploymentConfig.

func (*Etcd) DeleteDeployment

func (r *Etcd) DeleteDeployment(ctx kapi.Context, id string) error

DeleteDeployment deletes a Deployment specified by its ID.

func (*Etcd) DeleteDeploymentConfig

func (r *Etcd) DeleteDeploymentConfig(ctx kapi.Context, id string) error

DeleteDeploymentConfig deletes a DeploymentConfig specified by its ID.

func (*Etcd) GetDeployment

func (r *Etcd) GetDeployment(ctx kapi.Context, id string) (*api.Deployment, error)

GetDeployment gets a specific Deployment specified by its ID.

func (*Etcd) GetDeploymentConfig

func (r *Etcd) GetDeploymentConfig(ctx kapi.Context, id string) (*api.DeploymentConfig, error)

GetDeploymentConfig gets a specific DeploymentConfig specified by its ID.

func (*Etcd) ListDeploymentConfigs

func (r *Etcd) ListDeploymentConfigs(ctx kapi.Context, label, field labels.Selector) (*api.DeploymentConfigList, error)

ListDeploymentConfigs obtains a list of DeploymentConfigs.

func (*Etcd) ListDeployments

func (r *Etcd) ListDeployments(ctx kapi.Context, label, field labels.Selector) (*api.DeploymentList, error)

ListDeployments obtains a list of Deployments.

func (*Etcd) UpdateDeployment

func (r *Etcd) UpdateDeployment(ctx kapi.Context, deployment *api.Deployment) error

UpdateDeployment replaces an existing Deployment.

func (*Etcd) UpdateDeploymentConfig

func (r *Etcd) UpdateDeploymentConfig(ctx kapi.Context, deploymentConfig *api.DeploymentConfig) error

UpdateDeploymentConfig replaces an existing DeploymentConfig.

func (*Etcd) WatchDeploymentConfigs

func (r *Etcd) WatchDeploymentConfigs(ctx kapi.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

WatchDeploymentConfigs begins watching for new, changed, or deleted DeploymentConfigs.

func (*Etcd) WatchDeployments

func (r *Etcd) WatchDeployments(ctx kapi.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)

WatchDeployments begins watching for new, changed, or deleted Deployments.