Categorygithub.com/denislobanov/go-pubsub
modulepackage
1.1.1
Repository: https://github.com/denislobanov/go-pubsub.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
2
Dependents
14
Files
43 SLOC

# README

go-pubsub

A simple abstraction for message publishing and consumption that presents a uniform API, regardless of the underlying implementation.

Current implementations and their status

ImplementationStatus
Mock (in memory testing implementation)incomplete
Apache Kafkabeta
Nats streamingbeta
AMQPincomplete
AWS SQSbeta
AWS SNSbeta

The API is not yet guaranteed but changes should be minimal from now.

# Packages

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Structs

No description provided by the author
Status represents a snapshot of the state of a source or sink.

# Interfaces

ConcurrentMessageSource concurrent message consumer.
No description provided by the author
No description provided by the author
ProducerMessage is an individual message that can be sent.
Statuser is the interface that wraps the Status method.

# Type aliases

ConsumerErrorHandler is invoked when a message can not be processed.
ConsumerMessageHandler processes messages, and should return an error if it is unable to do so.
SimpleProducerMessage is a convenience type for simply sending byte slices.