Versions in this module Expand all Collapse all v0 v0.2.0 Dec 23, 2013 Changes in this version + const CompareAndSwap + const CompareAndSwapFail + const CompareAndSwapSuccess + const Create + const CreateFail + const CreateSuccess + const Delete + const DeleteFail + const DeleteSuccess + const Expire + const ExpireCount + const Get + const GetFail + const GetSuccess + const Set + const SetFail + const SetSuccess + const Update + const UpdateFail + const UpdateSuccess + var Permanent time.Time + func MaxVersion() int + func MinVersion() int + func RegisterCommandFactory(factory CommandFactory) + func TTL(duration string) (time.Time, error) + type CommandFactory interface + CreateCompareAndSwapCommand func(key string, value string, prevValue string, prevIndex uint64, ...) raft.Command + CreateCreateCommand func(key string, dir bool, value string, expireTime time.Time, unique bool) raft.Command + CreateDeleteCommand func(key string, dir, recursive bool) raft.Command + CreateSetCommand func(key string, dir bool, value string, expireTime time.Time) raft.Command + CreateSyncCommand func(now time.Time) raft.Command + CreateUpdateCommand func(key string, value string, expireTime time.Time) raft.Command + CreateUpgradeCommand func() raft.Command + Version func() int + func GetCommandFactory(version int) CommandFactory + type Event struct + Action string + Node *NodeExtern + func (e *Event) Index() uint64 + func (e *Event) IsCreated() bool + func (event *Event) Response(currentIndex uint64) interface{} + type EventHistory struct + LastIndex uint64 + Queue eventQueue + StartIndex uint64 + type NodeExtern struct + CreatedIndex uint64 + Dir bool + Expiration *time.Time + Key string + ModifiedIndex uint64 + Nodes NodeExterns + PrevValue string + TTL int64 + Value string + type NodeExterns []NodeExtern + func (ns NodeExterns) Len() int + func (ns NodeExterns) Less(i, j int) bool + func (ns NodeExterns) Swap(i, j int) + type Stats struct + CompareAndSwapFail uint64 + CompareAndSwapSuccess uint64 + CreateFail uint64 + CreateSuccess uint64 + DeleteFail uint64 + DeleteSuccess uint64 + ExpireCount uint64 + GetFail uint64 + GetSuccess uint64 + SetFail uint64 + SetSuccess uint64 + UpdateFail uint64 + UpdateSuccess uint64 + Watchers uint64 + func (s *Stats) Inc(field int) + func (s *Stats) TotalReads() uint64 + func (s *Stats) TotalTranscations() uint64 type Store + func New() Store + CommandFactory func() CommandFactory + CompareAndSwap func(nodePath string, prevValue string, prevIndex uint64, value string, ...) (*Event, error) + Create func(nodePath string, dir bool, value string, unique bool, expireTime time.Time) (*Event, error) + DeleteExpiredKeys func(cutoff time.Time) + JsonStats func() []byte + TotalTransactions func() uint64 + Update func(nodePath string, newValue string, expireTime time.Time) (*Event, error) + Version func() int + Watch func(prefix string, recursive bool, sinceIndex uint64) (<-chan *Event, error) v0.2.0-rc4 Dec 23, 2013 v0.2.0-rc3 Dec 16, 2013 v0.2.0-rc2 Dec 6, 2013 v0.2.0-rc1 Nov 14, 2013 v0.2.0-rc0 Oct 17, 2013 v0.1.2 Oct 10, 2013 v0.1.1 Aug 19, 2013 Changes in this version type Store + func (s *Store) TotalWrites() uint64 v0.1.0 Aug 11, 2013 Changes in this version + var PERMANENT = time.Unix(0, 0) + func CheckKeyword(key string) bool + func GenKeys(num int, depth int) []string + type EtcdStats struct + Deletes uint64 + Gets uint64 + Sets uint64 + TestAndSets uint64 + type Keyword string + func (e Keyword) Error() string + type ListNode struct + Key string + Type string + Value string + type Node struct + ExpireTime time.Time + Value string + type NotFile string + func (e NotFile) Error() string + type NotFoundError string + func (e NotFoundError) Error() string + type Response struct + Action string + Dir bool + Expiration *time.Time + Index uint64 + Key string + NewKey bool + PrevValue string + TTL int64 + Value string + type Store struct + BasicStats EtcdStats + Index uint64 + ResponseCurrSize uint + ResponseMap map[string]*Response + ResponseMaxSize int + ResponseStartIndex uint64 + Tree *tree + func CreateStore(max int) *Store + func (s *Store) AddWatcher(prefix string, watcher *Watcher, sinceIndex uint64) error + func (s *Store) Delete(key string, index uint64) ([]byte, error) + func (s *Store) Get(key string) ([]byte, error) + func (s *Store) RawGet(key string) ([]*Response, error) + func (s *Store) Recovery(state []byte) error + func (s *Store) Save() ([]byte, error) + func (s *Store) Set(key string, value string, expireTime time.Time, index uint64) ([]byte, error) + func (s *Store) SetMessager(messager chan<- string) + func (s *Store) Stats() []byte + func (s *Store) TestAndSet(key string, prevValue string, value string, expireTime time.Time, index uint64) ([]byte, error) + type TestFail string + func (e TestFail) Error() string + type Watcher struct + C chan *Response + func NewWatcher() *Watcher + type WatcherHub struct
Go to main page