events

Documentation

Index

• Variables
• func Clone(e *v1.Data) *v1.Data
• func Hit(e *v1.Data)
• func List() *v1.Data_List
• func Now() func() time.Time
• func One() *v1.Data
• func Parse(log *slog.Logger, g *geo.Geo, req *v1.Event) *v1.Data
• func Put(ls *v1.Data_List)
• func PutOne(d *v1.Data)
• func SampleRecord(opts ...SampleOption) arrow.Record
• func Samples(opts ...SampleOption) *v1.Data_List
• func Update(fromSession *v1.Data, event *v1.Data)
• type Builder
  • func New(mem memory.Allocator, metadata ...map[string]string) *Builder
  • func (b *Builder) Len() int
  • func (b *Builder) NewRecord() arrow.Record
  • func (b *Builder) Release()
  • func (b *Builder) Write(list *v1.Data_List) arrow.Record
  • func (b *Builder) WriteData(data *v1.Data)
• type SampleOption
  • func WithNow(now func() time.Time) SampleOption
  • func WithStep(step time.Duration) SampleOption

Variables

var False = ptr(false)

var Mapping, Schema = mapping()

var True = ptr(true)

Functions

func Clone

func Clone(e *v1.Data) *v1.Data

func Hit

func Hit(e *v1.Data)

func List

func List() *v1.Data_List

func Now

func Now() func() time.Time

func One

func One() *v1.Data

func Parse

func Parse(log *slog.Logger, g *geo.Geo, req *v1.Event) *v1.Data

func Put

func Put(ls *v1.Data_List)

func PutOne

func PutOne(d *v1.Data)

func SampleRecord

func SampleRecord(opts ...SampleOption) arrow.Record

func Samples

func Samples(opts ...SampleOption) *v1.Data_List

func Update

func Update(fromSession *v1.Data, event *v1.Data)

Types

type Builder

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

func New

func New(mem memory.Allocator, metadata ...map[string]string) *Builder

func (*Builder) Len

func (b *Builder) Len() int

func (*Builder) NewRecord

func (b *Builder) NewRecord() arrow.Record

func (*Builder) Release

func (b *Builder) Release()

func (*Builder) Write

func (b *Builder) Write(list *v1.Data_List) arrow.Record

func (*Builder) WriteData

func (b *Builder) WriteData(data *v1.Data)

type SampleOption

type SampleOption func(*sampleOptions)

func WithNow

func WithNow(now func() time.Time) SampleOption

func WithStep

func WithStep(step time.Duration) SampleOption