Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + type MessageQueueInitSubscriber struct + func NewMessageQueueInitSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueInitSubscriber, error) + func (mqis *MessageQueueInitSubscriber) AddStorageOps(storageOps MessageQueueInitSubscriberOperations) + func (mqis *MessageQueueInitSubscriber) CloseMessageQueues() error + func (mqis *MessageQueueInitSubscriber) HandleQueueMessages(ctx context.Context) (time.Time, error) + type MessageQueueInitSubscriberOperations interface + HandleInitMessage func(queueMessage *kafka.Message) (bool, error) + type MessageQueueUpdateSubscriber struct + func NewMessageQueueUpdateSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueUpdateSubscriber, error) + func (mqus *MessageQueueUpdateSubscriber) AddStorageOps(storageOps MessageQueueUpdateSubscriberOperations) + func (mqus *MessageQueueUpdateSubscriber) CloseMessageQueue() error + func (mqus *MessageQueueUpdateSubscriber) HandleFirstQueueMessage(ctx context.Context, offsetTime time.Time) (bool, error) + func (mqus *MessageQueueUpdateSubscriber) HandleQueueMessage(ctx context.Context) (bool, error) + type MessageQueueUpdateSubscriberOperations interface + HandleUpdateMessage func(queueMessage *kafka.Message) (bool, error)
Go to main page