chunker

package

v1.3.4 Latest Latest Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Chunks struct {
	Cfg Config
	// contains filtered or unexported fields
}

func NewChunks(cfg Config) *Chunks

func (c *Chunks) Chunk() chan any

func (c *Chunks) Chunks() <-chan chan any

func (c *Chunks) Generator()

func (c *Chunks) NewChunk() chan any

func (c *Chunks) SetValue(v any)

func (c *Chunks) Stop()

type Config struct {
	MaxChunkSize uint
	BufferSize   uint
	MaxIdleTime  time.Duration
	Strategy     Strategy
}

type Strategy string

const (
	FlushByOneMessage Strategy = "flush-by-one-message"
	FlushByTime       Strategy = "flush-by-time"
)