kafka

Documentation

Index

• func Exit()
• func Init(cfg *Config, log *logrus.Entry) error
• func Publish(topic string, msg []byte) error
• func Subscriber() *serviceImpl
• type Config
  • func (cfg *Config) Validate() error
• type Handler

Functions

func Exit

func Exit()

func Init

func Init(cfg *Config, log *logrus.Entry) error

func Publish

func Publish(topic string, msg []byte) error

func Subscriber

func Subscriber() *serviceImpl

Types

type Config

type Config struct {
	Address string `json:"address" required:"true"`
}

func (*Config) Validate

func (cfg *Config) Validate() error

type Handler

type Handler func([]byte, map[string]string) error