Method tryParseTTLPolicy

parser/parser_table.go:1139–1189

(pos Pos)

}

func (p *Parser) tryParseTTLPolicy(pos Pos) (*TTLPolicy, error) {
	var rule *TTLPolicyRule
	switch {
	case p.tryConsumeKeywords(KeywordTo):
		if p.tryConsumeKeywords(KeywordDisk) {
			value, err := p.parseString(p.Pos())
			if err != nil {
				return nil, err
			}
			rule = &TTLPolicyRule{RulePos: pos, ToDisk: value}
		} else if p.tryConsumeKeywords(KeywordVolume) {
			value, err := p.parseString(p.Pos())
			if err != nil {
				return nil, err
			}
			rule = &TTLPolicyRule{RulePos: pos, ToVolume: value}
		} else {
			return nil, fmt.Errorf("unexpected token: %q, expected DISK or VOLUME", p.lastTokenKind())
		}
	case p.matchKeyword(KeywordDelete), p.matchKeyword(KeywordRecompress):
		token := p.last()
		_ = p.lexer.consumeToken()
		action := &TTLPolicyRuleAction{
			ActionPos: token.Pos,
			ActionEnd: token.End,
			Action:    token.ToString(),
		}
		codec, err := p.tryParseCompressionCodecs(p.Pos())
		if err != nil {
			return nil, err
		}
		action.Codec = codec
		rule = &TTLPolicyRule{RulePos: pos, Action: action}
	default:
		return nil, nil // nolint
	}
	policy := &TTLPolicy{Item: rule}

	where, err := p.tryParseWhereClause(p.Pos())
	if err != nil {
		return nil, err
	}
	policy.Where = where

	groupBy, err := p.tryParseGroupByClause(p.Pos())
	if err != nil {
		return nil, err
	}
	policy.GroupBy = groupBy
	return policy, nil
}

func (p *Parser) parseTTLExpr(pos Pos) (*TTLExpr, error) {
	columnExpr, err := p.parseExpr(pos)