Documentation ¶
Index ¶
- Constants
- Variables
- func NewClient(kvClient *kv.Client, messagesClient *messages.Client, logger *zap.Logger) *streamClient
- func WithConsumerGroupID(id string) consumeOpt
- func WithConsumerID(id string) consumeOpt
- func WithInitialOffsetBehaviour(b offsetBehaviour) consumeOpt
- func WithMaxBatchSize(size int) consumeOpt
- type ShardConsumer
Constants ¶
View Source
const ( OFFSET_BEHAVIOUR_FROM_START offsetBehaviour = iota OFFSET_BEHAVIOUR_FROM_NOW )
Variables ¶
Functions ¶
func WithConsumerGroupID ¶
func WithConsumerGroupID(id string) consumeOpt
func WithConsumerID ¶
func WithConsumerID(id string) consumeOpt
func WithInitialOffsetBehaviour ¶
func WithInitialOffsetBehaviour(b offsetBehaviour) consumeOpt
func WithMaxBatchSize ¶
func WithMaxBatchSize(size int) consumeOpt
Types ¶
type ShardConsumer ¶
type ShardConsumer func([]*messages.StoredMessage) (int, error)
Click to show internal directories.
Click to hide internal directories.