README
¶
RIP
Was used by old evensource modules, which were suporessed by https://github.com/replaygaming/sse
Consumer Go package
This wraps the message consumer logic into a small package. Currently only contains a google pubsub backend but it can be extended for other backends in the future
Build
go build
Yes. That simple
Test
With a pubsub emulator running, then... Start a pubsub emulator with
gcloud beta emulators pubsub start
Then initialize the environment and run the tests with
eval $(gcloud beta emulators pubsub env-init)
go test
Once again, yes... that simple :)
Documentation
godoc github.com/replaygaming/consumer
BOOM 💥
Documentation
¶
Overview ¶
Consumer package provides a very thin abstraction around message consuming. It assumes a simple message and consumer interface that can consume messages and acknowledge them
Index ¶
Constants ¶
View Source
const ContextDuration time.Duration = 30 * time.Second
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer interface {
// Creates a channel that will receive messages. Each message should be
// acknowledged once you're done with it through the Done() method on the
// message
Consume() (chan Message, error)
// Signals the backend to remove this consumer
Remove() error
}
Represents a consumer
func NewConsumer ¶
Creates a new consumer
Source Files
Click to show internal directories.
Click to hide internal directories.