startup_events

type ConfluentClientProvider interface {
	ConfluentClient() *schemaregistry.Client
}

type EventOptions struct {
	EventSenderConfig string `` /* 165-byte string literal not displayed */

	Inputs struct {
		// A function to create the event topics. This option must be specified.
		Topics events.TopicsFunc `validate:"required"`

		// optional kafka config to use with the kafka events producer
		KafkaConfig *sarama.Config
	}
	// contains filtered or unexported fields
}

type KafkaClientProvider interface {
	KafkaClient() sarama.Client
}

type SchemaRegistryProvider interface {
	SchemaRegistry() schema.Registry
}