condition

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: 7 Imported by: 0

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 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