session

package
v0.0.67 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 21, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

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

Variables

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

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL