etcdbackend

Documentation

Overview

Etcd implementation of the backend, where all vulcand properties are implemented as directories or keys. This backend watches the changes and generates events with sequence of changes.

Index

• type EtcdBackend
  • func NewEtcdBackend(registry *plugin.Registry, nodes []string, etcdKey string) (*EtcdBackend, error)
  • func NewEtcdBackendWithOptions(registry *plugin.Registry, nodes []string, etcdKey string, options Options) (*EtcdBackend, error)
  • func (s *EtcdBackend) AddEndpoint(e *backend.Endpoint) (*backend.Endpoint, error)
  • func (s *EtcdBackend) AddHost(h *backend.Host) (*backend.Host, error)
  • func (s *EtcdBackend) AddHostListener(hostname string, listener *backend.Listener) (*backend.Listener, error)
  • func (s *EtcdBackend) AddLocation(l *backend.Location) (*backend.Location, error)
  • func (s *EtcdBackend) AddLocationMiddleware(hostname, locationId string, m *backend.MiddlewareInstance) (*backend.MiddlewareInstance, error)
  • func (s *EtcdBackend) AddUpstream(u *backend.Upstream) (*backend.Upstream, error)
  • func (s *EtcdBackend) Close()
  • func (s *EtcdBackend) DeleteEndpoint(upstreamId, id string) error
  • func (s *EtcdBackend) DeleteHost(name string) error
  • func (s *EtcdBackend) DeleteHostListener(hostname string, listenerId string) error
  • func (s *EtcdBackend) DeleteLocation(hostname, id string) error
  • func (s *EtcdBackend) DeleteLocationMiddleware(hostname, locationId, mType, id string) error
  • func (s *EtcdBackend) DeleteUpstream(upstreamId string) error
  • func (s *EtcdBackend) ExpectLocation(hostname, locationId string) error
  • func (s *EtcdBackend) GetEndpoint(upstreamId, id string) (*backend.Endpoint, error)
  • func (s *EtcdBackend) GetHost(hostname string) (*backend.Host, error)
  • func (s *EtcdBackend) GetHosts() ([]*backend.Host, error)
  • func (s *EtcdBackend) GetLocation(hostname, locationId string) (*backend.Location, error)
  • func (s *EtcdBackend) GetLocationMiddleware(hostname, locationId, mType, id string) (*backend.MiddlewareInstance, error)
  • func (s *EtcdBackend) GetRegistry() *plugin.Registry
  • func (s *EtcdBackend) GetUpstream(upstreamId string) (*backend.Upstream, error)
  • func (s *EtcdBackend) GetUpstreams() ([]*backend.Upstream, error)
  • func (s *EtcdBackend) UpdateHostKeyPair(hostname string, keyPair *backend.KeyPair) (*backend.Host, error)
  • func (s *EtcdBackend) UpdateLocationMiddleware(hostname, locationId string, m *backend.MiddlewareInstance) (*backend.MiddlewareInstance, error)
  • func (s *EtcdBackend) UpdateLocationOptions(hostname, id string, o backend.LocationOptions) (*backend.Location, error)
  • func (s *EtcdBackend) UpdateLocationUpstream(hostname, id, upstreamId string) (*backend.Location, error)
  • func (s *EtcdBackend) UpdateUpstreamOptions(id string, o backend.UpstreamOptions) (*backend.Upstream, error)
  • func (s *EtcdBackend) WatchChanges(changes chan interface{}, cancelC chan bool) error
• type MatcherFn
• type Options
• type Pair

Types

type EtcdBackend

type EtcdBackend struct {
	// contains filtered or unexported fields
}

func NewEtcdBackend

func NewEtcdBackend(registry *plugin.Registry, nodes []string, etcdKey string) (*EtcdBackend, error)

func NewEtcdBackendWithOptions

func NewEtcdBackendWithOptions(registry *plugin.Registry, nodes []string, etcdKey string, options Options) (*EtcdBackend, error)

func (*EtcdBackend) AddEndpoint

func (s *EtcdBackend) AddEndpoint(e *backend.Endpoint) (*backend.Endpoint, error)

func (*EtcdBackend) AddHost

func (s *EtcdBackend) AddHost(h *backend.Host) (*backend.Host, error)

func (*EtcdBackend) AddHostListener

func (s *EtcdBackend) AddHostListener(hostname string, listener *backend.Listener) (*backend.Listener, error)

func (*EtcdBackend) AddLocation

func (s *EtcdBackend) AddLocation(l *backend.Location) (*backend.Location, error)

func (*EtcdBackend) AddLocationMiddleware

func (s *EtcdBackend) AddLocationMiddleware(hostname, locationId string, m *backend.MiddlewareInstance) (*backend.MiddlewareInstance, error)

func (*EtcdBackend) AddUpstream

func (s *EtcdBackend) AddUpstream(u *backend.Upstream) (*backend.Upstream, error)

func (*EtcdBackend) Close

func (s *EtcdBackend) Close()

func (*EtcdBackend) DeleteEndpoint

func (s *EtcdBackend) DeleteEndpoint(upstreamId, id string) error

func (*EtcdBackend) DeleteHost

func (s *EtcdBackend) DeleteHost(name string) error

func (*EtcdBackend) DeleteHostListener

func (s *EtcdBackend) DeleteHostListener(hostname string, listenerId string) error

func (*EtcdBackend) DeleteLocation

func (s *EtcdBackend) DeleteLocation(hostname, id string) error

func (*EtcdBackend) DeleteLocationMiddleware

func (s *EtcdBackend) DeleteLocationMiddleware(hostname, locationId, mType, id string) error

func (*EtcdBackend) DeleteUpstream

func (s *EtcdBackend) DeleteUpstream(upstreamId string) error

func (*EtcdBackend) ExpectLocation

func (s *EtcdBackend) ExpectLocation(hostname, locationId string) error

func (*EtcdBackend) GetEndpoint

func (s *EtcdBackend) GetEndpoint(upstreamId, id string) (*backend.Endpoint, error)

func (*EtcdBackend) GetHost

func (s *EtcdBackend) GetHost(hostname string) (*backend.Host, error)

func (*EtcdBackend) GetHosts

func (s *EtcdBackend) GetHosts() ([]*backend.Host, error)

func (*EtcdBackend) GetLocation

func (s *EtcdBackend) GetLocation(hostname, locationId string) (*backend.Location, error)

func (*EtcdBackend) GetLocationMiddleware

func (s *EtcdBackend) GetLocationMiddleware(hostname, locationId, mType, id string) (*backend.MiddlewareInstance, error)

func (*EtcdBackend) GetRegistry

func (s *EtcdBackend) GetRegistry() *plugin.Registry

func (*EtcdBackend) GetUpstream

func (s *EtcdBackend) GetUpstream(upstreamId string) (*backend.Upstream, error)

func (*EtcdBackend) GetUpstreams

func (s *EtcdBackend) GetUpstreams() ([]*backend.Upstream, error)

func (*EtcdBackend) UpdateHostKeyPair

func (s *EtcdBackend) UpdateHostKeyPair(hostname string, keyPair *backend.KeyPair) (*backend.Host, error)

func (*EtcdBackend) UpdateLocationMiddleware

func (s *EtcdBackend) UpdateLocationMiddleware(hostname, locationId string, m *backend.MiddlewareInstance) (*backend.MiddlewareInstance, error)

func (*EtcdBackend) UpdateLocationOptions

func (s *EtcdBackend) UpdateLocationOptions(hostname, id string, o backend.LocationOptions) (*backend.Location, error)

func (*EtcdBackend) UpdateLocationUpstream

func (s *EtcdBackend) UpdateLocationUpstream(hostname, id, upstreamId string) (*backend.Location, error)

func (*EtcdBackend) UpdateUpstreamOptions

func (s *EtcdBackend) UpdateUpstreamOptions(id string, o backend.UpstreamOptions) (*backend.Upstream, error)

func (*EtcdBackend) WatchChanges

func (s *EtcdBackend) WatchChanges(changes chan interface{}, cancelC chan bool) error

Watches etcd changes and generates structured events telling vulcand to add or delete locations, hosts etc.

type MatcherFn

type MatcherFn func(*etcd.Response) (interface{}, error)

type Options

type Options struct {
	EtcdConsistency string
	Box             *secret.Box
}

type Pair

type Pair struct {
	Key string
	Val string
}