parser

package
v0.8.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 27, 2014 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ValueRegex        ValueType = C.VALUE_REGEX
	ValueInt                    = C.VALUE_INT
	ValueBool                   = C.VALUE_BOOLEAN
	ValueFloat                  = C.VALUE_FLOAT
	ValueString                 = C.VALUE_STRING
	ValueIntoName               = C.VALUE_INTO_NAME
	ValueTableName              = C.VALUE_TABLE_NAME
	ValueSimpleName             = C.VALUE_SIMPLE_NAME
	ValueDuration               = C.VALUE_DURATION
	ValueWildcard               = C.VALUE_WILDCARD
	ValueFunctionCall           = C.VALUE_FUNCTION_CALL
	ValueExpression             = C.VALUE_EXPRESSION
)

Variables

This section is empty.

Functions

func GetStringArray 

func GetStringArray(array *C.array) []string

func RewriteMergeQuery added in v0.8.4 

func RewriteMergeQuery(query *SelectQuery, rm RegexMatcher)

Given a function that returns the series names that match the given regex, this function will rewrite the query such that the matching serires names are included in the query. E.g. if we have series names foobar, foobaz and barbaz and a query 

select * from merge(/foo.*/)

the query will be rewritten to 

select * from merge(foobar, foobaz)

Types

type BasicQuery 

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

func (*BasicQuery) GetEndTime 

func (self *BasicQuery) GetEndTime() time.Time

Returns the start time of the query. Queries can only have one condition of the form time > start_time

func (*BasicQuery) GetStartTime 

func (self *BasicQuery) GetStartTime() time.Time

Returns the start time of the query. Queries can only have one condition of the form time > start_time

func (*BasicQuery) IsStartTimeSpecified 

func (self *BasicQuery) IsStartTimeSpecified() bool

type DeleteQuery 

type DeleteQuery struct {
	SelectDeleteCommonQuery
}

func (*DeleteQuery) GetQueryString 

func (self *DeleteQuery) GetQueryString(withTime bool) string

type DropQuery 

type DropQuery struct {
	Id int
}

type DropSeriesQuery 

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

func (*DropSeriesQuery) GetTableName 

func (self *DropSeriesQuery) GetTableName() string

type From 

type From struct {
	TableName string
}

type FromClause 

type FromClause struct {
	Type  FromClauseType
	Names []*TableName
	Regex *regexp.Regexp
}

func GetFromClause 

func GetFromClause(fromClause *C.from_clause) (*FromClause, error)

func (*FromClause) GetString 

func (self *FromClause) GetString() string

type FromClauseType 

type FromClauseType int
const (
	FromClauseArray      FromClauseType = C.FROM_ARRAY
	FromClauseMerge      FromClauseType = C.FROM_MERGE
	FromClauseInnerJoin  FromClauseType = C.FROM_INNER_JOIN
	FromClauseMergeRegex FromClauseType = C.FROM_MERGE_REGEX
)

type GroupByClause 

type GroupByClause struct {
	FillWithZero bool
	FillValue    *Value
	Elems        []*Value
}

func GetGroupByClause 

func GetGroupByClause(groupByClause *C.groupby_clause) (*GroupByClause, error)

func (GroupByClause) GetGroupByTime 

func (self GroupByClause) GetGroupByTime() (*time.Duration, bool, error)

func (*GroupByClause) GetString 

func (self *GroupByClause) GetString() string

type IntoClause 

type IntoClause struct {
	Target        *Value
	Backfill      bool
	BackfillValue *Value
}

func GetIntoClause 

func GetIntoClause(intoClause *C.into_clause) (*IntoClause, error)

func (*IntoClause) GetString 

func (self *IntoClause) GetString() string

type ListQuery 

type ListQuery struct {
	Type ListType

	IncludeSpaces bool
	// contains filtered or unexported fields
}

func (*ListQuery) GetRegex 

func (self *ListQuery) GetRegex() *regexp.Regexp

func (*ListQuery) HasRegex 

func (self *ListQuery) HasRegex() bool

func (*ListQuery) IsCaseSensitive 

func (self *ListQuery) IsCaseSensitive() bool

type ListType 

type ListType int
const (
	Series ListType = iota
	ContinuousQueries
	SeriesWithRegex
)

type Operation 

type Operation int

type Query 

type Query struct {
	SelectQuery     *SelectQuery
	DeleteQuery     *DeleteQuery
	ListQuery       *ListQuery
	DropSeriesQuery *DropSeriesQuery
	DropQuery       *DropQuery
	// contains filtered or unexported fields
}

func ParseQuery 

func ParseQuery(queryStr string) ([]*Query, error)

func (*Query) GetListSeriesQuery 

func (self *Query) GetListSeriesQuery() *ListQuery

func (*Query) GetQueryString 

func (self *Query) GetQueryString() string

func (*Query) GetQueryStringWithTimeCondition 

func (self *Query) GetQueryStringWithTimeCondition() string

func (*Query) IsContinuousQuery added in v0.8.3 

func (self *Query) IsContinuousQuery() bool

func (*Query) IsExplainQuery 

func (self *Query) IsExplainQuery() bool

func (*Query) IsListContinuousQueriesQuery 

func (self *Query) IsListContinuousQueriesQuery() bool

func (*Query) IsListQuery 

func (self *Query) IsListQuery() bool

func (*Query) IsListSeriesQuery 

func (self *Query) IsListSeriesQuery() bool

func (*Query) Type added in v0.8.3 

func (self *Query) Type() QueryType

type QueryError 

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

func (*QueryError) Error 

func (self *QueryError) Error() string

func (*QueryError) PrettyPrint 

func (self *QueryError) PrettyPrint() string

type QuerySpec 

type QuerySpec struct {
	RunAgainstAllServersInShard bool
	GroupByIrregularInterval    bool
	// contains filtered or unexported fields
}

func NewQuerySpec 

func NewQuerySpec(user common.User, database string, query *Query) *QuerySpec

func (*QuerySpec) AllShardsQuery 

func (self *QuerySpec) AllShardsQuery() bool

func (*QuerySpec) Database 

func (self *QuerySpec) Database() string

func (*QuerySpec) DeleteQuery 

func (self *QuerySpec) DeleteQuery() *DeleteQuery

func (*QuerySpec) GetEndTime 

func (self *QuerySpec) GetEndTime() time.Time

func (*QuerySpec) GetFromClause 

func (self *QuerySpec) GetFromClause() *FromClause

func (*QuerySpec) GetGroupByColumnCount 

func (self *QuerySpec) GetGroupByColumnCount() int

func (*QuerySpec) GetGroupByInterval 

func (self *QuerySpec) GetGroupByInterval() *time.Duration

func (*QuerySpec) GetQueryString 

func (self *QuerySpec) GetQueryString() string

func (*QuerySpec) GetQueryStringWithTimeCondition 

func (self *QuerySpec) GetQueryStringWithTimeCondition() string

func (*QuerySpec) GetStartTime 

func (self *QuerySpec) GetStartTime() time.Time

func (*QuerySpec) HasAggregates 

func (self *QuerySpec) HasAggregates() bool

func (*QuerySpec) HasReadAccess 

func (self *QuerySpec) HasReadAccess(name string) bool

func (*QuerySpec) IsAscending 

func (self *QuerySpec) IsAscending() bool

func (*QuerySpec) IsDeleteFromSeriesQuery 

func (self *QuerySpec) IsDeleteFromSeriesQuery() bool

func (*QuerySpec) IsDestructiveQuery 

func (self *QuerySpec) IsDestructiveQuery() bool

func (*QuerySpec) IsDropSeriesQuery 

func (self *QuerySpec) IsDropSeriesQuery() bool

func (*QuerySpec) IsExplainQuery 

func (self *QuerySpec) IsExplainQuery() bool

func (*QuerySpec) IsListSeriesQuery 

func (self *QuerySpec) IsListSeriesQuery() bool

func (*QuerySpec) IsRegex 

func (self *QuerySpec) IsRegex() bool

func (*QuerySpec) IsSinglePointQuery 

func (self *QuerySpec) IsSinglePointQuery() bool

func (*QuerySpec) Query 

func (self *QuerySpec) Query() *Query

func (*QuerySpec) ReadsFromMultipleSeries 

func (self *QuerySpec) ReadsFromMultipleSeries() bool

func (*QuerySpec) SelectQuery 

func (self *QuerySpec) SelectQuery() *SelectQuery

func (*QuerySpec) SeriesValuesAndColumns 

func (self *QuerySpec) SeriesValuesAndColumns() map[*Value][]string

func (*QuerySpec) TableNames 

func (self *QuerySpec) TableNames() []string

func (*QuerySpec) TableNamesAndRegex 

func (self *QuerySpec) TableNamesAndRegex() ([]string, *regexp.Regexp)

func (*QuerySpec) User 

func (self *QuerySpec) User() common.User

type QueryType added in v0.8.3 

type QueryType int
const (
	Select QueryType = iota
	Delete
	DropContinuousQuery
	ListSeries
	ListContinuousQueries
	DropSeries
	Continuous
)

func (QueryType) String added in v0.8.3 

func (qt QueryType) String() string

type RegexMatcher added in v0.8.4 

type RegexMatcher func(r *regexp.Regexp) []string

type SelectDeleteCommonQuery 

type SelectDeleteCommonQuery struct {
	BasicQuery
	FromClause *FromClause
	Condition  *WhereCondition
}

func (*SelectDeleteCommonQuery) GetFromClause 

func (self *SelectDeleteCommonQuery) GetFromClause() *FromClause

func (*SelectDeleteCommonQuery) GetTableAliases 

func (self *SelectDeleteCommonQuery) GetTableAliases(name string) []string

func (*SelectDeleteCommonQuery) GetWhereCondition 

func (self *SelectDeleteCommonQuery) GetWhereCondition() *WhereCondition

func (*SelectDeleteCommonQuery) GetWhereConditionWithTime 

func (self *SelectDeleteCommonQuery) GetWhereConditionWithTime(startTime, endTime time.Time) *WhereCondition

func (*SelectDeleteCommonQuery) WillReturnSingleSeries 

func (self *SelectDeleteCommonQuery) WillReturnSingleSeries() bool

type SelectQuery 

type SelectQuery struct {
	SelectDeleteCommonQuery
	ColumnNames []*Value

	IntoClause *IntoClause
	Limit      int
	Ascending  bool
	Explain    bool
	// contains filtered or unexported fields
}

func ParseSelectQuery 

func ParseSelectQuery(query string) (*SelectQuery, error)

This is just for backward compatability so we don't have to change all the code.

func (*SelectQuery) ContainsArithmeticOperators added in v0.8.4 

func (self *SelectQuery) ContainsArithmeticOperators() bool

Returns true if the query has some expression in the select clause

func (*SelectQuery) GetColumnNames 

func (self *SelectQuery) GetColumnNames() []*Value

func (*SelectQuery) GetGroupByClause 

func (self *SelectQuery) GetGroupByClause() *GroupByClause

func (*SelectQuery) GetIntoClause 

func (self *SelectQuery) GetIntoClause() *IntoClause

func (*SelectQuery) GetQueryString 

func (self *SelectQuery) GetQueryString() string

func (*SelectQuery) GetQueryStringWithTimeCondition 

func (self *SelectQuery) GetQueryStringWithTimeCondition() string

func (*SelectQuery) GetQueryStringWithTimes 

func (self *SelectQuery) GetQueryStringWithTimes(startTime, endTime time.Time) string

func (*SelectQuery) GetQueryStringWithTimesAndNoIntoClause 

func (self *SelectQuery) GetQueryStringWithTimesAndNoIntoClause(startTime, endTime time.Time) string

func (*SelectQuery) GetReferencedColumns 

func (self *SelectQuery) GetReferencedColumns() map[*Value][]string

Returns a mapping from the time series names (or regex) to the column names that are references

func (*SelectQuery) GetResultColumns 

func (self *SelectQuery) GetResultColumns() map[*Value][]string

func (*SelectQuery) GetSinglePointQuerySequenceNumber 

func (self *SelectQuery) GetSinglePointQuerySequenceNumber() (uint64, error)

func (*SelectQuery) HasAggregates 

func (self *SelectQuery) HasAggregates() bool

Returns true if the query has aggregate functions applied to the columns

func (*SelectQuery) IsExplainQuery 

func (self *SelectQuery) IsExplainQuery() bool

func (*SelectQuery) IsNonRecursiveContinuousQuery 

func (self *SelectQuery) IsNonRecursiveContinuousQuery() bool

func (*SelectQuery) IsSinglePointQuery 

func (self *SelectQuery) IsSinglePointQuery() bool

func (*SelectQuery) IsValidContinuousQuery 

func (self *SelectQuery) IsValidContinuousQuery() bool

type TableName 

type TableName struct {
	Name  *Value
	Alias string
}

func GetTableName 

func GetTableName(name *C.table_name) (*TableName, error)

func GetTableNameArray 

func GetTableNameArray(array *C.table_name_array) ([]*TableName, error)

func (*TableName) GetAlias 

func (self *TableName) GetAlias() string

func (*TableName) GetAliasString 

func (self *TableName) GetAliasString() string

type Value 

type Value struct {
	Name  string
	Alias string
	Type  ValueType
	Elems []*Value

	IsInsensitive bool
	// contains filtered or unexported fields
}

func GetValue 

func GetValue(value *C.value) (*Value, error)

func GetValueArray 

func GetValueArray(array *C.value_array) ([]*Value, error)

func (*Value) GetCompiledRegex 

func (self *Value) GetCompiledRegex() (*regexp.Regexp, bool)

func (*Value) GetString 

func (self *Value) GetString() string

func (*Value) IsFunctionCall 

func (self *Value) IsFunctionCall() bool

type ValueType 

type ValueType int

type Values 

type Values []*Value

func (Values) GetString 

func (self Values) GetString() string

type WhereCondition 

type WhereCondition struct {
	Left      interface{}
	Operation string
	Right     *WhereCondition
	// contains filtered or unexported fields
}

func GetWhereCondition 

func GetWhereCondition(condition *C.condition) (*WhereCondition, error)

func (*WhereCondition) GetBoolExpression 

func (self *WhereCondition) GetBoolExpression() (*Value, bool)

func (*WhereCondition) GetLeftWhereCondition 

func (self *WhereCondition) GetLeftWhereCondition() (*WhereCondition, bool)

func (*WhereCondition) GetString 

func (self *WhereCondition) GetString() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.