Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventOptions ¶
type EventOptions struct {
ConfluentURL string `` /* 172-byte string literal not displayed */
Async struct {
Kafka struct {
Addr string `` /* 142-byte string literal not displayed */
DisableTLS bool `` /* 130-byte string literal not displayed */
Replication int16 `` /* 167-byte string literal not displayed */
Properties []string `` /* 247-byte string literal not displayed */
}
BufferSize uint `` /* 208-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 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(clientId string) events.EventSender
Click to show internal directories.
Click to hide internal directories.