planner

Documentation

Index

• Variables
• func ElementsEqual(left, right []EnumElementType) (isEqual bool)
• func NamesMatch(src, candidates []string) (match bool)
• func NewQuery(d *Directory) *query
• func Query()
• type DateRange
  • func NewDateRange() *DateRange
• type ParseResult
  • func NewParseResult() *ParseResult
  • func (pr *ParseResult) GetCandleAttributes() (cat map[TimeBucketKey]*CandleAttributes)
  • func (pr *ParseResult) GetDataShapes() (dsv map[TimeBucketKey][]DataShape)
  • func (pr *ParseResult) GetRowLen() (rlenMap map[TimeBucketKey]int)
  • func (pr *ParseResult) GetRowType() (rt map[TimeBucketKey]EnumRecordType)
• type QualifiedFile
• type RestrictionList
  • func NewRestrictionList() RestrictionList
  • func (r RestrictionList) AddRestriction(category string, item string)
  • func (r RestrictionList) GetRestrictionMap() RestrictionList
• type RowLimit
  • func NewRowLimit() *RowLimit
• type TimeQualFunc

Variables

var MaxEpoch = time.Unix(1<<63-62135596801, 999999999).Unix()

var MinEpoch = int64(0)

Functions

func ElementsEqual

func ElementsEqual(left, right []EnumElementType) (isEqual bool)

func NamesMatch

func NamesMatch(src, candidates []string) (match bool)

func NewQuery

func NewQuery(d *Directory) *query

func Query

func Query()

Method for composing simple queries

Types

type DateRange

type DateRange struct {
	Start, End         int64
	StartYear, EndYear int16
}

func NewDateRange

func NewDateRange() *DateRange

type ParseResult

type ParseResult struct {
	QualifiedFiles  []QualifiedFile
	Limit           *RowLimit
	Range           *DateRange
	IntervalsPerDay int64
	RootDir         string
	TimeQuals       []TimeQualFunc
}

func NewParseResult

func NewParseResult() *ParseResult

func (*ParseResult) GetCandleAttributes

func (pr *ParseResult) GetCandleAttributes() (cat map[TimeBucketKey]*CandleAttributes)

func (*ParseResult) GetDataShapes

func (pr *ParseResult) GetDataShapes() (dsv map[TimeBucketKey][]DataShape)

func (*ParseResult) GetRowLen

func (pr *ParseResult) GetRowLen() (rlenMap map[TimeBucketKey]int)

func (*ParseResult) GetRowType

func (pr *ParseResult) GetRowType() (rt map[TimeBucketKey]EnumRecordType)

type QualifiedFile

type QualifiedFile struct {
	Key  TimeBucketKey
	File *TimeBucketInfo
}

type RestrictionList

type RestrictionList map[string][]string //Key is category, items list is target

func NewRestrictionList

func NewRestrictionList() RestrictionList

func (RestrictionList) AddRestriction

func (r RestrictionList) AddRestriction(category string, item string)

func (RestrictionList) GetRestrictionMap

func (r RestrictionList) GetRestrictionMap() RestrictionList

type RowLimit

type RowLimit struct {
	Number int32
	// -1 backward, 1 forward
	Direction DirectionEnum
}

func NewRowLimit

func NewRowLimit() *RowLimit

type TimeQualFunc

type TimeQualFunc func(epoch int64) bool