service

Documentation

Index

• func RegisterTables(db *gorm.DB)
• type NodeServer
  • func NewNodeServer() (*NodeServer, error)
  • func (srv *NodeServer) Down()
  • func (srv *NodeServer) Register() error
  • func (srv *NodeServer) Run() (err error)
  • func (srv *NodeServer) Stop(i interface{})

Functions

func RegisterTables

func RegisterTables(db *gorm.DB)

Types

type NodeServer

type NodeServer struct {
	*etcdclient.ServerReg
	*models.Node
	*cron.Cron
	// contains filtered or unexported fields
}

func NewNodeServer

func NewNodeServer() (*NodeServer, error)

func (*NodeServer) Down

func (srv *NodeServer) Down()

Remove the survival information from mysql after the node instance is deactivated

func (*NodeServer) Register

func (srv *NodeServer) Register() error

Register into ETCD with /crony/node/<node_id>

func (*NodeServer) Run

func (srv *NodeServer) Run() (err error)

func (*NodeServer) Stop

func (srv *NodeServer) Stop(i interface{})