README
¶
queue
A highly flexible and extensible queue interface implementation in Go that provides a unified way to interact with different queue backends.
This package implements a generic queue interface that abstracts away the complexities of working with different queue systems. It provides a consistent API for common and usual operations while supporting various queue backends like RabbitMQ, AWS SQS, Kafka and others. The implementation includes robust error handling, metrics collection, and APM tracing capabilities.
Features
- Unified Queue Interface: Common interface for multiple queue backends (IQueue)
- Concurrent Operations: Support for both single and multi-queue operations
- Built-in Metrics: Comprehensive metrics tracking for all operations
- APM Integration: Built-in application performance monitoring with distributed tracing
- Extensible Architecture: Easy to implement new queue backends
- Pre/Post Operation Hooks: Customizable hooks for operation lifecycle management
- Type-Safe Operations: Generic type support for type-safe data handling
- RabbitMQ Implementation: Full featured RabbitMQ queue implementation included
- Robust Error Handling: Comprehensive error handling with customer error types
- Logging Support: Integrated logging system with different log levels
Install
go get github.com/thalesfsp/queue
Contributing
- Fork
- Clone
- Create a branch
- Make changes following the same standards as the project
- Run
make ci - Create a merge request
Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
customapm
Package customapm provides types and methods to deal APM.
|
Package customapm provides types and methods to deal APM. |
|
logging
Package logging provides the application logger.
|
Package logging provides the application logger. |
|
metrics
Package metrics provides a set of metrics for the application.
|
Package metrics provides a set of metrics for the application. |
|
shared
Package shared contains common shared information, and utilities.
|
Package shared contains common shared information, and utilities. |
|
Package queue provides a simple interface to interact with a queue.
|
Package queue provides a simple interface to interact with a queue. |
|
Package rabbitmq provides a RabbitMQ implementation of the queue interface.
|
Package rabbitmq provides a RabbitMQ implementation of the queue interface. |
Click to show internal directories.
Click to hide internal directories.