entry

Documentation

Index

• Variables
• func Context(ctx ...context.Context) context.Context
• func Fields() (f []arrow.Field)
• func NewFileReader(r parquet.ReaderAtSeeker) *file.Reader
• func NewFileWriter(w io.Writer) *file.Writer
• type Entry
  • func NewEntry() *Entry
  • func (e *Entry) Clone() *Entry
  • func (e *Entry) Hit()
  • func (e *Entry) Release()
  • func (s *Entry) Update(e *Entry)
• type MultiEntry
  • func NewMulti() *MultiEntry
  • func (m *MultiEntry) Append(e *Entry)
  • func (m *MultiEntry) Len() int
  • func (m *MultiEntry) Release()
  • func (m *MultiEntry) Reset()
  • func (m *MultiEntry) Write(f *file.Writer, hash func(v1.Column, parquet.ByteArray))
• type Reader
  • func NewReader() *Reader
  • func (b *Reader) Read(r *file.Reader, groups []int)
  • func (b *Reader) Record() arrow.Record
  • func (b *Reader) Release()
• type Request
  • func NewRequest() *Request
  • func (r *Request) Parse(body io.Reader) error
  • func (r *Request) Release()

Variables

var All = Fields()

var ErrBadJSON = errors.New("api: invalid json ")

var Index = func() (m map[string]int) {
	m = make(map[string]int)
	for i := range All {
		m[All[i].Name] = i
	}
	return
}()

var ParquetSchema = parquetSchema()

var Pool = memory.NewGoAllocator()

var Schema = arrow.NewSchema(All, nil)

Functions

func Context

func Context(ctx ...context.Context) context.Context

func Fields

func Fields() (f []arrow.Field)

Fields for constructing arrow schema on Entry.

func NewFileReader

func NewFileReader(r parquet.ReaderAtSeeker) *file.Reader

func NewFileWriter

func NewFileWriter(w io.Writer) *file.Writer

Types

type Entry

type Entry struct {
	Bounce         int64
	Session        int64
	Browser        string
	BrowserVersion string
	City           string
	Country        string
	Domain         string
	Duration       time.Duration
	EntryPage      string
	ExitPage       string
	Host           string
	ID             uint64
	Event          string
	Os             string
	OsVersion      string
	Path           string
	Referrer       string
	ReferrerSource string
	Region         string
	Screen         string
	Timestamp      int64
	UtmCampaign    string
	UtmContent     string
	UtmMedium      string
	UtmSource      string
	UtmTerm        string
}

func NewEntry

func NewEntry() *Entry

func (*Entry) Clone

func (e *Entry) Clone() *Entry

func (*Entry) Hit

func (e *Entry) Hit()

func (*Entry) Release

func (e *Entry) Release()

func (*Entry) Update

func (s *Entry) Update(e *Entry)

type MultiEntry

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

func NewMulti

func NewMulti() *MultiEntry

func (*MultiEntry) Append

func (m *MultiEntry) Append(e *Entry)

func (*MultiEntry) Len

func (m *MultiEntry) Len() int

func (*MultiEntry) Release

func (m *MultiEntry) Release()

func (*MultiEntry) Reset

func (m *MultiEntry) Reset()

func (*MultiEntry) Write

func (m *MultiEntry) Write(f *file.Writer, hash func(v1.Column, parquet.ByteArray))

type Reader

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

func NewReader

func NewReader() *Reader

func (*Reader) Read

func (b *Reader) Read(r *file.Reader, groups []int)

func (*Reader) Record

func (b *Reader) Record() arrow.Record

func (*Reader) Release

func (b *Reader) Release()

type Request

type Request struct {
	EventName   string `json:"n"`
	URI         string `json:"url"`
	Referrer    string `json:"r"`
	Domain      string `json:"d"`
	ScreenWidth int    `json:"w"`
	HashMode    bool   `json:"h"`

	IP        string `json:"ip,omitempty"`
	UserAgent string `json:"ua,omitempty"`
	// contains filtered or unexported fields
}

Request is sent by the vince script embedded in client websites

func NewRequest

func NewRequest() *Request

func (*Request) Parse

func (r *Request) Parse(body io.Reader) error

Parse opportunistic parses request body to r object. This is crucial method any gains here translates to smooth events ingestion pipeline.

A hard size limitation of 32kb is imposed. This is arbitrary value, any change to it must be be supported with statistics.

func (*Request) Release

func (r *Request) Release()