chunker

package

v0.0.3 Latest Latest Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Chunks[T any] struct {
	Cfg Config
	// contains filtered or unexported fields
}

func NewChunks[T any](ctx context.Context, cfg Config) *Chunks[T]

func (c *Chunks[T]) Close()

func (c *Chunks[T]) Ctx() context.Context

func (c *Chunks[T]) Generator()

func (c *Chunks[T]) GetChunks() <-chan chan T

func (c *Chunks[T]) Input() chan<- T

func (c *Chunks[T]) NewChunk() chan T

type Config struct {
	MaxChunkSize int
	BufferSize   int
	MaxIdleTime  time.Duration
}