expr

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Package expr 提供表达式过滤处理器

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	// Expression 过滤表达式,返回 true 保留记录,false 过滤记录
	// 支持类 Python 语法,可访问记录的所有字段
	// 示例: "status == 'active' && score > 60"
	// 内置函数: str_contains, str_hasPrefix, str_hasSuffix, str_matches
	Expression string `json:"expression"`
}

Config Processor 的配置

type Processor

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

Processor 根据表达式过滤记录

func New

func New() *Processor

New 创建新的 Processor

func (*Processor) ConcurrencyCap

func (p *Processor) ConcurrencyCap() dataflow.ConcurrencyCap

ConcurrencyCap 声明支持并发

func (*Processor) Init

func (p *Processor) Init(config []byte) error

Init 初始化 Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, in <-chan types.Record, out chan<- types.Record) error

Process 处理数据,只输出满足表达式的记录

Jump to

Keyboard shortcuts

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