Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + type FakeInitPublisher struct + func (fip *FakeInitPublisher) CreateInitialDataMessages(ctx context.Context) ([]kafka.Message, error) + func (fip *FakeInitPublisher) HasInitialData() (bool, error)
Go to main page