Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventOptions ¶
type EventOptions struct {
AsyncBufferSize uint `` /* 216-byte string literal not displayed */
WriteToFile string `long:"event-sender-file" env:"EVENT_SENDER_FILE" description:"File to write all events to. Sender will be encoded as json"`
Inputs struct {
// A function to define event mapping & existing topics
Topics events.TopicsFunc `validate:"required"`
// OutboxTable is the name of the outbox table
OutboxTable string `json:"outboxTable"`
}
// contains filtered or unexported fields
}
func (*EventOptions) EventSender ¶
func (opts *EventOptions) EventSender() events.EventSender
func (*EventOptions) Initialize ¶ added in v2.7.0
func (opts *EventOptions) Initialize(kafkaOptions startup_kafka.KafkaOptions)
Click to show internal directories.
Click to hide internal directories.