Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + type FakeInitSubscriber struct + func (fis *FakeInitSubscriber) HandleInitMessage(queueMessage *kafka.Message) (bool, error) + type FakeUpdateSubscriber struct + func (fus *FakeUpdateSubscriber) HandleUpdateMessage(queueMessage *kafka.Message) (bool, error)
Go to main page