Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + const CompressionCodecGzip + const CompressionCodecLz4 + const CompressionCodecNone + const CompressionCodecSnappy + const CompressionCodecZstd + type MessageQueueInitPublisher struct + func NewMessageQueueInitPublisher(publishOptions *MessageQueuePublisherOptions, ...) (*MessageQueueInitPublisher, error) + func (mqip *MessageQueueInitPublisher) AddStorageOps(storageOps MessageQueueInitPublisherOperations) + func (mqip *MessageQueueInitPublisher) CloseMessageQueues() error + func (mqip *MessageQueueInitPublisher) GetMaxBatchSize() int + func (mqip *MessageQueueInitPublisher) HandleInitQueueMessages(ctx context.Context) error + type MessageQueueInitPublisherOperations interface + CreateInitialDataMessages func(ctx context.Context) ([]kafka.Message, error) + HasInitialData func() (bool, error) + type MessageQueuePublisherOptions struct + CompressionCodec string + func NewMessageQueuePublisherOptions() *MessageQueuePublisherOptions + func (mqpo *MessageQueuePublisherOptions) AddFlags(flagSet *pflag.FlagSet) + type MessageQueueUpdatePublisher struct + func NewMessageQueueUpdatePublisher(messageQueueConfig *messagequeue.MessageQueueConfig, topic string, ...) (*MessageQueueUpdatePublisher, error) + func (mqup *MessageQueueUpdatePublisher) CloseMessageQueue() error + func (mqup *MessageQueueUpdatePublisher) GetMaxBatchSize() int + func (mqup *MessageQueueUpdatePublisher) WriteQueueMessages(messages []kafka.Message) error