sessions

type BenchBatcher struct {
	// contains filtered or unexported fields
}

type DAO interface {
	PutSession(session *tree.IndexationSession) error
	ReadSession(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error)
	DeleteSession(session *tree.IndexationSession) error
	CleanSessions() error
}

type MemoryBatcher struct {
	// contains filtered or unexported fields
}

type SessionBatcher interface {
	Notify(topic string, msg interface{})
	Flush(ctx context.Context, dao index.DAO)
}

type SessionMemoryStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type StoredEvent struct {
	Topic     string
	Msg       interface{}
	EventTime time.Time
}