Directories
¶
| Path | Synopsis |
|---|---|
|
common
|
|
|
errors
Package gferrors provides common error types and utilities for the goflow library.
|
Package gferrors provides common error types and utilities for the goflow library. |
|
validation
Package validation provides common validation utilities for configuration parameters across the goflow library.
|
Package validation provides common validation utilities for configuration parameters across the goflow library. |
|
Package ratelimit provides rate limiting primitives for Go applications.
|
Package ratelimit provides rate limiting primitives for Go applications. |
|
concurrency
Package concurrency provides concurrency limiting for Go applications.
|
Package concurrency provides concurrency limiting for Go applications. |
|
leakybucket
Package leakybucket provides leaky bucket rate limiting for Go applications.
|
Package leakybucket provides leaky bucket rate limiting for Go applications. |
|
Package scheduling provides task scheduling and execution primitives for Go applications.
|
Package scheduling provides task scheduling and execution primitives for Go applications. |
|
pipeline
Package pipeline provides multi-stage data processing with error handling and monitoring.
|
Package pipeline provides multi-stage data processing with error handling and monitoring. |
|
scheduler
Package scheduler provides task scheduling with support for delayed execution, repeating tasks, and cron expressions.
|
Package scheduler provides task scheduling with support for delayed execution, repeating tasks, and cron expressions. |
|
workerpool
Package workerpool provides a worker pool for executing tasks concurrently with a fixed number of goroutines and bounded queue.
|
Package workerpool provides a worker pool for executing tasks concurrently with a fixed number of goroutines and bounded queue. |
|
Package streaming offers a new take on streaming data, providing higher-level abstractions than standard Go readers and writers.
|
Package streaming offers a new take on streaming data, providing higher-level abstractions than standard Go readers and writers. |
|
channel
Package channel provides backpressure-aware channels for flow control in concurrent applications.
|
Package channel provides backpressure-aware channels for flow control in concurrent applications. |
|
stream
Package stream provides a powerful and expressive API for processing sequences of data in Go.
|
Package stream provides a powerful and expressive API for processing sequences of data in Go. |
|
writer
Package writer provides asynchronous buffered writing for Go applications.
|
Package writer provides asynchronous buffered writing for Go applications. |
Click to show internal directories.
Click to hide internal directories.