state

package

Go to main page

Versions in this module

v0

v0.8.4

Jun 9, 2017

v0.8.3

May 12, 2017

v0.8.2

May 9, 2017

Changes in this version

+ type Restore struct

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

+ func (s *Restore) Abort()

+ func (s *Restore) Autopilot(config *structs.AutopilotConfig) error

+ func (s *Restore) Commit()

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

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

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

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

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

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

+ type Snapshot struct

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

+ func (s *Snapshot) Autopilot() (*structs.AutopilotConfig, error)

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

+ func (s *Snapshot) Close()

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

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

+ func (s *Snapshot) LastIndex() uint64

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

+ func (s *Snapshot) PreparedQueries() (structs.PreparedQueries, error)

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

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

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

+ type Store struct

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

+ func (s *Store) ACLGet(ws memdb.WatchSet, aclID string) (uint64, *structs.ACL, error)

+ func (s *Store) ACLList(ws memdb.WatchSet) (uint64, structs.ACLs, error)

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

+ func (s *Store) Abandon()

+ func (s *Store) AbandonCh() <-chan struct{}

+ func (s *Store) AutopilotCASConfig(idx, cidx uint64, config *structs.AutopilotConfig) (bool, error)

+ func (s *Store) AutopilotConfig() (uint64, *structs.AutopilotConfig, error)

+ func (s *Store) AutopilotSetConfig(idx uint64, config *structs.AutopilotConfig) error

+ func (s *Store) CheckServiceNodes(ws memdb.WatchSet, serviceName string) (uint64, structs.CheckServiceNodes, error)

+ func (s *Store) CheckServiceTagNodes(ws memdb.WatchSet, serviceName, tag string) (uint64, structs.CheckServiceNodes, error)

+ func (s *Store) ChecksInState(ws memdb.WatchSet, state string) (uint64, structs.HealthChecks, error)

+ func (s *Store) ChecksInStateByNodeMeta(ws memdb.WatchSet, state string, filters map[string]string) (uint64, structs.HealthChecks, error)

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

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

+ func (s *Store) Coordinates(ws memdb.WatchSet) (uint64, structs.Coordinates, error)

+ func (s *Store) DeleteCheck(idx uint64, node string, checkID types.CheckID) error

+ func (s *Store) DeleteNode(idx uint64, nodeName string) error

+ func (s *Store) DeleteService(idx uint64, nodeName, serviceID string) error

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

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

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

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

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

+ func (s *Store) GetNodeID(id types.NodeID) (uint64, *structs.Node, error)

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

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

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

+ func (s *Store) KVSGet(ws memdb.WatchSet, key string) (uint64, *structs.DirEntry, error)

+ func (s *Store) KVSList(ws memdb.WatchSet, prefix string) (uint64, structs.DirEntries, error)

+ func (s *Store) KVSListKeys(ws memdb.WatchSet, prefix, sep string) (uint64, []string, error)

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

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

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

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

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

+ func (s *Store) NodeCheck(nodeName string, checkID types.CheckID) (uint64, *structs.HealthCheck, error)

+ func (s *Store) NodeChecks(ws memdb.WatchSet, nodeName string) (uint64, structs.HealthChecks, error)

+ func (s *Store) NodeDump(ws memdb.WatchSet) (uint64, structs.NodeDump, error)

+ func (s *Store) NodeInfo(ws memdb.WatchSet, node string) (uint64, structs.NodeDump, error)

+ func (s *Store) NodeService(nodeName string, serviceID string) (uint64, *structs.NodeService, error)

+ func (s *Store) NodeServices(ws memdb.WatchSet, nodeNameOrID string) (uint64, *structs.NodeServices, error)

+ func (s *Store) NodeSessions(ws memdb.WatchSet, nodeID string) (uint64, structs.Sessions, error)

+ func (s *Store) Nodes(ws memdb.WatchSet) (uint64, structs.Nodes, error)

+ func (s *Store) NodesByMeta(ws memdb.WatchSet, filters map[string]string) (uint64, structs.Nodes, error)

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

+ func (s *Store) PreparedQueryGet(ws memdb.WatchSet, queryID string) (uint64, *structs.PreparedQuery, error)

+ func (s *Store) PreparedQueryList(ws memdb.WatchSet) (uint64, structs.PreparedQueries, error)

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

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

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

+ func (s *Store) Restore() *Restore

+ func (s *Store) ServiceChecks(ws memdb.WatchSet, serviceName string) (uint64, structs.HealthChecks, error)

+ func (s *Store) ServiceChecksByNodeMeta(ws memdb.WatchSet, serviceName string, filters map[string]string) (uint64, structs.HealthChecks, error)

+ func (s *Store) ServiceNodes(ws memdb.WatchSet, serviceName string) (uint64, structs.ServiceNodes, error)

+ func (s *Store) ServiceTagNodes(ws memdb.WatchSet, service string, tag string) (uint64, structs.ServiceNodes, error)

+ func (s *Store) Services(ws memdb.WatchSet) (uint64, structs.Services, error)

+ func (s *Store) ServicesByNodeMeta(ws memdb.WatchSet, filters map[string]string) (uint64, structs.Services, error)

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

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

+ func (s *Store) SessionGet(ws memdb.WatchSet, sessionID string) (uint64, *structs.Session, error)

+ func (s *Store) SessionList(ws memdb.WatchSet) (uint64, structs.Sessions, error)

+ func (s *Store) Snapshot() *Snapshot

+ func (s *Store) TxnRO(ops structs.TxnOps) (structs.TxnResults, structs.TxnErrors)

+ func (s *Store) TxnRW(idx uint64, ops structs.TxnOps) (structs.TxnResults, structs.TxnErrors)

v0.8.1

Apr 17, 2017

v0.8.0

Apr 5, 2017

Changes in this version

type StateRestore

+ func (s *StateRestore) Autopilot(config *structs.AutopilotConfig) error

type StateSnapshot

+ func (s *StateSnapshot) Autopilot() (*structs.AutopilotConfig, error)

type StateStore

+ func (s *StateStore) AutopilotCASConfig(idx, cidx uint64, config *structs.AutopilotConfig) (bool, error)

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

+ func (s *StateStore) AutopilotSetConfig(idx uint64, config *structs.AutopilotConfig) error

v0.8.0-rc1

Mar 27, 2017

v0.7.5

Feb 15, 2017

v0.7.4

Feb 6, 2017

Changes in this version

type StateStore

+ func (s *StateStore) GetNodeID(id types.NodeID) (uint64, *structs.Node, error)

v0.7.3

Jan 26, 2017

Changes in this version

type StateStore

+ func (s *StateStore) Abandon()

+ func (s *StateStore) AbandonCh() <-chan struct{}

+ func (s *StateStore) ChecksInStateByNodeMeta(ws memdb.WatchSet, state string, filters map[string]string) (uint64, structs.HealthChecks, error)

+ func (s *StateStore) NodesByMeta(ws memdb.WatchSet, filters map[string]string) (uint64, structs.Nodes, error)

+ func (s *StateStore) ServiceChecksByNodeMeta(ws memdb.WatchSet, serviceName string, filters map[string]string) (uint64, structs.HealthChecks, error)

+ func (s *StateStore) ServicesByNodeMeta(ws memdb.WatchSet, filters map[string]string) (uint64, structs.Services, error)

v0.7.2

Dec 19, 2016

Changes in this version

type StateStore

+ func (s *StateStore) NodeCheck(nodeID string, checkID types.CheckID) (uint64, *structs.HealthCheck, error)

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

v0.7.2-rc1

Dec 15, 2016

v0.7.1

Nov 10, 2016

v0.7.0

Sep 14, 2016

Changes in this version

type StateStore

+ func (s *StateStore) TxnRO(ops structs.TxnOps) (structs.TxnResults, structs.TxnErrors)

+ func (s *StateStore) TxnRW(idx uint64, ops structs.TxnOps) (structs.TxnResults, structs.TxnErrors)

v0.7.0-rc2

Aug 31, 2016

v0.7.0-rc1

Aug 17, 2016

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