store

type EtcdStore struct {
	// mutex is used to synchronize client access
	*sync.Mutex
	// client is the Etcd client connection
	client.KeysAPI
	// timeout is the etcd client request timeout
	Timeout time.Duration
}

type KeyNotFound struct {
	Key string
	// contains filtered or unexported fields
}

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

type Store interface {
	// Get returns an io.Reader for key
	Get(key string) io.Reader
	// Delete removes the specified key. Set recurse to true to delete recursively
	Delete(key string, recurse bool) error
	// GetMulti retrieves all keys with prefix.  The io.Reader returns all values
	// concatenated back to back.  See the Example in the tests to show how to
	// use this with JSON data.  Lazy loaded and if any errors occur they are
	// propagated through the io.Readers Read().
	GetMulti(prefix string) io.Reader
	// GetMultiMap retrieves all keys with prefix.  The return is a map of keys to
	// io.Reader values. Error is propagated from underlying backend.
	GetMultiMap(prefix string) (map[string]io.Reader, error)
	// Set will store a key-value pair into the store.  If the ttl value is 0,
	// then the value will never timeout. The returned error will be nil on
	// success or come from the underlying implementation.
	Set(key string, value []byte, ttl time.Duration) error
	// Mkdir creates a directory or bucket with the specified path and ttl
	Mkdir(path string, ttl time.Duration) error
	// Keys returns all keys prefixed by prefix. error returned is specific to
	// underlying store implementation.
	Keys(prefix string) ([]string, error)
}