Documentation
¶
Index ¶
- Constants
- func AddMessageTask(ctx persistence.TxContext, messageId int, messageInstanceId int) (task model.MessageTask, err error)
- func AddRunningTask(ctx persistence.TxContext, task model.MessageTask) (runningTask model.MessageRunningTask, err error)
- func CalcPageOffset(p app.Pager) int
- func CancelExpiredTask(taskId int)
- func CreateApnsMessage(ctx persistence.TxContext, message model.MessageInfo, ...) (m model.ApnsMessageInfo, err error)
- func CreateMailMessage(ctx persistence.TxContext, message model.MessageInfo, ...) (m model.MailMessageInfo, err error)
- func CreateMessage(ctx persistence.TxContext, org int, subject string, ...) (m model.MessageInfo, err error)
- func CreateMessageTemplate(code, name, body, templateId, params, description string, ...) (m model.MessageTemplate, err error)
- func CreateSmsMessage(ctx persistence.TxContext, message model.MessageInfo, ...) (m model.SmsMessageInfo, err error)
- func DeleteRunningTask(ctx persistence.TxContext, id int) (err error)
- func DeleteRunningTaskByTaskId(ctx persistence.TxContext, taskId int) (err error)
- func GetApnsByMessageId(msgId int) (m model.ApnsMessageInfo, err error)
- func GetClientByAppId(appId string) (c model.OpenClient, err error)
- func GetClientById(ctx persistence.OrmContext, id int) (c model.OpenClient, err error)
- func GetClients(ctx persistence.OrmContext, key string) (c []model.OpenClient, err error)
- func GetDefMessageSender(org int, category msg.MessageCategory, provider msg.MessageProvider) (s model.MessageSenderInfo, err error)
- func GetExpiredTasks(size int, timeLatest time.Time) (tasks []model.MessageRunningTask, err error)
- func GetMailByMessageId(msgId int) (m model.MailMessageInfo, err error)
- func GetMessageById(id int) (m model.MessageInfo, err error)
- func GetMessageTask(id int) (t model.MessageTask, err error)
- func GetMessageTemplateByCode(code string) (tpl model.MessageTemplate, err error)
- func GetMessageTemplateById(id int) (tpl model.MessageTemplate, err error)
- func GetMessageTemplates(org int, category msg.MessageCategory, provider msg.MessageProvider) (templates []model.MessageTemplate, err error)
- func GetMessageToSend(size int) (messages []model.MessageInfo, err error)
- func GetMessages(status int, category int, page app.Pager) (p app.Pager, messages []model.MessageInfo, err error)
- func GetSmsByMessageId(msgId int) (m model.SmsMessageInfo, err error)
- func GetTaskByMessage(messageId int) (t model.MessageTask, err error)
- func GetTaskList(status int, page app.Pager) (p app.Pager, list []model.MessageTask, err error)
- func GetTemplateByCode(code string, category msg.MessageCategory) (s model.MessageTemplate, err error)
- func GetTenant(code string) (t model.Tenant, err error)
- func TaskSendFail(messageId int)
- func UpdateMessagePriority(id int, priority int) (m model.MessageInfo, err error)
- func UpdateMessageStatus(ctx persistence.TxContext, id int, status int) (m model.MessageInfo, err error)
- func UpdateMessageTemplate(status int, code, name, body, description string) (m model.MessageTemplate, err error)
- func UpdateTaskStatus(ctx persistence.TxContext, taskId int, status int) (task model.MessageTask, err error)
- type PagerReq
- type PagerRes
Constants ¶
View Source
const ( ConditionIgnore = 0 DefaultPageNo = 1 DefaultPageSize = 10 )
Variables ¶
This section is empty.
Functions ¶
func AddMessageTask ¶
func AddMessageTask(ctx persistence.TxContext, messageId int, messageInstanceId int) (task model.MessageTask, err error)
创建投送task 从未投送的message中取出一个
func AddRunningTask ¶
func AddRunningTask(ctx persistence.TxContext, task model.MessageTask) (runningTask model.MessageRunningTask, err error)
func CalcPageOffset ¶ added in v0.11.0
func CalcPageOffset(p app.Pager) int
func CreateApnsMessage ¶
func CreateApnsMessage(ctx persistence.TxContext, message model.MessageInfo, sender model.MessageSenderInfo, mode int, bundleId string, params string, subject, receiver string) (m model.ApnsMessageInfo, err error)
func CreateMailMessage ¶
func CreateMailMessage(ctx persistence.TxContext, message model.MessageInfo, template model.MessageTemplate, templateParams string, subject, receiver string) (m model.MailMessageInfo, err error)
func CreateMessage ¶
func CreateMessage(ctx persistence.TxContext, org int, subject string, category msg.MessageCategory) (m model.MessageInfo, err error)
func CreateMessageTemplate ¶ added in v0.11.0
func CreateMessageTemplate(code, name, body, templateId, params, description string, category msg.MessageCategory, provider msg.MessageProvider) (m model.MessageTemplate, err error)
func CreateSmsMessage ¶
func CreateSmsMessage(ctx persistence.TxContext, message model.MessageInfo, template model.MessageTemplate, templateParams string, receiver string) (m model.SmsMessageInfo, err error)
func DeleteRunningTask ¶
func DeleteRunningTask(ctx persistence.TxContext, id int) (err error)
func DeleteRunningTaskByTaskId ¶
func DeleteRunningTaskByTaskId(ctx persistence.TxContext, taskId int) (err error)
func GetApnsByMessageId ¶
func GetApnsByMessageId(msgId int) (m model.ApnsMessageInfo, err error)
func GetClientByAppId ¶ added in v0.7.1
func GetClientByAppId(appId string) (c model.OpenClient, err error)
func GetClientById ¶
func GetClientById(ctx persistence.OrmContext, id int) (c model.OpenClient, err error)
func GetClients ¶
func GetClients(ctx persistence.OrmContext, key string) (c []model.OpenClient, err error)
func GetDefMessageSender ¶ added in v0.11.0
func GetDefMessageSender(org int, category msg.MessageCategory, provider msg.MessageProvider) (s model.MessageSenderInfo, err error)
GetDefMessageSender 获取默认的消息发送者
func GetExpiredTasks ¶
超时的列表 size:取出数据量
func GetMailByMessageId ¶
func GetMailByMessageId(msgId int) (m model.MailMessageInfo, err error)
func GetMessageById ¶
func GetMessageById(id int) (m model.MessageInfo, err error)
func GetMessageTask ¶
func GetMessageTask(id int) (t model.MessageTask, err error)
func GetMessageTemplateByCode ¶ added in v0.11.0
func GetMessageTemplateByCode(code string) (tpl model.MessageTemplate, err error)
func GetMessageTemplateById ¶ added in v0.11.0
func GetMessageTemplateById(id int) (tpl model.MessageTemplate, err error)
func GetMessageTemplates ¶ added in v0.11.0
func GetMessageTemplates( org int, category msg.MessageCategory, provider msg.MessageProvider, ) (templates []model.MessageTemplate, err error)
func GetMessageToSend ¶
func GetMessageToSend(size int) (messages []model.MessageInfo, err error)
查询需要发送的消息
func GetMessages ¶
func GetMessages(status int, category int, page app.Pager) (p app.Pager, messages []model.MessageInfo, err error)
func GetSmsByMessageId ¶
func GetSmsByMessageId(msgId int) (m model.SmsMessageInfo, err error)
func GetTaskByMessage ¶
func GetTaskByMessage(messageId int) (t model.MessageTask, err error)
func GetTaskList ¶
func GetTaskList(status int, page app.Pager) (p app.Pager, list []model.MessageTask, err error)
func GetTemplateByCode ¶ added in v0.11.0
func GetTemplateByCode(code string, category msg.MessageCategory) (s model.MessageTemplate, err error)
func TaskSendFail ¶
func TaskSendFail(messageId int)
func UpdateMessagePriority ¶
func UpdateMessagePriority(id int, priority int) (m model.MessageInfo, err error)
func UpdateMessageStatus ¶
func UpdateMessageStatus(ctx persistence.TxContext, id int, status int) (m model.MessageInfo, err error)
func UpdateMessageTemplate ¶ added in v0.11.0
func UpdateMessageTemplate(status int, code, name, body, description string) (m model.MessageTemplate, err error)
func UpdateTaskStatus ¶
func UpdateTaskStatus(ctx persistence.TxContext, taskId int, status int) (task model.MessageTask, err error)
Types ¶
Click to show internal directories.
Click to hide internal directories.