session

Documentation

Index

• Constants
• Variables
• type Session
  • 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, start, end int64, fs *v1.Filters) (arrow.Record, error)
  • func (s *Session) Start(ctx context.Context)

Constants

const (
	DefaultSession = 30 * time.Minute
	// To make sure we always have fresh data for current visitors
	DefaultFlushInterval = time.Minute
)

Variables

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

Types

type Session

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

func New

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

func (*Session) Append

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

func (*Session) Close

func (s *Session) Close()

func (*Session) Flush

func (s *Session) Flush()

func (*Session) Persist

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

func (*Session) Restore

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

func (*Session) Scan

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

func (*Session) Start

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