session

Documentation

Index

• Constants
• func With(ctx context.Context, s *Session) context.Context
• type Session
  • func Get(ctx context.Context) *Session
  • func New(mem memory.Allocator, resource string, storage db.Storage, indexer index.Index, ...) *Session
  • func (s *Session) Close()
  • func (s *Session) Flush()
  • func (s *Session) Queue(ctx context.Context, req *v1.Event)
  • 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
)

Functions

func With

func With(ctx context.Context, s *Session) context.Context

Types

type Session

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

func Get

func Get(ctx context.Context) *Session

func New

func New(mem memory.Allocator, resource string, storage db.Storage,
	indexer index.Index,
	primary index.Primary, opts ...lsm.Option) *Session

func (*Session) Close

func (s *Session) Close()

func (*Session) Flush

func (s *Session) Flush()

func (*Session) Queue

func (s *Session) Queue(ctx context.Context, req *v1.Event)

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)