Documentation
¶
Overview ¶
Package condition 提供条件过滤处理器
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Field 要过滤的字段名
Field string `json:"field"`
// Op 操作符
// 比较操作符: eq, ne, gt, gte, lt, lte
// 数组操作符: in, nin
// 存在性操作符: exists
// 字符串操作符: contains, prefix, suffix, regex
Op string `json:"op"`
// Value 比较值
Value interface{} `json:"value"`
}
Config Processor 的配置
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor 根据条件过滤记录
func (*Processor) ConcurrencyCap ¶
func (p *Processor) ConcurrencyCap() dataflow.ConcurrencyCap
ConcurrencyCap 声明支持并发
Click to show internal directories.
Click to hide internal directories.