Plugins
The samber/ro library comes with a rich ecosystem of plugins that extend its core functionality. These plugins provide specialized operators and utilities for common use cases like data encoding, HTTP requests, observability, file system operations, and much more.
Each plugin is designed to be lightweight and focused on a specific domain, making it easy to add just the functionality you need to your reactive streams.
Reference
📄️ Introduction
Extend ro with powerful plugins for bytes, encoding, HTTP, observability, and more
📄️ Bytes
Byte manipulation and conversion utilities for observable streams.
📄️ Strings
String manipulation and text processing utilities for streams.
📄️ iter
Iterator utilities and Go 1.23+ iter package integration.
📄️ Encoding / JSON
JSON encoding and decoding utilities for streams.
📄️ Encoding / Base64
Base64 encoding and decoding utilities for streams.
📄️ Encoding / JSON / v2
JSON encoding and decoding utilities for streams.
📄️ Encoding / YAML
YAML encoding and decoding utilities for streams.
📄️ Encoding / XML
XML encoding and decoding utilities for streams.
📄️ Encoding / Gob
Gob encoding and decoding utilities for streams.
📄️ Encoding / CSV
CSV encoding and decoding utilities for streams.
📄️ IO
I/O operations and file system utilities for streams.
📄️ HTTP Client
HTTP utilities and request handling for streams.
📄️ Signal
OS signal handling and system signal utilities for streams.
📄️ Regexp
Regular expression matching and text pattern utilities.
📄️ Sort
Sorting algorithms and data ordering utilities for streams.
📄️ Strconv
String conversion utilities for numeric and boolean types.
📄️ Template
Template processing and text templating utilities.
📄️ Testify
Testing utilities and assertion helpers for stream testing.
📄️ Cron
Cron job scheduling and time-based task utilities.
📄️ Proc
Process management and system process utilities for streams.
📄️ FSNotify
File system monitoring and file change detection utilities.
📄️ ozzo/ozzo-validation
Data validation utilities using ozzo-validation library.
📄️ Rate limit (Native)
Native Go rate limiting utilities and request throttling for streams.
📄️ Rate limit / Ulule
Advanced rate limiting using ulule/limiter library.
📄️ Logger / log
Logging utilities using Go's standard log package.
📄️ Logger / Logrus
Structured logging utilities using logrus library.
📄️ Logger / Sentry
Error tracking and logging utilities using Sentry.
📄️ Logger / slog
Structured logging utilities using Go's slog package.
📄️ Logger / Zap
High-performance structured logging using zap library.
📄️ Logger / Zerolog
Fast and simple structured logging using zerolog library.
📄️ samber/hot
In-memory cache library
📄️ samber/oops
Error handling and panic recovery utilities.
📄️ samber/psi
Performance monitoring and system metrics utilities.
📄️ Hyperloglog
HyperLogLog cardinality estimation and probabilistic data structures.