kafkaconfigurator

Documentation

Index

• Constants
• type BrokerHandler
  • func NewBrokerHandler(l *logrus.Entry, brokers string) *BrokerHandler
  • func (bh *BrokerHandler) Close() error
  • func (bh *BrokerHandler) ReadFromTopicWithContext(ctx context.Context, topic string, consumerGroupID string, ...) error
• type Plugin
  • func New() *Plugin
  • func (p *Plugin) Boot(conf interface{}, dependencies ...interface{}) plugins.Plugin
  • func (p *Plugin) Close() error
  • func (p *Plugin) IsEnabled() bool
  • func (p *Plugin) LoadConfig(brokers string, topic string, updateFn func(conf string) error) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) Start() error

Constants

const (
	Name = "kafkaconfigurator"
)

Types

type BrokerHandler

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

func NewBrokerHandler

func NewBrokerHandler(l *logrus.Entry, brokers string) *BrokerHandler

func (*BrokerHandler) Close

func (bh *BrokerHandler) Close() error

func (*BrokerHandler) ReadFromTopicWithContext

func (bh *BrokerHandler) ReadFromTopicWithContext(ctx context.Context, topic string, consumerGroupID string, messageC chan kafka.Message) error

type Plugin

type Plugin struct {
	Logger *log.Entry
	// contains filtered or unexported fields
}

func New

func New() *Plugin

func (*Plugin) Boot

func (p *Plugin) Boot(conf interface{}, dependencies ...interface{}) plugins.Plugin

func (*Plugin) Close

func (p *Plugin) Close() error

func (*Plugin) IsEnabled

func (p *Plugin) IsEnabled() bool

func (*Plugin) LoadConfig

func (p *Plugin) LoadConfig(brokers string, topic string, updateFn func(conf string) error) error

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) Start

func (p *Plugin) Start() error