Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

store

package

Go to main page

Versions in this module

v0

v0.3.0

Jun 16, 2015

Changes in this version

+ const CONSUL

+ const DefaultWatchWaitTime

+ const ETCD

+ const MOCK

+ const ZK

+ var ErrCannotLock = errors.New("Error acquiring the lock")

+ var ErrInvalidTTL = errors.New(...)

+ var ErrKeyModified = errors.New("Unable to complete atomic operation, key modified")

+ var ErrKeyNotFound = errors.New("Key not found in store")

+ var ErrNotImplemented = errors.New("Call not implemented in current backend")

+ var ErrNotReachable = errors.New("Api not reachable")

+ var ErrNotSupported = errors.New("Backend storage not supported yet, please choose another one")

+ var ErrPreviousNotSpecified = errors.New("Previous K/V pair should be provided for the Atomic operation")

+ var ErrWatchDoesNotExist = errors.New("No watch found for specified key")

+ type Backend string

+ type Config struct

+ ConnectionTimeout time.Duration

+ EphemeralTTL time.Duration

+ TLS *tls.Config

+ type Consul struct

+ func (s *Consul) AtomicDelete(key string, previous *KVPair) (bool, error)

+ func (s *Consul) AtomicPut(key string, value []byte, previous *KVPair, options *WriteOptions) (bool, *KVPair, error)

+ func (s *Consul) Close()

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

+ func (s *Consul) DeleteTree(prefix string) error

+ func (s *Consul) Exists(key string) (bool, error)

+ func (s *Consul) Get(key string) (*KVPair, error)

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

+ func (s *Consul) NewLock(key string, options *LockOptions) (Locker, error)

+ func (s *Consul) Put(key string, value []byte, opts *WriteOptions) error

+ func (s *Consul) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, error)

+ func (s *Consul) WatchTree(prefix string, stopCh <-chan struct{}) (<-chan []*KVPair, error)

+ type Etcd struct

+ func (s *Etcd) AtomicDelete(key string, previous *KVPair) (bool, error)

+ func (s *Etcd) AtomicPut(key string, value []byte, previous *KVPair, options *WriteOptions) (bool, *KVPair, error)

+ func (s *Etcd) Close()

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

+ func (s *Etcd) DeleteTree(prefix string) error

+ func (s *Etcd) Exists(key string) (bool, error)

+ func (s *Etcd) Get(key string) (*KVPair, error)

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

+ func (s *Etcd) NewLock(key string, options *LockOptions) (Locker, error)

+ func (s *Etcd) Put(key string, value []byte, opts *WriteOptions) error

+ func (s *Etcd) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, error)

+ func (s *Etcd) WatchTree(prefix string, stopCh <-chan struct{}) (<-chan []*KVPair, error)

+ type Initialize func(addrs []string, options *Config) (Store, error)

+ type KVPair struct

+ Key string

+ LastIndex uint64

+ Value []byte

+ type LockOptions struct

+ TTL time.Duration

+ Value []byte

+ type Locker interface

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

+ Unlock func() error

+ type Mock struct

+ Endpoints []string

+ Options *Config

+ func (s *Mock) AtomicDelete(key string, previous *KVPair) (bool, error)

+ func (s *Mock) AtomicPut(key string, value []byte, previous *KVPair, opts *WriteOptions) (bool, *KVPair, error)

+ func (s *Mock) Close()

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

+ func (s *Mock) DeleteTree(prefix string) error

+ func (s *Mock) Exists(key string) (bool, error)

+ func (s *Mock) Get(key string) (*KVPair, error)

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

+ func (s *Mock) NewLock(key string, options *LockOptions) (Locker, error)

+ func (s *Mock) Put(key string, value []byte, opts *WriteOptions) error

+ func (s *Mock) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, error)

+ func (s *Mock) WatchTree(prefix string, stopCh <-chan struct{}) (<-chan []*KVPair, error)

+ type MockLock struct

+ func (l *MockLock) Lock() (<-chan struct{}, error)

+ func (l *MockLock) Unlock() error

+ type Store interface

+ AtomicDelete func(key string, previous *KVPair) (bool, error)

+ AtomicPut func(key string, value []byte, previous *KVPair, options *WriteOptions) (bool, *KVPair, error)

+ Close func()

+ Delete func(key string) error

+ DeleteTree func(prefix string) error

+ Exists func(key string) (bool, error)

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

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

+ NewLock func(key string, options *LockOptions) (Locker, error)

+ Put func(key string, value []byte, options *WriteOptions) error

+ Watch func(key string, stopCh <-chan struct{}) (<-chan *KVPair, error)

+ WatchTree func(prefix string, stopCh <-chan struct{}) (<-chan []*KVPair, error)

+ func InitializeConsul(endpoints []string, options *Config) (Store, error)

+ func InitializeEtcd(addrs []string, options *Config) (Store, error)

+ func InitializeMock(endpoints []string, options *Config) (Store, error)

+ func InitializeZookeeper(endpoints []string, options *Config) (Store, error)

+ func NewStore(backend Backend, addrs []string, options *Config) (Store, error)

+ type WatchCallback func(entries ...*KVPair)

+ type WriteOptions struct

+ Ephemeral bool

+ Heartbeat time.Duration

+ type Zookeeper struct

+ func (s *Zookeeper) AtomicDelete(key string, previous *KVPair) (bool, error)

+ func (s *Zookeeper) AtomicPut(key string, value []byte, previous *KVPair, _ *WriteOptions) (bool, *KVPair, error)

+ func (s *Zookeeper) Close()

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

+ func (s *Zookeeper) DeleteTree(prefix string) error

+ func (s *Zookeeper) Exists(key string) (bool, error)

+ func (s *Zookeeper) Get(key string) (*KVPair, error)

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

+ func (s *Zookeeper) NewLock(key string, options *LockOptions) (Locker, error)

+ func (s *Zookeeper) Put(key string, value []byte, opts *WriteOptions) error

+ func (s *Zookeeper) Watch(key string, stopCh <-chan struct{}) (<-chan *KVPair, error)

+ func (s *Zookeeper) WatchTree(prefix string, stopCh <-chan struct{}) (<-chan []*KVPair, error)

v0.3.0-rc3

Jun 16, 2015

v0.3.0-rc2

Jun 5, 2015

v0.3.0-rc1

May 27, 2015