physical

package

Go to main page

Versions in this module

v0

v0.3.1

Oct 6, 2015

v0.3.0

Sep 28, 2015

Changes in this version

+ const EtcdLockRenewInterval

v0.3.0-rc

Sep 22, 2015

v0.2.0

Jul 13, 2015

Changes in this version

+ const EtcdLockTTL

+ const EtcdMachineDelimiter

+ const EtcdNodeFilePrefix

+ const EtcdNodeLockPrefix

+ const EtcdWatchRetryInterval

+ const EtcdWatchRetryMax

+ const ZKNodeFilePrefix

+ var EtcdLockHeldError = errors.New("lock already held")

+ var EtcdLockNotHeldError = errors.New("lock not held")

+ var EtcdSemaphoreKeyRemovedError = errors.New("semaphore key removed before lock aquisition")

+ var EtcdSemaphoreKeysEmptyError = errors.New("lock queue is empty")

+ var EtcdSyncClusterError = errors.New("client setup failed: unable to sync etcd cluster")

+ type EtcdBackend struct

+ func (c *EtcdBackend) Delete(key string) error

+ func (c *EtcdBackend) Get(key string) (*Entry, error)

+ func (c *EtcdBackend) List(prefix string) ([]string, error)

+ func (c *EtcdBackend) LockWith(key, value string) (Lock, error)

+ func (c *EtcdBackend) Put(entry *Entry) error

+ type EtcdLock struct

+ func (c *EtcdLock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (c *EtcdLock) Unlock() error

+ func (c *EtcdLock) Value() (bool, string, error)

+ type MySQLBackend struct

+ func (m *MySQLBackend) Delete(key string) error

+ func (m *MySQLBackend) Get(key string) (*Entry, error)

+ func (m *MySQLBackend) List(prefix string) ([]string, error)

+ func (m *MySQLBackend) Put(entry *Entry) error

+ type S3Backend struct

+ func (s *S3Backend) Delete(key string) error

+ func (s *S3Backend) Get(key string) (*Entry, error)

+ func (s *S3Backend) List(prefix string) ([]string, error)

+ func (s *S3Backend) Put(entry *Entry) error

type ZookeeperBackend

+ func (c *ZookeeperBackend) LockWith(key, value string) (Lock, error)

+ type ZookeeperHALock struct

+ func (i *ZookeeperHALock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (i *ZookeeperHALock) Unlock() error

+ func (i *ZookeeperHALock) Value() (bool, string, error)

v0.1.2

May 11, 2015

Changes in this version

+ type AdvertiseDetect interface

+ DetectHostAddr func() (string, error)

type ConsulBackend

+ func (c *ConsulBackend) DetectHostAddr() (string, error)

+ type ZookeeperBackend struct

+ func (c *ZookeeperBackend) Delete(key string) error

+ func (c *ZookeeperBackend) Get(key string) (*Entry, error)

+ func (c *ZookeeperBackend) List(prefix string) ([]string, error)

+ func (c *ZookeeperBackend) Put(entry *Entry) error

v0.1.1

May 2, 2015

v0.1.0

Apr 28, 2015

Changes in this version

+ const DefaultCacheSize

+ var BuiltinBackends = map[string]Factory

+ type Backend interface

+ Delete func(key string) error

+ Get func(key string) (*Entry, error)

+ List func(prefix string) ([]string, error)

+ Put func(entry *Entry) error

+ func NewBackend(t string, conf map[string]string) (Backend, error)

+ type Cache struct

+ func NewCache(b Backend, size int) *Cache

+ func (c *Cache) Delete(key string) error

+ func (c *Cache) Get(key string) (*Entry, error)

+ func (c *Cache) List(prefix string) ([]string, error)

+ func (c *Cache) Purge()

+ func (c *Cache) Put(entry *Entry) error

+ type ConsulBackend struct

+ func (c *ConsulBackend) Delete(key string) error

+ func (c *ConsulBackend) Get(key string) (*Entry, error)

+ func (c *ConsulBackend) List(prefix string) ([]string, error)

+ func (c *ConsulBackend) LockWith(key, value string) (Lock, error)

+ func (c *ConsulBackend) Put(entry *Entry) error

+ type ConsulLock struct

+ func (c *ConsulLock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (c *ConsulLock) Unlock() error

+ func (c *ConsulLock) Value() (bool, string, error)

+ type Entry struct

+ Key string

+ Value []byte

+ type Factory func(map[string]string) (Backend, error)

+ type FileBackend struct

+ Path string

+ func (b *FileBackend) Delete(k string) error

+ func (b *FileBackend) Get(k string) (*Entry, error)

+ func (b *FileBackend) List(prefix string) ([]string, error)

+ func (b *FileBackend) Put(entry *Entry) error

+ type HABackend interface

+ LockWith func(key, value string) (Lock, error)

+ type InmemBackend struct

+ func NewInmem() *InmemBackend

+ func (i *InmemBackend) Delete(key string) error

+ func (i *InmemBackend) Get(key string) (*Entry, error)

+ func (i *InmemBackend) List(prefix string) ([]string, error)

+ func (i *InmemBackend) Put(entry *Entry) error

+ type InmemHABackend struct

+ func NewInmemHA() *InmemHABackend

+ func (i *InmemHABackend) LockWith(key, value string) (Lock, error)

+ type InmemLock struct

+ func (i *InmemLock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (i *InmemLock) Unlock() error

+ func (i *InmemLock) Value() (bool, string, error)

+ type Lock interface

+ Lock func(stopCh <-chan struct{}) (<-chan struct{}, error)

+ Unlock func() error

+ Value func() (bool, string, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL