influxql

package

Go to main page

Versions in this module

v0

v0.2.1

Nov 16, 2015

Changes in this version

type DropDatabaseStatement

+ IfExists bool

v0.2.0

Oct 27, 2015

Changes in this version

+ func EvalBool(expr Expr, m map[string]interface{}) bool

+ func HasTimeExpr(expr Expr) bool

+ func OnlyTimeExpr(expr Expr) bool

type Call

+ func (c *Call) Fields() []string

type CreateDatabaseStatement

+ IfNotExists bool

+ type CreateSubscriptionStatement struct

+ Database string

+ Destinations []string

+ Mode string

+ Name string

+ RetentionPolicy string

+ func (s *CreateSubscriptionStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *CreateSubscriptionStatement) String() string

+ type DropServerStatement struct

+ Force bool

+ NodeID uint64

+ func (s *DropServerStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropServerStatement) String() string

+ type DropSubscriptionStatement struct

+ Database string

+ Name string

+ RetentionPolicy string

+ func (s *DropSubscriptionStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropSubscriptionStatement) String() string

type Measurement

+ IsTarget bool

type SelectStatement

+ func (s *SelectStatement) ColumnNames() []string

+ func (s *SelectStatement) FunctionCallsByPosition() [][]*Call

+ func (s *SelectStatement) HasTimeFieldSpecified() bool

+ func (s *SelectStatement) LimitTagSets(a []*TagSet) []*TagSet

+ func (s *SelectStatement) SourceNames() []string

+ func (s *SelectStatement) TimeAscending() bool

type ShowDiagnosticsStatement

+ Module string

type ShowMeasurementsStatement

+ Source Source

+ type ShowShardsStatement struct

+ func (s *ShowShardsStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowShardsStatement) String() string

type ShowStatsStatement

+ Module string

+ type ShowSubscriptionsStatement struct

+ func (s *ShowSubscriptionsStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowSubscriptionsStatement) String() string

type ShowTagKeysStatement

+ SLimit int

+ SOffset int

type Token

+ const ANY

+ const COLON

+ const DESTINATIONS

+ const FORCE

+ const NOT

+ const SERVER

+ const SHARDS

+ const SUBSCRIPTION

+ const SUBSCRIPTIONS

v0.1.9

Sep 22, 2015

v0.1.8

Sep 4, 2015

v0.1.7

Aug 27, 2015

v0.1.6

Aug 24, 2015

Changes in this version

type Fields

+ func (a Fields) AliasNames() []string

+ func (a Fields) Names() []string

type Row

+ func (r *Row) SameSeries(o *Row) bool

type SelectStatement

+ func (s *SelectStatement) HasDimensionWildcard() bool

+ func (s *SelectStatement) HasFieldWildcard() bool

+ func (s *SelectStatement) NamesInDimension() []string

v0.1.4

Aug 18, 2015

Changes in this version

+ const Boolean

+ const DateFormat

+ const DateTimeFormat

+ const Duration

+ const Float

+ const Integer

+ const String

+ const Time

+ const Unknown

+ var ErrInvalidDuration = errors.New("invalid duration")

+ func Eval(expr Expr, m map[string]interface{}) interface

+ func FormatDuration(d time.Duration) string

+ func IdentNeedsQuotes(ident string) bool

+ func IsNumeric(c *Call) bool

+ func IsRegexOp(t Token) bool

+ func MapCount(itr Iterator) interface

+ func MapCountDistinct(itr Iterator) interface

+ func MapDistinct(itr Iterator) interface

+ func MapEcho(itr Iterator) interface

+ func MapFirst(itr Iterator) interface

+ func MapLast(itr Iterator) interface

+ func MapMax(itr Iterator) interface

+ func MapMean(itr Iterator) interface

+ func MapMin(itr Iterator) interface

+ func MapRawQuery(itr Iterator) interface

+ func MapSpread(itr Iterator) interface

+ func MapStddev(itr Iterator) interface

+ func MapSum(itr Iterator) interface

+ func MatchSource(sources Sources, name string) string

+ func ParseDuration(s string) (time.Duration, error)

+ func QuoteIdent(segments ...string) string

+ func QuoteString(s string) string

+ func ReduceCountDistinct(values []interface{}) interface

+ func ReduceDistinct(values []interface{}) interface

+ func ReduceFirst(values []interface{}) interface

+ func ReduceLast(values []interface{}) interface

+ func ReduceMax(values []interface{}) interface

+ func ReduceMean(values []interface{}) interface

+ func ReduceMedian(values []interface{}) interface

+ func ReduceMin(values []interface{}) interface

+ func ReduceSpread(values []interface{}) interface

+ func ReduceStddev(values []interface{}) interface

+ func ReduceSum(values []interface{}) interface

+ func ScanBareIdent(r io.RuneScanner) string

+ func ScanDelimited(r io.RuneScanner, start, end rune, escapes map[rune]rune, escapesPassThru bool) ([]byte, error)

+ func ScanString(r io.RuneScanner) (string, error)

+ func TimeRange(expr Expr) (min, max time.Time)

+ func TimeRangeAsEpochNano(expr Expr) (min, max int64)

+ func Walk(v Visitor, node Node)

+ func WalkFunc(node Node, fn func(Node))

+ type AlterRetentionPolicyStatement struct

+ Database string

+ Default bool

+ Duration *time.Duration

+ Name string

+ Replication *int

+ func (s *AlterRetentionPolicyStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *AlterRetentionPolicyStatement) String() string

+ type BinaryExpr struct

+ LHS Expr

+ Op Token

+ RHS Expr

+ func (e *BinaryExpr) String() string

+ type BooleanLiteral struct

+ Val bool

+ func (l *BooleanLiteral) String() string

+ type Call struct

+ Args []Expr

+ Name string

+ func (c *Call) String() string

+ type CreateContinuousQueryStatement struct

+ Database string

+ Name string

+ Source *SelectStatement

+ func (s *CreateContinuousQueryStatement) DefaultDatabase() string

+ func (s *CreateContinuousQueryStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *CreateContinuousQueryStatement) String() string

+ type CreateDatabaseStatement struct

+ Name string

+ func (s *CreateDatabaseStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *CreateDatabaseStatement) String() string

+ type CreateRetentionPolicyStatement struct

+ Database string

+ Default bool

+ Duration time.Duration

+ Name string

+ Replication int

+ func (s *CreateRetentionPolicyStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *CreateRetentionPolicyStatement) String() string

+ type CreateUserStatement struct

+ Admin bool

+ Name string

+ Password string

+ func (s *CreateUserStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *CreateUserStatement) String() string

+ type DataType int

+ func InspectDataType(v interface{}) DataType

+ func (d DataType) String() string

+ type DeleteStatement struct

+ Condition Expr

+ Source Source

+ func (s *DeleteStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DeleteStatement) String() string

+ type Dimension struct

+ Expr Expr

+ func (d *Dimension) String() string

+ type Dimensions []*Dimension

+ func (a Dimensions) Normalize() (time.Duration, []string, error)

+ func (a Dimensions) String() string

+ type Distinct struct

+ Val string

+ func (d *Distinct) NewCall() *Call

+ func (d *Distinct) String() string

+ type DropContinuousQueryStatement struct

+ Database string

+ Name string

+ func (s *DropContinuousQueryStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropContinuousQueryStatement) String() string

+ type DropDatabaseStatement struct

+ Name string

+ func (s *DropDatabaseStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropDatabaseStatement) String() string

+ type DropMeasurementStatement struct

+ Name string

+ func (s *DropMeasurementStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropMeasurementStatement) String() string

+ type DropRetentionPolicyStatement struct

+ Database string

+ Name string

+ func (s *DropRetentionPolicyStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropRetentionPolicyStatement) String() string

+ type DropSeriesStatement struct

+ Condition Expr

+ Sources Sources

+ func (s *DropSeriesStatement) String() string

+ func (s DropSeriesStatement) RequiredPrivileges() ExecutionPrivileges

+ type DropUserStatement struct

+ Name string

+ func (s *DropUserStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *DropUserStatement) String() string

+ type DurationLiteral struct

+ Val time.Duration

+ func (l *DurationLiteral) String() string

+ type ExecutionPrivilege struct

+ Admin bool

+ Name string

+ Privilege Privilege

+ type ExecutionPrivileges []ExecutionPrivilege

+ type Expr interface

+ func CloneExpr(expr Expr) Expr

+ func ParseExpr(s string) (Expr, error)

+ func Reduce(expr Expr, valuer Valuer) Expr

+ type Field struct

+ Alias string

+ Expr Expr

+ func (f *Field) Name() string

+ func (f *Field) String() string

+ type Fields []*Field

+ func (a Fields) String() string

+ func (f Fields) Len() int

+ func (f Fields) Less(i, j int) bool

+ func (f Fields) Swap(i, j int)

+ type FillOption int

+ const NoFill

+ const NullFill

+ const NumberFill

+ const PreviousFill

+ type GrantAdminStatement struct

+ User string

+ func (s *GrantAdminStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *GrantAdminStatement) String() string

+ type GrantStatement struct

+ On string

+ Privilege Privilege

+ User string

+ func (s *GrantStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *GrantStatement) String() string

+ type HasDefaultDatabase interface

+ DefaultDatabase func() string

+ type Iterator interface

+ Next func() (time int64, value interface{})

+ type MapFunc func(Iterator) interface

+ func InitializeMapFunc(c *Call) (MapFunc, error)

+ type Measurement struct

+ Database string

+ Name string

+ Regex *RegexLiteral

+ RetentionPolicy string

+ func (m *Measurement) String() string

+ type Measurements []*Measurement

+ func (a Measurements) String() string

+ type Node interface

+ String func() string

+ func Rewrite(r Rewriter, node Node) Node

+ func RewriteFunc(node Node, fn func(Node) Node) Node

+ type NowValuer struct

+ Now time.Time

+ func (v *NowValuer) Value(key string) (interface{}, bool)

+ type NumberLiteral struct

+ Val float64

+ func (l *NumberLiteral) String() string

+ type NumberType int8

+ const Float64Type

+ const Int64Type

+ type ParenExpr struct

+ Expr Expr

+ func (e *ParenExpr) String() string

+ type ParseError struct

+ Expected []string

+ Found string

+ Message string

+ Pos Pos

+ func (e *ParseError) Error() string

+ type Parser struct

+ func NewParser(r io.Reader) *Parser

+ func (p *Parser) ParseExpr() (Expr, error)

+ func (p *Parser) ParseQuery() (*Query, error)

+ func (p *Parser) ParseStatement() (Statement, error)

+ type Pos struct

+ Char int

+ Line int

+ type Privilege int

+ const AllPrivileges

+ const NoPrivileges

+ const ReadPrivilege

+ const WritePrivilege

+ func NewPrivilege(p Privilege) *Privilege

+ func (p Privilege) String() string

+ type Processor func(values []interface{}) interface

+ func GetProcessor(expr Expr, startIndex int) (Processor, int)

+ type Query struct

+ Statements Statements

+ func ParseQuery(s string) (*Query, error)

+ func (q *Query) String() string

+ type ReduceFunc func([]interface{}) interface

+ func InitializeReduceFunc(c *Call) (ReduceFunc, error)

+ func ReducePercentile(percentile float64) ReduceFunc

+ type RegexLiteral struct

+ Val *regexp.Regexp

+ func CloneRegexLiteral(r *RegexLiteral) *RegexLiteral

+ func (r *RegexLiteral) String() string

+ type Result struct

+ Err error

+ Series Rows

+ StatementID int

+ func (r *Result) MarshalJSON() ([]byte, error)

+ func (r *Result) UnmarshalJSON(b []byte) error

+ type RevokeAdminStatement struct

+ User string

+ func (s *RevokeAdminStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *RevokeAdminStatement) String() string

+ type RevokeStatement struct

+ On string

+ Privilege Privilege

+ User string

+ func (s *RevokeStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *RevokeStatement) String() string

+ type Rewriter interface

+ Rewrite func(Node) Node

+ type Row struct

+ Columns []string

+ Err error

+ Name string

+ Tags map[string]string

+ Values [][]interface{}

+ type Rows []*Row

+ func (p Rows) Len() int

+ func (p Rows) Less(i, j int) bool

+ func (p Rows) Swap(i, j int)

+ type Scanner struct

+ func NewScanner(r io.Reader) *Scanner

+ func (s *Scanner) Scan() (tok Token, pos Pos, lit string)

+ func (s *Scanner) ScanRegex() (tok Token, pos Pos, lit string)

+ type SelectStatement struct

+ Condition Expr

+ Dimensions Dimensions

+ Fields Fields

+ Fill FillOption

+ FillValue interface{}

+ IsRawQuery bool

+ Limit int

+ Offset int

+ SLimit int

+ SOffset int

+ SortFields SortFields

+ Sources Sources

+ Target *Target

+ func (s *SelectStatement) Clone() *SelectStatement

+ func (s *SelectStatement) FunctionCalls() []*Call

+ func (s *SelectStatement) GroupByInterval() (time.Duration, error)

+ func (s *SelectStatement) HasCountDistinct() bool

+ func (s *SelectStatement) HasDerivative() bool

+ func (s *SelectStatement) HasDistinct() bool

+ func (s *SelectStatement) HasWildcard() bool

+ func (s *SelectStatement) IsSimpleDerivative() bool

+ func (s *SelectStatement) NamesInSelect() []string

+ func (s *SelectStatement) NamesInWhere() []string

+ func (s *SelectStatement) OnlyTimeDimensions() bool

+ func (s *SelectStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *SelectStatement) RewriteDistinct()

+ func (s *SelectStatement) RewriteWildcards(fields Fields, dimensions Dimensions) *SelectStatement

+ func (s *SelectStatement) SetTimeRange(start, end time.Time) error

+ func (s *SelectStatement) String() string

+ func (s *SelectStatement) Substatement(ref *VarRef) (*SelectStatement, error)

+ type SetPasswordUserStatement struct

+ Name string

+ Password string

+ func (s *SetPasswordUserStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *SetPasswordUserStatement) String() string

+ type ShowContinuousQueriesStatement struct

+ func (s *ShowContinuousQueriesStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowContinuousQueriesStatement) String() string

+ type ShowDatabasesStatement struct

+ func (s *ShowDatabasesStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowDatabasesStatement) String() string

+ type ShowDiagnosticsStatement struct

+ func (s *ShowDiagnosticsStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowDiagnosticsStatement) String() string

+ type ShowFieldKeysStatement struct

+ Limit int

+ Offset int

+ SortFields SortFields

+ Sources Sources

+ func (s *ShowFieldKeysStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowFieldKeysStatement) String() string

+ type ShowGrantsForUserStatement struct

+ Name string

+ func (s *ShowGrantsForUserStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowGrantsForUserStatement) String() string

+ type ShowMeasurementsStatement struct

+ Condition Expr

+ Limit int

+ Offset int

+ SortFields SortFields

+ func (s *ShowMeasurementsStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowMeasurementsStatement) String() string

+ type ShowRetentionPoliciesStatement struct

+ Database string

+ func (s *ShowRetentionPoliciesStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowRetentionPoliciesStatement) String() string

+ type ShowSeriesStatement struct

+ Condition Expr

+ Limit int

+ Offset int

+ SortFields SortFields

+ Sources Sources

+ func (s *ShowSeriesStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowSeriesStatement) String() string

+ type ShowServersStatement struct

+ func (s *ShowServersStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowServersStatement) String() string

+ type ShowStatsStatement struct

+ Host string

+ func (s *ShowStatsStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowStatsStatement) String() string

+ type ShowTagKeysStatement struct

+ Condition Expr

+ Limit int

+ Offset int

+ SortFields SortFields

+ Sources Sources

+ func (s *ShowTagKeysStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowTagKeysStatement) String() string

+ type ShowTagValuesStatement struct

+ Condition Expr

+ Limit int

+ Offset int

+ SortFields SortFields

+ Sources Sources

+ TagKeys []string

+ func (s *ShowTagValuesStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowTagValuesStatement) String() string

+ type ShowUsersStatement struct

+ func (s *ShowUsersStatement) RequiredPrivileges() ExecutionPrivileges

+ func (s *ShowUsersStatement) String() string

+ type SortField struct

+ Ascending bool

+ Name string

+ func (field *SortField) String() string

+ type SortFields []*SortField

+ func (a SortFields) String() string

+ type Source interface

+ type Sources []Source

+ func (a Sources) String() string

+ type Statement interface

+ RequiredPrivileges func() ExecutionPrivileges

+ func MustParseStatement(s string) Statement

+ func ParseStatement(s string) (Statement, error)

+ type Statements []Statement

+ func (a Statements) String() string

+ type StringLiteral struct

+ Val string

+ func (l *StringLiteral) String() string

+ type TagSet struct

+ Filters []Expr

+ Key []byte

+ SeriesKeys []string

+ Tags map[string]string

+ func (t *TagSet) AddFilter(key string, filter Expr)

+ type Target struct

+ Measurement *Measurement

+ func (t *Target) String() string

+ type TimeLiteral struct

+ Val time.Time

+ func (l *TimeLiteral) String() string

+ type Token int

+ const ADD

+ const ALL

+ const ALTER

+ const AND

+ const AS

+ const ASC

+ const BADESCAPE

+ const BADREGEX

+ const BADSTRING

+ const BEGIN

+ const BY

+ const COMMA

+ const CONTINUOUS

+ const CREATE

+ const DATABASE

+ const DATABASES

+ const DEFAULT

+ const DELETE

+ const DESC

+ const DIAGNOSTICS

+ const DISTINCT

+ const DIV

+ const DOT

+ const DROP

+ const DURATION

+ const DURATION_VAL

+ const END

+ const EOF

+ const EQ

+ const EQREGEX

+ const EXISTS

+ const EXPLAIN

+ const FALSE

+ const FIELD

+ const FOR

+ const FROM

+ const GRANT

+ const GRANTS

+ const GROUP

+ const GT

+ const GTE

+ const IDENT

+ const IF

+ const ILLEGAL

+ const IN

+ const INF

+ const INNER

+ const INSERT

+ const INTO

+ const KEY

+ const KEYS

+ const LIMIT

+ const LPAREN

+ const LT

+ const LTE

+ const MEASUREMENT

+ const MEASUREMENTS

+ const MUL

+ const NEQ

+ const NEQREGEX

+ const NUMBER

+ const OFFSET

+ const ON

+ const OR

+ const ORDER

+ const PASSWORD

+ const POLICIES

+ const POLICY

+ const PRIVILEGES

+ const QUERIES

+ const QUERY

+ const READ

+ const REGEX

+ const REPLICATION

+ const RETENTION

+ const REVOKE

+ const RPAREN

+ const SELECT

+ const SEMICOLON

+ const SERIES

+ const SERVERS

+ const SET

+ const SHOW

+ const SLIMIT

+ const SOFFSET

+ const STATS

+ const STRING

+ const SUB

+ const TAG

+ const TO

+ const TRUE

+ const USER

+ const USERS

+ const VALUES

+ const WHERE

+ const WITH

+ const WRITE

+ const WS

+ func Lookup(ident string) Token

+ func (tok Token) Precedence() int

+ func (tok Token) String() string

+ type UnmarshalFunc func([]byte) (interface{}, error)

+ func InitializeUnmarshaller(c *Call) (UnmarshalFunc, error)

+ type Valuer interface

+ Value func(key string) (interface{}, bool)

+ type VarRef struct

+ Val string

+ func (r *VarRef) String() string

+ type Visitor interface

+ Visit func(Node) Visitor

+ type Wildcard struct

+ func (e *Wildcard) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL