etcdbackend

package
Version: v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 22, 2014 License: Apache-2.0 Imports: 10 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL