pull/78/head
Hunter Long 2018-09-28 00:22:58 -07:00
parent 81923a3b7c
commit 91ad727f50
17 changed files with 70 additions and 26 deletions

View File

@ -8,5 +8,5 @@
// Remember that you'll need to compile the static assets using Rice: // Remember that you'll need to compile the static assets using Rice:
// // cd source && rice embed-go // // cd source && rice embed-go
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package main package main

View File

@ -2,5 +2,5 @@
// Services, Hits, Failures, Users, service checking mechanisms, databases, and notifiers // Services, Hits, Failures, Users, service checking mechanisms, databases, and notifiers
// in the notifier package // in the notifier package
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package core package core

View File

@ -1,4 +1,4 @@
// Package Notifier contains the main functionality for the Statup Notification system // Package Notifier contains the main functionality for the Statup Notification system
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup/wiki/Notifiers
package notifier package notifier

View File

@ -22,11 +22,11 @@ import (
"time" "time"
) )
type Example struct { type ExampleNotifier struct {
*Notification *Notification
} }
var example = &Example{&Notification{ var example = &ExampleNotifier{&Notification{
Method: METHOD, Method: METHOD,
Host: "http://exmaplehost.com", Host: "http://exmaplehost.com",
Title: "Example", Title: "Example",
@ -85,98 +85,142 @@ func init() {
} }
// REQUIRED // REQUIRED
func (n *Example) Send(msg interface{}) error { func (n *ExampleNotifier) Send(msg interface{}) error {
message := msg.(string) message := msg.(string)
fmt.Printf("i received this string: %v\n", message) fmt.Printf("i received this string: %v\n", message)
return nil return nil
} }
// REQUIRED // REQUIRED
func (n *Example) Select() *Notification { func (n *ExampleNotifier) Select() *Notification {
return n.Notification return n.Notification
} }
// REQUIRED // REQUIRED
func (n *Example) OnSave() error { func (n *ExampleNotifier) OnSave() error {
msg := fmt.Sprintf("received on save trigger") msg := fmt.Sprintf("received on save trigger")
n.AddQueue(msg) n.AddQueue(msg)
return errors.New("onsave triggered") return errors.New("onsave triggered")
} }
// REQUIRED - BASIC EVENT // REQUIRED - BASIC EVENT
func (n *Example) OnSuccess(s *types.Service) { func (n *ExampleNotifier) OnSuccess(s *types.Service) {
msg := fmt.Sprintf("received a count trigger for service: %v\n", s.Name) msg := fmt.Sprintf("received a count trigger for service: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// REQUIRED - BASIC EVENT // REQUIRED - BASIC EVENT
func (n *Example) OnFailure(s *types.Service, f *types.Failure) { func (n *ExampleNotifier) OnFailure(s *types.Service, f *types.Failure) {
msg := fmt.Sprintf("received a failure trigger for service: %v\n", s.Name) msg := fmt.Sprintf("received a failure trigger for service: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL Test function before user saves // OPTIONAL Test function before user saves
func (n *Example) OnTest() error { func (n *ExampleNotifier) OnTest() error {
fmt.Printf("received a test trigger with form data: %v\n", n.Host) fmt.Printf("received a test trigger with form data: %v\n", n.Host)
return nil return nil
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnNewService(s *types.Service) { func (n *ExampleNotifier) OnNewService(s *types.Service) {
msg := fmt.Sprintf("received a new service trigger for service: %v\n", s.Name) msg := fmt.Sprintf("received a new service trigger for service: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnUpdatedService(s *types.Service) { func (n *ExampleNotifier) OnUpdatedService(s *types.Service) {
msg := fmt.Sprintf("received a update service trigger for service: %v\n", s.Name) msg := fmt.Sprintf("received a update service trigger for service: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnDeletedService(s *types.Service) { func (n *ExampleNotifier) OnDeletedService(s *types.Service) {
msg := fmt.Sprintf("received a delete service trigger for service: %v\n", s.Name) msg := fmt.Sprintf("received a delete service trigger for service: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnNewUser(s *types.User) { func (n *ExampleNotifier) OnNewUser(s *types.User) {
msg := fmt.Sprintf("received a new user trigger for user: %v\n", s.Username) msg := fmt.Sprintf("received a new user trigger for user: %v\n", s.Username)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnUpdatedUser(s *types.User) { func (n *ExampleNotifier) OnUpdatedUser(s *types.User) {
msg := fmt.Sprintf("received a updated user trigger for user: %v\n", s.Username) msg := fmt.Sprintf("received a updated user trigger for user: %v\n", s.Username)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnDeletedUser(s *types.User) { func (n *ExampleNotifier) OnDeletedUser(s *types.User) {
msg := fmt.Sprintf("received a deleted user trigger for user: %v\n", s.Username) msg := fmt.Sprintf("received a deleted user trigger for user: %v\n", s.Username)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnUpdatedCore(s *types.Core) { func (n *ExampleNotifier) OnUpdatedCore(s *types.Core) {
msg := fmt.Sprintf("received a updated core trigger for core: %v\n", s.Name) msg := fmt.Sprintf("received a updated core trigger for core: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnStart(s *types.Core) { func (n *ExampleNotifier) OnStart(s *types.Core) {
msg := fmt.Sprintf("received a trigger on Statup boot: %v\n", s.Name) msg := fmt.Sprintf("received a trigger on Statup boot: %v\n", s.Name)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnNewNotifier(s *Notification) { func (n *ExampleNotifier) OnNewNotifier(s *Notification) {
msg := fmt.Sprintf("received a new notifier trigger for notifier: %v\n", s.Method) msg := fmt.Sprintf("received a new notifier trigger for notifier: %v\n", s.Method)
n.AddQueue(msg) n.AddQueue(msg)
} }
// OPTIONAL // OPTIONAL
func (n *Example) OnUpdatedNotifier(s *Notification) { func (n *ExampleNotifier) OnUpdatedNotifier(s *Notification) {
msg := fmt.Sprintf("received a update notifier trigger for notifier: %v\n", s.Method) msg := fmt.Sprintf("received a update notifier trigger for notifier: %v\n", s.Method)
n.AddQueue(msg) n.AddQueue(msg)
} }
// Create a new notifier that includes a form for the end user to insert their own values
func Example() {
// Create a new variable for your Notifier
example = &ExampleNotifier{&Notification{
Method: "Example",
Title: "Example Notifier",
Description: "Example Notifier can hold many different types of fields for a customized look.",
Author: "Hunter Long",
AuthorUrl: "https://github.com/hunterlong",
Delay: time.Duration(1500 * time.Millisecond),
Limits: 7,
Form: []NotificationForm{{
Type: "text",
Title: "Host",
Placeholder: "Insert your Host here.",
DbField: "host",
SmallText: "you can also use SmallText to insert some helpful hints under this input",
}},
}}
// AddNotifier accepts a notifier to load into the Statup Notification system
AddNotifier(example)
}
// Add any type of interface to the AddQueue function when a service is successful
func Example_onSuccess() {
msg := fmt.Sprintf("this is a successful message as a string passing into AddQueue function")
example.AddQueue(msg)
}
// Add any type of interface to the AddQueue function when a service is successful
func Example_onFailure() {
msg := fmt.Sprintf("this is a failing message as a string passing into AddQueue function")
example.AddQueue(msg)
}
// The Send method will run the main functionality of your notifier
func Example_send() {
// example.Send(msg interface{})
for i := 0; i <= 10; i++ {
fmt.Printf("do something awesome rather than a loop %v\n", i)
}
}

View File

@ -1,5 +1,5 @@
// Package handlers holds all the HTTP requests and routes. All HTTP related // Package handlers holds all the HTTP requests and routes. All HTTP related
// functions are in this package. // functions are in this package.
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package handlers package handlers

View File

@ -5,5 +5,5 @@
// To see a full example of a notifier with all events, visit Statup's // To see a full example of a notifier with all events, visit Statup's
// notifier example code: https://github.com/hunterlong/statup/wiki/Notifier-Example // notifier example code: https://github.com/hunterlong/statup/wiki/Notifier-Example
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package notifiers package notifiers

View File

@ -4,5 +4,5 @@
// //
// To compile all the assets run `rice embed-go` in the source directory. // To compile all the assets run `rice embed-go` in the source directory.
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package source package source

View File

@ -1,4 +1,4 @@
// Package types contains all of the structs for objects in Statup including services, hits, failures, Core, and others. // Package types contains all of the structs for objects in Statup including services, hits, failures, Core, and others.
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package types package types

View File

@ -6,5 +6,5 @@
// You can overwrite the utils.Directory global variable by including // You can overwrite the utils.Directory global variable by including
// STATUP_DIR environment variable to be an absolute path. // STATUP_DIR environment variable to be an absolute path.
// //
// by Hunter Long // More info on: https://github.com/hunterlong/statup
package utils package utils