Lines Matching defs:store
65 type store struct { struct
66 ReadView
67 WriteView
69 cfg StoreConfig
72 mu sync.RWMutex
74 ci cindex.ConsistentIndexer
76 b backend.Backend
77 kvindex index
79 le lease.Lessor
84 revMu sync.RWMutex
86 currentRev int64
88 compactMainRev int64
90 fifoSched schedule.Scheduler
92 stopc chan struct{}
94 lg *zap.Logger
146 func (s *store) compactBarrier(ctx context.Context, ch chan struct{}) {
161 func (s *store) Hash() (hash uint32, revision int64, err error) {
172 func (s *store) HashByRev(rev int64) (hash uint32, currentRev int64, compactRev int64, err error) {
225 func (s *store) updateCompactRev(rev int64) (<-chan struct{}, error) {
256 func (s *store) compact(trace *traceutil.Trace, rev int64) (<-chan struct{}, error) {
278 func (s *store) compactLockfree(rev int64) (<-chan struct{}, error) {
287 func (s *store) Compact(trace *traceutil.Trace, rev int64) (<-chan struct{}, error) {
312 func (s *store) Commit() {
323 func (s *store) Restore(b backend.Backend) error {
342 func (s *store) restore() error {
509 func (s *store) Close() error {
515 func (s *store) saveIndex(tx backend.BatchTx) {
521 func (s *store) ConsistentIndex() uint64 {
528 func (s *store) setupMetricsReporter() {