Versions in this module Expand all Collapse all v1 v1.0.0 Nov 25, 2019 Changes in this version + type ConcurrentMessageSource interface + ConsumeMessagesConcurrently func(ctx context.Context, handler ConsumerMessageHandler, ...) error + type ConsumerErrorHandler func(ConsumerMessage, error) error + type ConsumerMessage struct + Data []byte + type ConsumerMessageHandler func(ConsumerMessage) error + type MessageSink interface + PutMessage func(ProducerMessage) error + type MessageSource interface + ConsumeMessages func(ctx context.Context, handler ConsumerMessageHandler, ...) error + type ProducerMessage interface + Marshal func() ([]byte, error) + type SimpleProducerMessage []byte + func (sm SimpleProducerMessage) Marshal() ([]byte, error) + type Status struct + Problems []string + Working bool + type Statuser interface + Status func() (*Status, error)
Go to main page