Versions in this module Expand all Collapse all v1 v1.1.0 May 3, 2018 v1.0.0 Dec 3, 2017 Changes in this version + type Coordinator struct + App *protocol.ApplicationContext + Log *zap.Logger + func (nc *Coordinator) Configure() + func (nc *Coordinator) Start() error + func (nc *Coordinator) Stop() error + type EmailNotifier struct + App *protocol.ApplicationContext + Log *zap.Logger + func (module *EmailNotifier) AcceptConsumerGroup(status *protocol.ConsumerGroupStatus) bool + func (module *EmailNotifier) Configure(name string, configRoot string) + func (module *EmailNotifier) GetGroupBlacklist() *regexp.Regexp + func (module *EmailNotifier) GetGroupWhitelist() *regexp.Regexp + func (module *EmailNotifier) GetLogger() *zap.Logger + func (module *EmailNotifier) GetName() string + func (module *EmailNotifier) Notify(status *protocol.ConsumerGroupStatus, eventID string, startTime time.Time, ...) + func (module *EmailNotifier) Start() error + func (module *EmailNotifier) Stop() error + type HTTPNotifier struct + App *protocol.ApplicationContext + Log *zap.Logger + func (module *HTTPNotifier) AcceptConsumerGroup(status *protocol.ConsumerGroupStatus) bool + func (module *HTTPNotifier) Configure(name string, configRoot string) + func (module *HTTPNotifier) GetGroupBlacklist() *regexp.Regexp + func (module *HTTPNotifier) GetGroupWhitelist() *regexp.Regexp + func (module *HTTPNotifier) GetLogger() *zap.Logger + func (module *HTTPNotifier) GetName() string + func (module *HTTPNotifier) Notify(status *protocol.ConsumerGroupStatus, eventID string, startTime time.Time, ...) + func (module *HTTPNotifier) Start() error + func (module *HTTPNotifier) Stop() error + type Module interface + AcceptConsumerGroup func(*protocol.ConsumerGroupStatus) bool + GetGroupBlacklist func() *regexp.Regexp + GetGroupWhitelist func() *regexp.Regexp + GetLogger func() *zap.Logger + GetName func() string + Notify func(*protocol.ConsumerGroupStatus, string, time.Time, bool) + type NullNotifier struct + App *protocol.ApplicationContext + CalledAcceptConsumerGroup bool + CalledConfigure bool + CalledNotify bool + CalledStart bool + CalledStop bool + Log *zap.Logger + func (module *NullNotifier) AcceptConsumerGroup(status *protocol.ConsumerGroupStatus) bool + func (module *NullNotifier) Configure(name string, configRoot string) + func (module *NullNotifier) GetGroupBlacklist() *regexp.Regexp + func (module *NullNotifier) GetGroupWhitelist() *regexp.Regexp + func (module *NullNotifier) GetLogger() *zap.Logger + func (module *NullNotifier) GetName() string + func (module *NullNotifier) Notify(status *protocol.ConsumerGroupStatus, eventID string, startTime time.Time, ...) + func (module *NullNotifier) Start() error + func (module *NullNotifier) Stop() error
Go to main page