state

package

Go to main page

Versions in this module

v0

v0.6.4

Mar 16, 2016

Changes in this version

type PrefixWatch

+ func (w *PrefixWatch) Clear(notifyCh chan struct{})

+ func (w *PrefixWatch) Wait(notifyCh chan struct{})

+ type PrefixWatchManager struct

+ func NewPrefixWatchManager() *PrefixWatchManager

+ func (w *PrefixWatchManager) Clear(prefix string, notifyCh chan struct{})

+ func (w *PrefixWatchManager) NewPrefixWatch(prefix string) Watch

+ func (w *PrefixWatchManager) Notify(prefix string, subtree bool)

+ func (w *PrefixWatchManager) Wait(prefix string, notifyCh chan struct{})

+ type PreparedQueryIndex struct

+ func (*PreparedQueryIndex) FromObject(obj interface{}) (bool, []byte, error)

+ func (*PreparedQueryIndex) PrefixFromArgs(args ...interface{}) ([]byte, error)

+ func (p *PreparedQueryIndex) FromArgs(args ...interface{}) ([]byte, error)

type StateStore

+ func (s *StateStore) PreparedQueryResolve(queryIDOrName string) (uint64, *structs.PreparedQuery, error)

v0.6.4-rc3

Mar 10, 2016

v0.6.4-rc2

Mar 9, 2016

v0.6.4-rc1

Mar 7, 2016

v0.6.3

Jan 14, 2016

v0.6.2

Jan 14, 2016

v0.6.1

Jan 6, 2016

v0.6.0

Dec 3, 2015

Changes in this version

+ var ErrMissingACLID = errors.New("Missing ACL ID")

+ var ErrMissingNode = errors.New("Missing node registration")

+ var ErrMissingQueryID = errors.New("Missing Query ID")

+ var ErrMissingService = errors.New("Missing service registration")

+ var ErrMissingSessionID = errors.New("Missing session ID")

+ type Delay struct

+ func NewDelay() *Delay

+ func (d *Delay) GetExpiration(key string) time.Time

+ func (d *Delay) SetExpiration(key string, now time.Time, delay time.Duration)

+ type DumbWatchManager struct

+ func NewDumbWatchManager(tableWatches map[string]*FullTableWatch) *DumbWatchManager

+ func (d *DumbWatchManager) Arm(table string)

+ func (d *DumbWatchManager) Notify()

+ type FullTableWatch struct

+ func NewFullTableWatch() *FullTableWatch

+ func (w *FullTableWatch) Clear(notifyCh chan struct{})

+ func (w *FullTableWatch) Notify()

+ func (w *FullTableWatch) Wait(notifyCh chan struct{})

+ type Graveyard struct

+ func NewGraveyard(gc *TombstoneGC) *Graveyard

+ func (g *Graveyard) DumpTxn(tx *memdb.Txn) (memdb.ResultIterator, error)

+ func (g *Graveyard) GetMaxIndexTxn(tx *memdb.Txn, prefix string) (uint64, error)

+ func (g *Graveyard) InsertTxn(tx *memdb.Txn, key string, idx uint64) error

+ func (g *Graveyard) ReapTxn(tx *memdb.Txn, idx uint64) error

+ func (g *Graveyard) RestoreTxn(tx *memdb.Txn, stone *Tombstone) error

+ type IndexEntry struct

+ Key string

+ Value uint64

+ type MultiWatch struct

+ func NewMultiWatch(watches ...Watch) *MultiWatch

+ func (w *MultiWatch) Clear(notifyCh chan struct{})

+ func (w *MultiWatch) Wait(notifyCh chan struct{})

+ type NotifyGroup struct

+ func (n *NotifyGroup) Clear(ch chan struct{})

+ func (n *NotifyGroup) Notify()

+ func (n *NotifyGroup) Wait(ch chan struct{})

+ func (n *NotifyGroup) WaitCh() chan struct{}

+ type PrefixWatch struct

+ func NewPrefixWatch() *PrefixWatch

+ func (w *PrefixWatch) GetSubwatch(prefix string) *NotifyGroup

+ func (w *PrefixWatch) Notify(prefix string, subtree bool)

+ type StateRestore struct

+ func (s *StateRestore) ACL(acl *structs.ACL) error

+ func (s *StateRestore) Abort()

+ func (s *StateRestore) Commit()

+ func (s *StateRestore) Coordinates(idx uint64, updates structs.Coordinates) error

+ func (s *StateRestore) KVS(entry *structs.DirEntry) error

+ func (s *StateRestore) PreparedQuery(query *structs.PreparedQuery) error

+ func (s *StateRestore) Registration(idx uint64, req *structs.RegisterRequest) error

+ func (s *StateRestore) Session(sess *structs.Session) error

+ func (s *StateRestore) Tombstone(stone *Tombstone) error

+ type StateSnapshot struct

+ func (s *StateSnapshot) ACLs() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) Checks(node string) (memdb.ResultIterator, error)

+ func (s *StateSnapshot) Close()

+ func (s *StateSnapshot) Coordinates() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) KVs() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) LastIndex() uint64

+ func (s *StateSnapshot) Nodes() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) PreparedQueries() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) Services(node string) (memdb.ResultIterator, error)

+ func (s *StateSnapshot) Sessions() (memdb.ResultIterator, error)

+ func (s *StateSnapshot) Tombstones() (memdb.ResultIterator, error)

+ type StateStore struct

+ func NewStateStore(gc *TombstoneGC) (*StateStore, error)

+ func (s *StateStore) ACLDelete(idx uint64, aclID string) error

+ func (s *StateStore) ACLGet(aclID string) (uint64, *structs.ACL, error)

+ func (s *StateStore) ACLList() (uint64, structs.ACLs, error)

+ func (s *StateStore) ACLSet(idx uint64, acl *structs.ACL) error

+ func (s *StateStore) CheckServiceNodes(serviceName string) (uint64, structs.CheckServiceNodes, error)

+ func (s *StateStore) CheckServiceTagNodes(serviceName, tag string) (uint64, structs.CheckServiceNodes, error)

+ func (s *StateStore) ChecksInState(state string) (uint64, structs.HealthChecks, error)

+ func (s *StateStore) CoordinateBatchUpdate(idx uint64, updates structs.Coordinates) error

+ func (s *StateStore) CoordinateGetRaw(node string) (*coordinate.Coordinate, error)

+ func (s *StateStore) Coordinates() (uint64, structs.Coordinates, error)

+ func (s *StateStore) DeleteCheck(idx uint64, node, id string) error

+ func (s *StateStore) DeleteNode(idx uint64, nodeID string) error

+ func (s *StateStore) DeleteService(idx uint64, nodeID, serviceID string) error

+ func (s *StateStore) EnsureCheck(idx uint64, hc *structs.HealthCheck) error

+ func (s *StateStore) EnsureNode(idx uint64, node *structs.Node) error

+ func (s *StateStore) EnsureRegistration(idx uint64, req *structs.RegisterRequest) error

+ func (s *StateStore) EnsureService(idx uint64, node string, svc *structs.NodeService) error

+ func (s *StateStore) GetKVSWatch(prefix string) Watch

+ func (s *StateStore) GetNode(id string) (uint64, *structs.Node, error)

+ func (s *StateStore) GetQueryWatch(method string) Watch

+ func (s *StateStore) KVSDelete(idx uint64, key string) error

+ func (s *StateStore) KVSDeleteCAS(idx, cidx uint64, key string) (bool, error)

+ func (s *StateStore) KVSDeleteTree(idx uint64, prefix string) error

+ func (s *StateStore) KVSGet(key string) (uint64, *structs.DirEntry, error)

+ func (s *StateStore) KVSList(prefix string) (uint64, structs.DirEntries, error)

+ func (s *StateStore) KVSListKeys(prefix, sep string) (uint64, []string, error)

+ func (s *StateStore) KVSLock(idx uint64, entry *structs.DirEntry) (bool, error)

+ func (s *StateStore) KVSLockDelay(key string) time.Time

+ func (s *StateStore) KVSSet(idx uint64, entry *structs.DirEntry) error

+ func (s *StateStore) KVSSetCAS(idx uint64, entry *structs.DirEntry) (bool, error)

+ func (s *StateStore) KVSUnlock(idx uint64, entry *structs.DirEntry) (bool, error)

+ func (s *StateStore) NodeChecks(nodeID string) (uint64, structs.HealthChecks, error)

+ func (s *StateStore) NodeDump() (uint64, structs.NodeDump, error)

+ func (s *StateStore) NodeInfo(node string) (uint64, structs.NodeDump, error)

+ func (s *StateStore) NodeServices(nodeID string) (uint64, *structs.NodeServices, error)

+ func (s *StateStore) NodeSessions(nodeID string) (uint64, structs.Sessions, error)

+ func (s *StateStore) Nodes() (uint64, structs.Nodes, error)

+ func (s *StateStore) PreparedQueryDelete(idx uint64, queryID string) error

+ func (s *StateStore) PreparedQueryGet(queryID string) (uint64, *structs.PreparedQuery, error)

+ func (s *StateStore) PreparedQueryList() (uint64, structs.PreparedQueries, error)

+ func (s *StateStore) PreparedQueryLookup(queryIDOrName string) (uint64, *structs.PreparedQuery, error)

+ func (s *StateStore) PreparedQuerySet(idx uint64, query *structs.PreparedQuery) error

+ func (s *StateStore) ReapTombstones(index uint64) error

+ func (s *StateStore) Restore() *StateRestore

+ func (s *StateStore) ServiceChecks(serviceName string) (uint64, structs.HealthChecks, error)

+ func (s *StateStore) ServiceNodes(serviceName string) (uint64, structs.ServiceNodes, error)

+ func (s *StateStore) ServiceTagNodes(service, tag string) (uint64, structs.ServiceNodes, error)

+ func (s *StateStore) Services() (uint64, structs.Services, error)

+ func (s *StateStore) SessionCreate(idx uint64, sess *structs.Session) error

+ func (s *StateStore) SessionDestroy(idx uint64, sessionID string) error

+ func (s *StateStore) SessionGet(sessionID string) (uint64, *structs.Session, error)

+ func (s *StateStore) SessionList() (uint64, structs.Sessions, error)

+ func (s *StateStore) Snapshot() *StateSnapshot

+ type Tombstone struct

+ Index uint64

+ Key string

+ type TombstoneGC struct

+ func NewTombstoneGC(ttl, granularity time.Duration) (*TombstoneGC, error)

+ func (t *TombstoneGC) ExpireCh() <-chan uint64

+ func (t *TombstoneGC) Hint(index uint64)

+ func (t *TombstoneGC) PendingExpiration() bool

+ func (t *TombstoneGC) SetEnabled(enabled bool)

+ type Watch interface

+ Clear func(notifyCh chan struct{})

+ Wait func(notifyCh chan struct{})

v0.6.0-rc2

Nov 18, 2015

v0.6.0-rc1

Oct 29, 2015

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL