session

Mar 3, 2024

Changes in this version

+ const DefaultFlushInterval

+ const DefaultSession

+ var ErrResourceNotFound = errors.New("session: Resource not found")

+ type Session struct

+ func New(mem memory.Allocator, tenants *tenant.Tenants, indexer index.Index, ...) *Session

+ func (s *Session) Append(e *v1.Data)

+ func (s *Session) Close()

+ func (s *Session) Flush()

+ func (s *Session) Persist(onCompact lsm.CompactCallback)

+ func (s *Session) Restore(source lsm.RecordSource) error

+ func (s *Session) Scan(ctx context.Context, tenantId string, start, end int64, fs *v1.Filters) (arrow.Record, error)

+ func (s *Session) Start(ctx context.Context)