Skip to main content

Go Pipeline

High-Performance Go Pipeline Processing Library

Generic Support

Type-safe implementation based on Go 1.18+ generics, supporting any data type with compile-time type checking.

Batch Processing

Supports automatic batching by size and time intervals, optimizing data processing efficiency and reducing system call overhead.

Concurrency Safe

Built-in goroutine safety mechanisms, supporting high-concurrency scenarios and ensuring thread safety of data processing.