Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + type BenchBatcher struct + func (bb *BenchBatcher) Flush(ctx context.Context, dao index.DAO) + func (bb *BenchBatcher) Notify(topic string, msg interface{}) + func (bb *BenchBatcher) UpdateMPath(path mtree.MPath, deltaSize int64) + type DAO interface + CleanSessions func() error + DeleteSession func(session *tree.IndexationSession) error + PutSession func(session *tree.IndexationSession) error + ReadSession func(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error) + type MemoryBatcher struct + func (b *MemoryBatcher) Flush(ctx context.Context, dao index.DAO) + func (b *MemoryBatcher) Notify(topic string, msg interface{}) + func (b *MemoryBatcher) UpdateMPath(path mtree.MPath, deltaSize int64) + type SessionBatcher interface + Flush func(ctx context.Context, dao index.DAO) + Notify func(topic string, msg interface{}) + UpdateMPath func(path mtree.MPath, deltaSize int64) + func GetBenchSessionBatcher(b SessionBatcher) SessionBatcher + type SessionMemoryStore struct + func NewSessionMemoryStore() *SessionMemoryStore + func (s *SessionMemoryStore) CleanSessions() error + func (s *SessionMemoryStore) DeleteSession(session *tree.IndexationSession) error + func (s *SessionMemoryStore) PutSession(session *tree.IndexationSession) error + func (s *SessionMemoryStore) ReadSession(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error) + type StoredEvent struct + EventTime time.Time + Msg interface{} + Topic string Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020
Go to main page