Versions in this module Expand all Collapse all v0 v0.0.3 Dec 6, 2024 v0.0.2 Nov 26, 2024 Changes in this version type Chunk + func (c *Chunk) Transform(val any) any v0.0.1 Nov 25, 2024 Changes in this version + type Chunk struct + func (c *Chunk) Init(ctx *pipelaner.Context) error + func (c *Chunk) Map(_ *pipelaner.Context, val any) any + type ChunkCfg struct + MaxChunkSize int64 + MaxIdleTime string + func (c *ChunkCfg) Interval() (time.Duration, error)
Go to main page