redi

Documentation

Index

• Constants
• Variables
• func Init()
• func PopAllIM(queue string) []*model.IM
• func PopAllMail() []*model.Mail
• func PopAllPhone() []*model.Sms
• func PopAllSms() []*model.Sms
• func WriteIM(tos []string, content string)
• func WriteIMModel(im *model.IM, queue string)
• func WriteImCard(conMap map[string]string)
• func WriteMail(tos []string, subject, content string)
• func WriteMailModel(mail *model.Mail)
• func WritePhone(tos []string, content string)
• func WritePhoneModel(phone *model.Sms)
• func WriteSms(tos []string, content string)
• func WriteSmsModel(sms *model.Sms)

Constants

const (
	IM_QUEUE_NAME                = "/im"
	SMS_QUEUE_NAME               = "/sms"
	MAIL_QUEUE_NAME              = "/mail"
	PHONE_QUEUE_NAME             = "/phone"
	FAILED_IM_QUEUE_NAME         = "/failed/im"
	FINALLY_FAILED_IM_QUEUE_NAME = "/finally_failed/im"
)

const SEP = "|||"

const TIMEOUT = 60 * 20

Variables

var RedisCluster *redisc.Cluster

Functions

func Init

func Init()

初始化redis集群

func PopAllIM

func PopAllIM(queue string) []*model.IM

func PopAllMail

func PopAllMail() []*model.Mail

func PopAllPhone

func PopAllPhone() []*model.Sms

func PopAllSms

func PopAllSms() []*model.Sms

func WriteIM

func WriteIM(tos []string, content string)

func WriteIMModel

func WriteIMModel(im *model.IM, queue string)

func WriteImCard

func WriteImCard(conMap map[string]string)

func WriteMail

func WriteMail(tos []string, subject, content string)

func WriteMailModel

func WriteMailModel(mail *model.Mail)

func WritePhone

func WritePhone(tos []string, content string)

电话报警接口

func WritePhoneModel

func WritePhoneModel(phone *model.Sms)

func WriteSms

func WriteSms(tos []string, content string)

func WriteSmsModel

func WriteSmsModel(sms *model.Sms)