startup_events

Documentation

Index

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

Types

type ConfluentClientProvider

type ConfluentClientProvider interface {
	ConfluentClient() *schemaregistry.Client
}

type EventOptions

type EventOptions struct {
	EventSenderConfig string `` /* 249-byte string literal not displayed */
	DisableTls        bool   `long:"event-sender-disable-tls" description:"Do not enable tls."`

	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

type SchemaRegistryProvider

type SchemaRegistryProvider interface {
	SchemaRegistry() schema.Registry
}