Documentation ¶
Index ¶
Constants ¶
View Source
const ( SERIAL_EXECUTION = "SERIAL_EXECUTION" DISCARD_LATER = "DISCARD_LATER" COVER_EARLY = "COVER_EARLY" )
View Source
const (
BEAT_ID = "BEAT_PING_PONG"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ExecutorBizImpl ¶
type ExecutorBizImpl struct {
// contains filtered or unexported fields
}
func NewExecutorBizImpl ¶
func NewExecutorBizImpl(triggerCallback *proccess.TriggerCallbackProccessor) *ExecutorBizImpl
func (*ExecutorBizImpl) Beat ¶
func (t *ExecutorBizImpl) Beat() ReturnT
func (*ExecutorBizImpl) IdleBeat ¶
func (t *ExecutorBizImpl) IdleBeat(idleBeatParam IdleBeatParam) ReturnT
func (*ExecutorBizImpl) Kill ¶
func (t *ExecutorBizImpl) Kill(killParam KillParam) ReturnT
func (*ExecutorBizImpl) Log ¶
func (t *ExecutorBizImpl) Log(logParam LogParam) ReturnT
func (*ExecutorBizImpl) Run ¶
func (t *ExecutorBizImpl) Run(triggerParam TriggerParam) ReturnT
type ExecutorBizServer ¶
type ExecutorBizServer struct {
// contains filtered or unexported fields
}
func NewExecutorBizServer ¶
func NewExecutorBizServer(ip string, port int32, accessToken string, executorBiz biz.ExecutorBiz) *ExecutorBizServer
func (*ExecutorBizServer) Start ¶
func (t *ExecutorBizServer) Start()
func (*ExecutorBizServer) Stop ¶
func (t *ExecutorBizServer) Stop()
type XxlRpcRequest ¶
type XxlRpcRequest struct { RequestId string `hessian:"requestId" json:"requestId"` CreateMillisTime int64 `hessian:"createMillisTime" json:"createMillisTime"` AccessToken string `hessian:"accessToken" json:"accessToken"` ClassName string `hessian:"className" json:"className"` MethodName string `hessian:"methodName" json:"methodName"` //ParameterTypes []interface{} `hessian:"parameterTypes" json:"parameterTypes"` // 不知道 java 中的Class对象该对应golang的什么类型,还不如不接收 Parameters []interface{} `hessian:"parameters" json:"parameters"` Version string `hessian:"version" json:"version"` }
func (XxlRpcRequest) JavaClassName ¶
func (XxlRpcRequest) JavaClassName() string
func (XxlRpcRequest) String ¶
func (t XxlRpcRequest) String() string
type XxlRpcResponse ¶
type XxlRpcResponse struct { RequestId string `hessian:"requestId" json:"requestId"` ErrorMsg string `hessian:"errorMsg" json:"errorMsg"` Result interface{} `hessian:"result" json:"result"` }
func (XxlRpcResponse) JavaClassName ¶
func (XxlRpcResponse) JavaClassName() string
type XxlRpcResponse2 ¶
type XxlRpcResponse2 struct { RequestId string `hessian:"requestId" json:"requestId"` ErrorMsg interface{} `hessian:"errorMsg" json:"errorMsg"` Result interface{} `hessian:"result" json:"result"` }
解决xxl-rpc 中返回 errorMsg 为空字符仍报错问题(xxl-rpc的坑)
func NewXxlRpcResponse2 ¶
func NewXxlRpcResponse2(r *XxlRpcResponse) XxlRpcResponse2
func (XxlRpcResponse2) JavaClassName ¶
func (XxlRpcResponse2) JavaClassName() string
Click to show internal directories.
Click to hide internal directories.