startup_schema

Documentation

Index

• type ConfluentClientOptions
  • func (opts *ConfluentClientOptions) ConfluentClient(options ...confluent.Option) *confluent.Client
• type SchemaRegistryOptions
  • func (opts *SchemaRegistryOptions) Initialize(consul *startup_consul.ConsulOptions)
  • func (opts *SchemaRegistryOptions) SchemaRegistry() schema.Registry

Types

type ConfluentClientOptions

type ConfluentClientOptions struct {
	ConfluentUrl startup.URL `long:"confluent-url" description:"URL to the confluent schema registry."`
	// contains filtered or unexported fields
}

func (*ConfluentClientOptions) ConfluentClient

func (opts *ConfluentClientOptions) ConfluentClient(options ...confluent.Option) *confluent.Client

type SchemaRegistryOptions

type SchemaRegistryOptions struct {
	SchemaBackend string `long:"schema-backend" default:"consul" description:"Avro schema registry to use. Can be 'consul' or 'noop'."`
	// contains filtered or unexported fields
}

Deprecated: Stop using this and use the more recent startup_event thingy.

func (*SchemaRegistryOptions) Initialize

func (opts *SchemaRegistryOptions) Initialize(consul *startup_consul.ConsulOptions)

func (*SchemaRegistryOptions) SchemaRegistry

func (opts *SchemaRegistryOptions) SchemaRegistry() schema.Registry