startup_events

Documentation

Index

• type EventOptions
  • func (opts *EventOptions) EventSender(kafkaClient KafkaClientProvider, registry SchemaRegistryProvider) events.EventSender
• type KafkaClientProvider
• type SchemaRegistryProvider

Types

type EventOptions

type EventOptions struct {
	Sender string `long:"event-sender" default:"none" description:"Event sender to use. Can be 'none', 'stdout', 'file:name.gz' or 'kafka'."`

	KafkaEncoder           string `long:"event-kafka-encoder" default:"avro" description:"Event encoder to use with kafka. Valid options are 'json' and 'avro'."`
	KafkaReplicationFactor int16  `long:"event-kafka-replication-factor" validate:"min=1" default:"1" description:"Replication factor for kafka topics."`

	Inputs struct {
		// Enable blocking. This should normally not be used for production and only
		// be used in batch cli tools
		KafkaBlocking bool

		// A function to create the event topics. This option must be specified.
		Topics events.TopicsFunc `validate:"required"`
	}
	// contains filtered or unexported fields
}

func (*EventOptions) EventSender

func (opts *EventOptions) EventSender(kafkaClient KafkaClientProvider, registry SchemaRegistryProvider) events.EventSender

type KafkaClientProvider

type KafkaClientProvider interface {
	KafkaClient() sarama.Client
}

type SchemaRegistryProvider

type SchemaRegistryProvider interface {
	SchemaRegistry() schema.Registry
}