rsql

package

Go to main page

Versions in this module

v1

v1.0.2

Jul 10, 2026

v1.0.1

Jul 9, 2026

v1.0.0

Jul 9, 2026

Changes in this version

type SelectStatement

+ JoinConfigs []types.JoinConfig

+ OrderBy []types.OrderByField

+ SourceAlias string

type TokenType

+ const TokenGlobal

+ const TokenStateTTL

+ const TokenTrigger

+ const TokenWindow

type WindowDefinition

+ CountStateTTL time.Duration

+ TriggerCondition string

v0

v0.10.7

Jan 19, 2026

Changes in this version

type TokenType

+ const TokenDot

v0.10.6

Dec 20, 2025

v0.10.5

Dec 16, 2025

v0.10.4

Nov 15, 2025

Changes in this version

type TokenType

+ const TokenAllowedLateness

+ const TokenIdleTimeout

+ const TokenMaxOutOfOrderness

type WindowDefinition

+ AllowedLateness time.Duration

+ IdleTimeout time.Duration

+ MaxOutOfOrderness time.Duration

v0.10.3

Aug 29, 2025

Changes in this version

+ const MaxRecursionDepth

+ const MaxSelectFields

v0.10.2

Aug 8, 2025

Changes in this version

type ParseError

+ func CreateSemanticError(message string, position int) *ParseError

v0.10.1

Jul 30, 2025

Changes in this version

type TokenType

+ const TokenQuotedIdent

v0.10.0

Jul 27, 2025

Changes in this version

+ func FormatErrorContext(input string, position int, contextLength int) string

+ func Parse(sql string) (*types.Config, string, error)

+ func ParseAggregateTypeWithExpression(exprStr string) (aggType aggregator.AggregateType, name string, expression string, ...)

+ type ErrorRecovery struct

+ func NewErrorRecovery(parser *Parser) *ErrorRecovery

+ func (er *ErrorRecovery) AddError(err *ParseError)

+ func (er *ErrorRecovery) GetErrors() []*ParseError

+ func (er *ErrorRecovery) HasErrors() bool

+ func (er *ErrorRecovery) RecoverFromError(errorType ErrorType) bool

+ type ErrorType int

+ const ErrorTypeInvalidExpression

+ const ErrorTypeInvalidNumber

+ const ErrorTypeLexical

+ const ErrorTypeMaxIterations

+ const ErrorTypeMissingToken

+ const ErrorTypeSemantics

+ const ErrorTypeSyntax

+ const ErrorTypeUnexpectedToken

+ const ErrorTypeUnknownFunction

+ const ErrorTypeUnknownKeyword

+ const ErrorTypeUnterminatedString

+ type Field struct

+ AggType string

+ Alias string

+ Expression string

+ type FunctionCall struct

+ Name string

+ Position int

+ type FunctionValidator struct

+ func NewFunctionValidator(errorRecovery *ErrorRecovery) *FunctionValidator

+ func (fv *FunctionValidator) ValidateExpression(expression string, position int)

+ type Lexer struct

+ func NewLexer(input string) *Lexer

+ func (l *Lexer) GetPosition() (int, int, int)

+ func (l *Lexer) NextToken() Token

+ func (l *Lexer) SetErrorRecovery(er *ErrorRecovery)

+ type ParseError struct

+ Column int

+ Context string

+ Expected []string

+ Line int

+ Message string

+ Position int

+ Recoverable bool

+ Suggestions []string

+ Token string

+ Type ErrorType

+ func CreateLexicalError(message string, position int, char byte) *ParseError

+ func CreateLexicalErrorWithPosition(message string, position int, line int, column int, char byte) *ParseError

+ func CreateMissingTokenError(expected string, position int) *ParseError

+ func CreateSyntaxError(message string, position int, token string, expected []string) *ParseError

+ func CreateUnexpectedTokenError(found string, expected []string, position int) *ParseError

+ func CreateUnknownFunctionError(functionName string, position int) *ParseError

+ func (e *ParseError) Error() string

+ func (e *ParseError) IsRecoverable() bool

+ type Parser struct

+ func NewParser(input string) *Parser

+ func (p *Parser) GetErrors() []*ParseError

+ func (p *Parser) HasErrors() bool

+ func (p *Parser) Parse() (*SelectStatement, error)

+ type SelectStatement struct

+ Condition string

+ Distinct bool

+ Fields []Field

+ GroupBy []string

+ Having string

+ Limit int

+ SelectAll bool

+ Source string

+ Window WindowDefinition

+ func (s *SelectStatement) ToStreamConfig() (*types.Config, string, error)

+ type Token struct

+ Column int

+ Line int

+ Pos int

+ Type TokenType

+ Value string

+ type TokenType int

+ const TokenAND

+ const TokenAS

+ const TokenAsterisk

+ const TokenBY

+ const TokenCASE

+ const TokenComma

+ const TokenCounting

+ const TokenDISTINCT

+ const TokenELSE

+ const TokenEND

+ const TokenEOF

+ const TokenEQ

+ const TokenFROM

+ const TokenGE

+ const TokenGROUP

+ const TokenGT

+ const TokenHAVING

+ const TokenIS

+ const TokenIdent

+ const TokenLBracket

+ const TokenLE

+ const TokenLIKE

+ const TokenLIMIT

+ const TokenLParen

+ const TokenLT

+ const TokenMinus

+ const TokenNE

+ const TokenNOT

+ const TokenNULL

+ const TokenNumber

+ const TokenOR

+ const TokenOrder

+ const TokenPlus

+ const TokenRBracket

+ const TokenRParen

+ const TokenSELECT

+ const TokenSession

+ const TokenSlash

+ const TokenSliding

+ const TokenString

+ const TokenTHEN

+ const TokenTimeUnit

+ const TokenTimestamp

+ const TokenTumbling

+ const TokenWHEN

+ const TokenWHERE

+ const TokenWITH

+ type WindowDefinition struct

+ Params []interface{}

+ TimeUnit time.Duration

+ TsProp string

+ Type string

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