cel

package

v0.0.3 Latest Latest Go to latest Published: Aug 6, 2024 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func NewCelFlow(ctx *engine.Context) engine.Flow

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

func (cf *CelFlow) Close() error

func (cf *CelFlow) Open() error

func (cf *CelFlow) Parallelism() int

func (cf *CelFlow) Process(records []engine.Record, cb engine.FlowNextFunc)