startup_events

Documentation

Index

• type EventOptions
  • func (opts *EventOptions) EventSender(clientId string) events.EventSender

Types

type EventOptions

type EventOptions struct {
	ConfluentURL startup.URL `` /* 139-byte string literal not displayed */

	Async struct {
		Kafka struct {
			Addr        string                 `long:"event-sender-kafka-addr" default:"kafka.shared.svc.cluster.local:9093" description:"Kafka bootstrap hosts"`
			DisableTLS  bool                   `long:"event-sender-kafka-disable-tls" description:"Disable TLS, might simplify local testing"`
			Replication int16                  `long:"event-sender-kafka-replication-factor" default:"3" description:"Replication factor to use when creating kafka topics"`
			Properties  map[string]interface{} `` /* 198-byte string literal not displayed */
		}

		BufferSize uint `` /* 171-byte string literal not displayed */
	}

	WriteToFile string `long:"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