index

Documentation

Index

• func Intersect(a, b []int) []int
• func Union(a, b []int) []int
• type HistogramBucket
• type Index
  • func Build(records []parser.Record) *Index
  • func (idx *Index) AddRecords(records []parser.Record)
  • func (idx *Index) AllIDs() []int
  • func (idx *Index) Complement(ids []int) []int
  • func (idx *Index) FieldLookup(field, value string) []int
  • func (idx *Index) FieldNames() []string
  • func (idx *Index) FieldValues(field string) []string
  • func (idx *Index) FullTextSearch(text string) []int
  • func (idx *Index) Histogram(buckets int, ids []int) []HistogramBucket
  • func (idx *Index) NumericGreater(field string, value float64) []int
  • func (idx *Index) NumericGreaterEqual(field string, value float64) []int
  • func (idx *Index) NumericLess(field string, value float64) []int
  • func (idx *Index) NumericLessEqual(field string, value float64) []int
  • func (idx *Index) TimeAfter(t time.Time) []int
  • func (idx *Index) TimeAfterEqual(t time.Time) []int
  • func (idx *Index) TimeBefore(t time.Time) []int
  • func (idx *Index) TimeBeforeEqual(t time.Time) []int
  • func (idx *Index) TimeRange(start, end time.Time) []int
• type NumericEntry
• type TimeEntry

Functions

func Intersect

func Intersect(a, b []int) []int

Intersect returns the sorted intersection of two sorted slices.

func Union

func Union(a, b []int) []int

Union returns the sorted union of two sorted slices.

Types

type HistogramBucket

type HistogramBucket struct {
	Start  time.Time
	End    time.Time
	Count  int
	Errors int // count of error/fatal in this bucket
}

HistogramBucket represents one bar in the time histogram.

type Index

type Index struct {
	Records []parser.Record

	TotalCount int
	// contains filtered or unexported fields
}

Index provides fast lookups over a set of parsed log records.

func Build

func Build(records []parser.Record) *Index

Build creates an index from a slice of records.

func (*Index) AddRecords

func (idx *Index) AddRecords(records []parser.Record)

AddRecords appends new records to the index incrementally.

func (*Index) AllIDs

func (idx *Index) AllIDs() []int

AllIDs returns all record indices.

func (*Index) Complement

func (idx *Index) Complement(ids []int) []int

Complement returns all IDs not in the given sorted slice.

func (*Index) FieldLookup

func (idx *Index) FieldLookup(field, value string) []int

FieldLookup returns record IDs where field has the given value.

func (*Index) FieldNames

func (idx *Index) FieldNames() []string

FieldNames returns all indexed field names, sorted alphabetically.

func (*Index) FieldValues

func (idx *Index) FieldValues(field string) []string

func (*Index) FullTextSearch

func (idx *Index) FullTextSearch(text string) []int

FullTextSearch scans all records for a substring match in any field value. Returns matching record IDs.

func (*Index) Histogram

func (idx *Index) Histogram(buckets int, ids []int) []HistogramBucket

Histogram returns bucketed counts for the time range of the given record IDs. If ids is nil, uses all records with timestamps.

func (*Index) NumericGreater

func (idx *Index) NumericGreater(field string, value float64) []int

NumericGreater returns record IDs where field > value.

func (*Index) NumericGreaterEqual

func (idx *Index) NumericGreaterEqual(field string, value float64) []int

NumericGreaterEqual returns record IDs where field >= value.

func (*Index) NumericLess

func (idx *Index) NumericLess(field string, value float64) []int

NumericLess returns record IDs where field < value.

func (*Index) NumericLessEqual

func (idx *Index) NumericLessEqual(field string, value float64) []int

NumericLessEqual returns record IDs where field <= value.

func (*Index) TimeAfter

func (idx *Index) TimeAfter(t time.Time) []int

TimeAfter returns record IDs where timestamp > t.

func (*Index) TimeAfterEqual

func (idx *Index) TimeAfterEqual(t time.Time) []int

TimeAfterEqual returns record IDs where timestamp >= t.

func (*Index) TimeBefore

func (idx *Index) TimeBefore(t time.Time) []int

TimeBefore returns record IDs where timestamp < t.

func (*Index) TimeBeforeEqual

func (idx *Index) TimeBeforeEqual(t time.Time) []int

TimeBeforeEqual returns record IDs where timestamp <= t.

func (*Index) TimeRange

func (idx *Index) TimeRange(start, end time.Time) []int

TimeRange returns record IDs within [start, end].

type NumericEntry

type NumericEntry struct {
	Value    float64
	RecordID int
}

NumericEntry holds a float64 value and the index of the record it belongs to.

type TimeEntry

type TimeEntry struct {
	Time     time.Time
	RecordID int
}

TimeEntry holds a timestamp and the index of the record it belongs to.