startup_events

package
v2.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 12, 2026 License: MIT Imports: 14 Imported by: 0

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 `long:"event-sender-confluent-url" env:"EVENT_SENDER_CONFLUENT_URL" description:"Confluent schema registry url."`

	Async struct {
		Kafka struct {
			Addr        string   `long:"event-sender-kafka-addr" env:"EVENT_SENDER_KAFKA_ADDR" description:"Kafka bootstrap hosts"`
			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"`
		OutboxTable string            `json:"outboxTable"`
	}
	// contains filtered or unexported fields
}

func (*EventOptions) EventSender

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL