daemon

Documentation

Overview

*

• Copyright 2015 @ 56x.net.
• name : defer.go
• author : jarryliu
• date : 2016-01-06 17:43
• description :
• history :

*

• Copyright 2015 @ 56x.net.
• name : mail_queue
• author : jarryliu
• date : 2015-07-27 17:06
• description :
• history :

*

• Copyright 2015 @ 56x.net.
• name : person_finance
• author : jarryliu
• date : 2016-04-02 10:35
• description :
• history :

Index

• func AddCron(spec string, cmd func())
• func AddTickerFunc(f Func)
• func CompareLastUnix(key string, unix int64) bool
• func FlagRun()
• func Recover()
• func RegisterService(s Service)
• func Run(ctx gof.App)
• func SetLastUnix(key string, unix int64)
• func Start()
• type Func
• type Service

Functions

func AddCron

func AddCron(spec string, cmd func())

添加定时任务

func AddTickerFunc

func AddTickerFunc(f Func)

AddTickerFunc 添加定时执行任务(默认5秒)

func CompareLastUnix

func CompareLastUnix(key string, unix int64) bool

CompareLastUnix 比较最后运行的时间戳

func FlagRun

func FlagRun()

自定义参数运行

func Recover

func Recover()

func RegisterService

func RegisterService(s Service)

RegisterService 注册服务

func Run

func Run(ctx gof.App)

运行

func SetLastUnix

func SetLastUnix(key string, unix int64)

SetLastUnix 设置最后运行的时间戳

func Start

func Start()

Start 启动守护进程

Types

type Func

type Func func(gof.App)

Func 守护进程执行的函数

type Service

type Service interface {
	// Name 服务名称
	Name() string
	// Start 启动服务,并传入APP上下文对象
	Start(gof.App)
	// OrderObs 处理订单,需根据订单不同的状态,作不同的业务,返回布尔值,如果返回false,则不继续执行
	OrderObs(singleOrder *proto.SSingleOrder) bool
	// MemberObs 监视会员修改,@create:是否为新注册会员,返回布尔值,如果返回false,则不继续执行
	MemberObs(m *proto.SMember, create bool) bool
	// PaymentOrderObs 通知支付单完成队列,返回布尔值,如果返回false,则不继续执行
	PaymentOrderObs(order *proto.SPaymentOrder) bool
	// HandleMailQueue 处理邮件队列,返回布尔值,如果返回false,则不继续执行
	HandleMailQueue([]*mss.MailTask) bool
}

Service 守护进程服务