goka

Documentation

Index

• func ConfigAdd(path string)
• func NewEmitter(ctx context.Context) (*goka.Emitter, error)
• func NewEmitterWithConfigPath(ctx context.Context, path string) (*goka.Emitter, error)
• func NewEmitterWithOptions(ctx context.Context, o *Options) (*goka.Emitter, error)
• type Logger
  • func (s *Logger) Debugf(msg string, args ...interface{})
  • func (s *Logger) Print(msgs ...interface{})
  • func (s *Logger) Printf(msg string, args ...interface{})
  • func (s *Logger) Println(msgs ...interface{})
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)

Functions

func ConfigAdd

func ConfigAdd(path string)

func NewEmitter

func NewEmitter(ctx context.Context) (*goka.Emitter, error)

NewEmitter returns connection with default options.

func NewEmitterWithConfigPath

func NewEmitterWithConfigPath(ctx context.Context, path string) (*goka.Emitter, error)

NewEmitterWithConfigPath returns connection with options from config path.

func NewEmitterWithOptions

func NewEmitterWithOptions(ctx context.Context, o *Options) (*goka.Emitter, error)

NewEmitterWithOptions returns connection with options.

Types

type Logger

type Logger struct {
}

func (*Logger) Debugf

func (s *Logger) Debugf(msg string, args ...interface{})

func (*Logger) Print

func (s *Logger) Print(msgs ...interface{})

func (*Logger) Printf

func (s *Logger) Printf(msg string, args ...interface{})

func (*Logger) Println

func (s *Logger) Println(msgs ...interface{})

type Options

type Options struct {
	Brokers []string
	Topic   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.