Directories
¶
| Path | Synopsis |
|---|---|
|
mq
Package mq provides a FileHandler implementation for message queue sources.
|
Package mq provides a FileHandler implementation for message queue sources. |
|
Package mqreader provides interfaces and types for reading messages from various message queue systems without consuming them.
|
Package mqreader provides interfaces and types for reading messages from various message queue systems without consuming them. |
|
kafka
Package kafka provides a Kafka implementation of the MessageQueueReader interface.
|
Package kafka provides a Kafka implementation of the MessageQueueReader interface. |
|
sqs
Package sqs provides an SQS implementation of the MessageQueueReader interface.
|
Package sqs provides an SQS implementation of the MessageQueueReader interface. |
Click to show internal directories.
Click to hide internal directories.