Package mock_kafkacommon is a generated GoMock package.

CreateEdgeEvent creates an event with standard CRC fields and edge payload.

NewConsumerService returns a new service.

NewKafkaConfigMapService returns a new service.

NewProducerService returns a new service.

NewTopicService returns a new service.

RecordKeyCreateCommit kafka record key const for creating a commit.

RecordKeyCreateImage kafka record key const for creating an image (wrapper for commit and installer).

RecordKeyCreateImageUpdate kafka record key const for creating an update.

RecordKeyCreateInstaller kafka record key const for creating an installer.

RecordKeyCreateKickstart kafka record key const for creating and injecting a kickstart file.

TopicFleetmgmtImageBuild topic name.

TopicFleetmgmtImageISOBuild topic name.

TopicFleetmgmtUpdateRepoRequested topic name for update repo requested event.

TopicFleetmgmtUpdateWriteTemplateRequested topic name for write template playbook event.

TopicInventoryEvents external topic for hosted inventory events.

TopicPlaybookDispatcherRuns external topic for playbook dispatcher results.

ConsumerService is the consumer service for edge.

KafkaConfigMapService is the config map service.

ProducerService is the producer service for edge.

TopicNotFoundError indicates the account was nil.

TopicService is the service struct.

Consumer is an interface for a kafka consumer, it matches the confluent consumer type definition.

ConsumerServiceInterface is the interface that defines the consumer service.

KafkaConfigMapServiceInterface is the interface that defines the config map service.

Producer is an interface for a kafka producer, it matches the confluent producer type definition.

ProducerServiceInterface is an interface that defines the producer service.

TopicServiceInterface is the interface for the service.