cron

Documentation

Index

• Variables
• func ConsumeIMSms()
• func ConsumeMail()
• func ConsumePhone()
• func ConsumeWechat()
• func GetEndpoint(content string) string
• func InitWorker()
• func RecordAlarm(recordMsg string)
• func RecordPhoneAlarm(recordMsg string)
• func SendMail(mail *model.Mail)
• func SendMailList(L []*model.Mail)
• func SendPhone(phone *model.Phone)
• func SendPhoneList(L []*model.Phone)
• func SendSms(imsms *model.IMSms)
• func SendSmsList(L []*model.IMSms)
• func SendWechat(sms *model.WechatSms)
• func SendWechatList(L []*model.WechatSms)
• func TransContent(content string) string
• func UpdateHostMap()
• type ResponseHost
• type SafeHostMap
  • func (this *SafeHostMap) GetHosts(url string)
  • func (this *SafeHostMap) GetIP(endpoint string) string
  • func (this *SafeHostMap) GetIPByEndpoint(endpoint string) string

Variables

var (
	IMSmsWorkerChan  chan int
	MailWorkerChan   chan int
	PhoneWorkerChan  chan int
	WechatWorkerChan chan int
)

var HostMap = &SafeHostMap{M: make(map[string]string)}

var IMSender im.IM99U

var MailSender smtp.SmtpMailSender

var PhoneSender nexmo.Nexmo

Functions

func ConsumeIMSms

func ConsumeIMSms()

func ConsumeMail

func ConsumeMail()

func ConsumePhone

func ConsumePhone()

func ConsumeWechat

func ConsumeWechat()

func GetEndpoint

func GetEndpoint(content string) string

该函数可以搜索content，并从中提取 Endpoint: 后面跟的内容。判断依据是非数字字母下划线中划线

func InitWorker

func InitWorker()

func RecordAlarm

func RecordAlarm(recordMsg string)

func RecordPhoneAlarm

func RecordPhoneAlarm(recordMsg string)

func SendMail

func SendMail(mail *model.Mail)

sdp function of send mail mail acount set by cfg file

func SendMailList

func SendMailList(L []*model.Mail)

func SendPhone

func SendPhone(phone *model.Phone)

func SendPhoneList

func SendPhoneList(L []*model.Phone)

func SendSms

func SendSms(imsms *model.IMSms)

func SendSmsList

func SendSmsList(L []*model.IMSms)

func SendWechat

func SendWechat(sms *model.WechatSms)

func SendWechatList

func SendWechatList(L []*model.WechatSms)

func TransContent

func TransContent(content string) string

func UpdateHostMap

func UpdateHostMap()

Types

type ResponseHost

type ResponseHost struct {
	Ip       string `json:"ip,omitempty"`
	Endpoint string `json:"endpoint,omitempty"`
}

type SafeHostMap

type SafeHostMap struct {
	sync.Mutex
	M map[string]string
}

endpoint-ip kv

func (*SafeHostMap) GetHosts

func (this *SafeHostMap) GetHosts(url string)

func (*SafeHostMap) GetIP

func (this *SafeHostMap) GetIP(endpoint string) string

func (*SafeHostMap) GetIPByEndpoint

func (this *SafeHostMap) GetIPByEndpoint(endpoint string) string