Versions in this module Expand all Collapse all v0 v0.4.9 Mar 31, 2015 Changes in this version type CommandFactory + CreateGetCommand func(key string, recursive, sorted bool) raft.Command v0.4.5 Jul 8, 2014 Changes in this version + const CompareAndDelete + const CompareAndDeleteFail + const CompareAndDeleteSuccess + const CompareAndSwap + const CompareAndSwapFail + const CompareAndSwapSuccess + const CompareIndexNotMatch + const CompareMatch + const CompareNotMatch + const CompareValueNotMatch + 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 + CreateCompareAndDeleteCommand func(key string, prevValue string, prevIndex uint64) raft.Command + 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 + PrevNode *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 + 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 Response struct + Action string + Dir bool + Expiration *time.Time + Index uint64 + Key string + NewKey bool + PrevValue *string + TTL int64 + Value *string + type Stats struct + CompareAndDeleteFail uint64 + CompareAndDeleteSuccess uint64 + 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 interface + CommandFactory func() CommandFactory + CompareAndDelete func(nodePath string, prevValue string, prevIndex uint64) (*Event, error) + 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) + Delete func(nodePath string, recursive, dir bool) (*Event, error) + DeleteExpiredKeys func(cutoff time.Time) + Get func(nodePath string, recursive, sorted bool) (*Event, error) + Index func() uint64 + JsonStats func() []byte + Recovery func(state []byte) error + Save func() ([]byte, error) + Set func(nodePath string, dir bool, value string, expireTime time.Time) (*Event, error) + TotalTransactions func() uint64 + Update func(nodePath string, newValue string, expireTime time.Time) (*Event, error) + Version func() int + Watch func(prefix string, recursive, stream bool, sinceIndex uint64) (*Watcher, error) + func New() Store + type Watcher struct + EventChan chan *Event + func (w *Watcher) Remove() v0.2.0-rc2 Dec 6, 2013 Incompatible versions in this module v2.2.0-rc.0+incompatible Aug 28, 2015 v2.2.0-alpha.1+incompatible Aug 13, 2015 v2.2.0-alpha.0+incompatible Aug 13, 2015 v2.0.13+incompatible Jun 25, 2015
Go to main page