notifier

Dec 27, 2016

Changes in this version

type ContactData

+ User string

+ type Database interface

+ AddNotification func(notification *ScheduledNotification) error

+ FetchEvent func() (*EventData, error)

+ GetChecksCount func() (int64, error)

+ GetContact func(id string) (ContactData, error)

+ GetContacts func() ([]ContactData, error)

+ GetMetricsCount func() (int64, error)

+ GetNotifications func(to int64) ([]*ScheduledNotification, error)

+ GetSubscription func(id string) (SubscriptionData, error)

+ GetTagsSubscriptions func(tags []string) ([]SubscriptionData, error)

+ GetTrigger func(id string) (TriggerData, error)

+ GetTriggerEventsCount func(id string, from int64) int64

+ GetTriggerTags func(id string) ([]string, error)

+ GetTriggerThrottlingTimestamps func(id string) (time.Time, time.Time)

+ SetContact func(contact *ContactData) error

+ SetTriggerThrottlingTimestamp func(id string, next time.Time) error

type DbConnector

+ func (connector *DbConnector) DeregisterBot(messenger string) error

+ func (connector *DbConnector) DeregisterBots()

+ func (connector *DbConnector) GetContacts() ([]ContactData, error)

+ func (connector *DbConnector) GetIDByUsername(messenger, username string) (string, error)

+ func (connector *DbConnector) RegisterBotIfAlreadyNot(messenger string) bool

+ func (connector *DbConnector) SetContact(contact *ContactData) error

+ func (connector *DbConnector) SetUsernameID(messenger, username, id string) error

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Fatal func(args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Warning func(args ...interface{})

+ Warningf func(format string, args ...interface{})

type TriggerData

+ Desc string

Aug 29, 2016

Changes in this version

+ var SelfCheckInterval = time.Second * 10

+ func CheckSelfStateMonitorSettings() error

+ func SelfStateMonitor(shutdown chan bool, wg *sync.WaitGroup)

+ func ToBool(str string) bool

+ type Config struct

+ Front FrontConfig

+ Graphite GraphiteConfig

+ Notifier NotifierConfig

+ Redis RedisConfig

type DbConnector

+ func (connector *DbConnector) GetChecksCount() (int64, error)

+ func (connector *DbConnector) GetMetricsCount() (int64, error)

type EventData

+ func (event *EventData) GetPseudoTags() []string

+ type FrontConfig struct

+ URI string

+ type GraphiteConfig struct

+ Interval int64

+ Prefix string

+ URI string

+ type NotifierConfig struct

+ LogColor string

+ LogFile string

+ LogLevel string

+ ResendingTimeout string

+ SelfState SelfStateConfig

+ SenderTimeout string

+ Senders []map[string]string

+ type RedisConfig struct

+ DBID int

+ Host string

+ Port string

+ type SelfStateConfig struct

+ Contacts []map[string]string

+ Enabled string

+ LastCheckDelay int64

+ LastMetricReceivedDelay int64

+ NoticeInterval int64

+ RedisDisconectDelay int64

Mar 25, 2016

Changes in this version

type EventData

+ Message string

Feb 25, 2016

Changes in this version

type DbConnector

+ func (connector *DbConnector) GetTriggerEventsCount(triggerID string, from int64) int64

Jan 19, 2016

Changes in this version

type ScheduledNotification

+ func (notification *ScheduledNotification) GetKey() string

Jan 15, 2016

Changes in this version

+ type EventsData []EventData

+ func (events EventsData) GetSubjectState() string

type TriggerData

+ func (trigger *TriggerData) GetTags() string

Jan 12, 2016

Changes in this version

+ var GetNow = func() time.Time

+ func FetchEvents(shutdown chan bool, wg *sync.WaitGroup)

+ func FetchScheduledNotifications(shutdown chan bool, wg *sync.WaitGroup)

+ func GetWaitGroup() *sync.WaitGroup

+ func InitMetrics()

+ func InitRedisDatabase()

+ func NewRedisPool(redisURI string) *redis.Pool

+ func ProcessEvent(event EventData) error

+ func ProcessScheduledNotifications() error

+ func RegisterSender(senderSettings map[string]string, sender Sender) error

+ func SetDb(connector *DbConnector)

+ func SetLogger(logger *logging.Logger)

+ func SetSettings(settings Settings)

+ func StopSenders()

+ type ContactData struct

+ ID string

+ Type string

+ Value string

+ type DbConnector struct

+ Pool *redis.Pool

+ func (connector *DbConnector) AddNotification(notification *ScheduledNotification, next time.Time) error

+ func (connector *DbConnector) FetchEvent() (*EventData, error)

+ func (connector *DbConnector) GetContact(id string) (ContactData, error)

+ func (connector *DbConnector) GetNotifications(to int64) ([]*ScheduledNotification, error)

+ func (connector *DbConnector) GetSubscription(id string) (SubscriptionData, error)

+ func (connector *DbConnector) GetTagsSubscriptions(tags []string) ([]SubscriptionData, error)

+ func (connector *DbConnector) GetTrigger(id string) (TriggerData, error)

+ func (connector *DbConnector) GetTriggerNotificationsCount(triggerID string, from int64) int64

+ func (connector *DbConnector) GetTriggerTags(triggerID string) ([]string, error)

+ func (connector *DbConnector) GetTriggerThrottlingTimestamps(triggerID string) (time.Time, time.Time)

+ func (connector *DbConnector) SetTriggerThrottlingTimestamp(triggerID string, next time.Time) error

+ type EventData struct

+ Metric string

+ OldState string

+ State string

+ SubscriptionID string

+ Timestamp int64

+ TriggerID string

+ Value float64

+ type ScheduleData struct

+ Days []ScheduleDataDay

+ EndOffset int64

+ StartOffset int64

+ TimezoneOffset int64

+ func (schedule *ScheduleData) CalculateNextDelivery(nextTime time.Time) (time.Time, error)

+ type ScheduleDataDay struct

+ Enabled bool

+ type ScheduledNotification struct

+ Contact ContactData

+ Event EventData

+ SendFail int

+ Throttled bool

+ Timestamp int64

+ Trigger TriggerData

+ func ConvertNotifications(redisResponse interface{}) ([]*ScheduledNotification, error)

+ type Sender interface

+ Init func(senderSettings map[string]string, logger *logging.Logger) error

+ SendEvents func(events []EventData, contact ContactData, trigger TriggerData, throttled bool) error

+ type Settings interface

+ Get func(section, key string) string

+ GetInterface func(section, key string) interface{}

+ type SubscriptionData struct

+ Contacts []string

+ Enabled bool

+ ID string

+ Schedule ScheduleData

+ Tags []string

+ ThrottlingEnabled bool

+ type TriggerData struct

+ ErrorValue float64

+ ID string

+ Name string

+ Patterns []string

+ Tags []string

+ Targets []string

+ WarnValue float64