kafkabus

Documentation

Index

• type Config
• type Emitter
  • func NewEmitter(c Config) (emitter Emitter, err error)
• type Listener
  • func NewListener(c Config) (listener Listener, err error)
• type Message

Types

type Config

type Config struct {
	Url      string
	Attempts int
	Timeout  time.Duration
}

type Emitter

type Emitter interface {
	Emit() chan *Message
	Close()
}

func NewEmitter

func NewEmitter(c Config) (emitter Emitter, err error)

type Listener

type Listener interface {
	On(topic string, partition int32, fn fnHandler) error
	Close()
}

func NewListener

func NewListener(c Config) (listener Listener, err error)

type Message

type Message struct {
	Topic     string
	Payload   interface{}
	Partition int32
}