confluent

Documentation

Index

• func ConfigAdd(path string)
• func New(ctx context.Context) (publisher.Driver, error)
• func NewWithConfigPath(ctx context.Context, path string) (publisher.Driver, error)
• func NewWithOptions(ctx context.Context, options *Options) publisher.Driver
• type Logger
  • func NewLogger(producer *kafka.Producer, level string) *Logger
  • func (s *Logger) Start()
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)

Functions

func ConfigAdd

func ConfigAdd(path string)

func New

func New(ctx context.Context) (publisher.Driver, error)

New returns connection with default options.

func NewWithConfigPath

func NewWithConfigPath(ctx context.Context, path string) (publisher.Driver, error)

NewWithConfigPath returns connection with options from config path.

func NewWithOptions

func NewWithOptions(ctx context.Context, options *Options) publisher.Driver

NewWithOptions returns connection with options.

Types

type Logger

type Logger struct {
	// contains filtered or unexported fields
}

func NewLogger

func NewLogger(producer *kafka.Producer, level string) *Logger

func (*Logger) Start

func (s *Logger) Start()

type Options

type Options struct {
	Log struct {
		Level string
	}
}

Options kafka connection options.

func NewOptions

func NewOptions() (*Options, error)

NewOptions returns options from config file or environment vars.

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

NewOptionsWithPath unmarshals a given key path into options and returns it.