dataframe

type AggrOption ¶

type AggrOption struct {
	// Should the aggregation be used?
	Enabled bool
	// Column to store the aggregation at.
	Column string
}

AggrOption defines options for a single aggregation.

type AggrOptionFunc ¶

type AggrOptionFunc func(*AggrsOptions)

type AggrsOptions ¶

type AggrsOptions struct {
	Sum   AggrOption
	Count AggrOption
	Min   AggrOption
	Max   AggrOption
	// contains filtered or unexported fields
}

AggrsOptions ia a collections of aggregations-related options. Determines what aggregations are enabled etc..

type Column ¶

type Column struct {
	Name string
	Type Type
}

type Dataframe ¶

type Dataframe interface {
	Schema() Schema
	RowsIterator() RowsIterator
}

Dataframe exposes ingested data to be used to turn into tabular format.

func FromSeries(r series.Set, resolution time.Duration, opts ...AggrOptionFunc) (Dataframe, error)

type Record ¶

type Record struct {
	Values map[string]interface{}
}

Record is a single instance of values for specific sample.

type Row ¶

type Row []interface{}

Row stores a single line of a table - the order of columns is defined by the Schema.

type RowsIterator ¶

type RowsIterator interface {
	Next() bool
	At() Row
}

RowsIterator exposes the rows of the dataframe.

type Schema ¶

type Schema []Column

Schema defines columns to be exposed by the dataframe.

type Type ¶

type Type string

const (
	TypeString Type = "string"
	TypeFloat  Type = "float"
	TypeUint   Type = "uint"
	TypeTime   Type = "time"
)