startup_events

package
v2.8.4 Latest Latest
Warning

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

Go to latest
Published: Jul 13, 2026 License: MIT Imports: 10 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 {
	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)

Jump to

Keyboard shortcuts

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