notifier

package module

Go to main page

Versions in this module

v1

v1.0.6

May 4, 2016

v1.0.5

Mar 25, 2016

Changes in this version

type EventData

+ Message string

v1.0.4

Feb 25, 2016

Changes in this version

type DbConnector

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

v1.0.3

Jan 19, 2016

Changes in this version

type ScheduledNotification

+ func (notification *ScheduledNotification) GetKey() string

v1.0.2

Jan 15, 2016

Changes in this version

+ type EventsData []EventData

+ func (events EventsData) GetSubjectState() string

type TriggerData

+ func (trigger *TriggerData) GetTags() string

v1.0.1

Jan 14, 2016

v1.0.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL