Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeInitPublisher ¶
func (*FakeInitPublisher) CreateInitialDataMessages ¶
func (fip *FakeInitPublisher) CreateInitialDataMessages( ctx context.Context) ([]kafka.Message, error)
func (*FakeInitPublisher) HasInitialData ¶
func (fip *FakeInitPublisher) HasInitialData() (bool, error)
Click to show internal directories.
Click to hide internal directories.