node

Documentation

Index

• type Groups
• type Jobs
• type Node
  • func NewNode(cfg *conf.Conf) (n *Node, err error)
  • func (n *Node) Register() (err error)
  • func (n *Node) Run() (err error)
  • func (n *Node) Stop(i interface{})

Types

type Groups

type Groups map[string]*cronsun.Group

type Jobs

type Jobs map[string]*cronsun.Job

type Node

type Node struct {
	*cronsun.Client
	*cronsun.Node
	*cron.Cron
	// contains filtered or unexported fields
}

Node 执行 cron 命令服务的结构体

func NewNode

func NewNode(cfg *conf.Conf) (n *Node, err error)

func (*Node) Register

func (n *Node) Register() (err error)

注册到 /cronsun/node/xx

func (*Node) Run

func (n *Node) Run() (err error)

启动服务

func (*Node) Stop

func (n *Node) Stop(i interface{})

停止服务