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

Apr 21, 2020

Changes in this version

+ func Register(name string, initFunc InitFunc)

+ type DataVersion int64

+ type DistLock struct

+ func NewDistLock(ctx context.Context, client *clientv3.Client, key string, ...) *DistLock

+ func (dl *DistLock) KeepAliveOnce()

+ func (dl *DistLock) Lock() (err error)

+ func (dl *DistLock) TryLock() (bool, error)

+ func (dl *DistLock) Unlock() error

+ type EtcdStore struct

+ func (store *EtcdStore) Create(ctx context.Context, key string, value []byte) error

+ func (store *EtcdStore) CreateWithTTL(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ func (store *EtcdStore) Delete(ctx context.Context, key string) error

+ func (store *EtcdStore) Get(ctx context.Context, key string) ([]byte, error)

+ func (store *EtcdStore) KeepAlive(ctx context.Context, key string, value []byte, ttl time.Duration) (<-chan *clientv3.LeaseKeepAliveResponse, error)

+ func (store *EtcdStore) NewIDGenerate(ctx context.Context, key string, base int64, timeout time.Duration) (int64, error)

+ func (store *EtcdStore) NewLock(ctx context.Context, key string, timeout time.Duration) *DistLock

+ func (store *EtcdStore) PrefixScan(ctx context.Context, prefix string) ([][]byte, [][]byte, error)

+ func (store *EtcdStore) Put(ctx context.Context, key string, value []byte) error

+ func (store *EtcdStore) PutWithLeaseId(ctx context.Context, key string, value []byte, ttl time.Duration, ...) error

+ func (store *EtcdStore) STM(ctx context.Context, apply func(stm concurrency.STM) error) error

+ func (store *EtcdStore) Update(ctx context.Context, key string, value []byte) error

+ func (store *EtcdStore) WatchPrefix(ctx context.Context, key string) (clientv3.WatchChan, error)

+ type InitFunc func(serverAddr []string) (Store, error)

+ type Store interface

+ Create func(ctx context.Context, key string, value []byte) error

+ CreateWithTTL func(ctx context.Context, key string, value []byte, ttl time.Duration) error

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) ([]byte, error)

+ KeepAlive func(ctx context.Context, key string, value []byte, ttl time.Duration) (<-chan *clientv3.LeaseKeepAliveResponse, error)

+ NewIDGenerate func(ctx context.Context, key string, base int64, timeout time.Duration) (int64, error)

+ NewLock func(ctx context.Context, key string, timeout time.Duration) *DistLock

+ PrefixScan func(ctx context.Context, prefix string) ([][]byte, [][]byte, error)

+ Put func(ctx context.Context, key string, value []byte) error

+ PutWithLeaseId func(ctx context.Context, key string, value []byte, ttl time.Duration, ...) error

+ STM func(ctx context.Context, apply func(stm concurrency.STM) error) error

+ Update func(ctx context.Context, key string, value []byte) error

+ WatchPrefix func(ctx context.Context, key string) (clientv3.WatchChan, error)

+ func NewEtcdStore(serverAddrs []string) (Store, error)

+ func OpenStore(implementation string, serverAddress []string) (Store, error)

+ type WatcherJob interface

+ Delete func(event *clientv3.Event)

+ Put func(event *clientv3.Event)

+ Start func()

+ Stop func()

Incompatible versions in this module

v3.2.7+incompatible

Apr 28, 2021

v3.2.5+incompatible

Dec 16, 2020

v3.2.0+incompatible

Sep 7, 2020

v3.1.0+incompatible

May 29, 2020