remotes

Documentation

Index

• Constants
• Variables
• type BaseRemote
  • func (b *BaseRemote) Call(ip string, port string, token string, method string, ...) (reply string, err error)
• type SystemRemote
  • func (this *SystemRemote) Ping(ip string, port string, token string, args map[string]interface{}) (res map[string]string, err error)
• type TaskRemote
  • func (this *TaskRemote) GetResults(ip string, port string, token string, args map[string]interface{}) (bool, error)
  • func (this *TaskRemote) Publish(ip string, port string, token string, args map[string]interface{}) error

Constants

const (
	Rpc_System_System      = "ServiceSystem"
	Rpc_System_Method_Ping = Rpc_System_System + ".Ping"
)

const (
	Rpc_Task_Service          = "ServiceTask"
	Rpc_Task_Method_Publish   = Rpc_Task_Service + ".Publish"
	Rpc_Task_Method_GetStatus = Rpc_Task_Service + ".Status"
	Rpc_Task_Method_Delete    = Rpc_Task_Service + ".Delete"
)

Variables

var Conn_Timeout = beego.AppConfig.DefaultInt64("agent.tls_timeout", 1000)

var System = SystemRemote{}

var Task = TaskRemote{}

Types

type BaseRemote

type BaseRemote struct {
}

func (*BaseRemote) Call

func (b *BaseRemote) Call(ip string, port string, token string, method string, args map[string]interface{}, timeout int64) (reply string, err error)

type SystemRemote

type SystemRemote struct {
	BaseRemote
}

func (*SystemRemote) Ping

func (this *SystemRemote) Ping(ip string, port string, token string, args map[string]interface{}) (res map[string]string, err error)

ping 检测是否联通

type TaskRemote

type TaskRemote struct {
	BaseRemote
}

func (*TaskRemote) GetResults

func (this *TaskRemote) GetResults(ip string, port string, token string, args map[string]interface{}) (bool, error)

获取节点执行结果

func (*TaskRemote) Publish

func (this *TaskRemote) Publish(ip string, port string, token string, args map[string]interface{}) error

发布