blockingquery

Aug 14, 2023

Changes in this version

+ var ErrNotChanged = fmt.Errorf("data did not change for query")

+ var ErrNotFound = fmt.Errorf("no data found for query")

+ func Query(fsmServer FSMServer, requestOpts RequestOptions, responseMeta ResponseMeta, ...) error

+ type FSMServer interface

+ ConsistentRead func() error

+ DecrementBlockingQueries func() uint64

+ GetShutdownChannel func() chan struct{}

+ GetState func() *state.Store

+ IncrementBlockingQueries func() uint64

+ RPCQueryTimeout func(time.Duration) time.Duration

+ SetQueryMeta func(ResponseMeta, string)

+ type QueryFn func(memdb.WatchSet, *state.Store) error

+ type RequestOptions interface

+ GetMaxQueryTime func() (time.Duration, error)

+ GetMinQueryIndex func() uint64

+ GetRequireConsistent func() bool

+ GetToken func() string

+ type ResponseMeta interface

+ GetIndex func() uint64

+ SetIndex func(uint64)

+ SetKnownLeader func(bool)

+ SetLastContact func(time.Duration)

+ SetResultsFilteredByACLs func(bool)