interfaces

Documentation

Index

• type CombineOperation
• type CombiningCondition
• type ComparisonCondition
• type Condition
• type Operation
• type ReadRequest
• type StorageEngineConsensusI
• type StorageEngineProcessingI
• type WriteRequest

Types

type CombineOperation

type CombineOperation int

const (
	NotOperation CombineOperation = iota // First has to be nil
	AndOperation
	OrOperation
)

definition of combining operators with order of precedence

type CombiningCondition

type CombiningCondition struct {
	First     *Condition
	CombineOp CombineOperation
	Second    *Condition
}

type ComparisonCondition

type ComparisonCondition struct {
	FieldName string
	Op        Operation
	Value     interface{}
}

type Condition

type Condition interface {
	IsCondition()
}

type Operation

type Operation int

const (
	EqualOperation Operation = iota
	NotEqualOperation
	GreaterThanOperation
	GreaterThanOrEqualOperation
	LessThanOperation
	LessThanOrEqualOperation
)

type ReadRequest

type ReadRequest struct {
	Timeseries   string
	IsRegex      bool // is the timeseries name a regex?
	StartTime    time.Time
	EndTime      time.Time
	IsContinuous bool
	Conditions   []*Condition
}

TODO: applying functions and joining time series

type StorageEngineConsensusI

type StorageEngineConsensusI interface {
}

type StorageEngineProcessingI

type StorageEngineProcessingI interface {
	WritePoints(request *WriteRequest) error
	ReadPoints(request *ReadRequest, yield func(pts []*protocol.Point) error) error
}

type WriteRequest

type WriteRequest struct {
	Timeseries []*protocol.Series
}