server

Documentation

Index

• Constants
• func Deal404(c *gin.Context)
• func Recovery(c *gin.Context)
• type Beat
  • func (Beat) JavaClassName() string
• type ExecutorBizImpl
  • func NewExecutorBizImpl(triggerCallback *proccess.TriggerCallbackProccessor) *ExecutorBizImpl
  • func (t *ExecutorBizImpl) Beat() ReturnT
  • func (t *ExecutorBizImpl) IdleBeat(idleBeatParam IdleBeatParam) ReturnT
  • func (t *ExecutorBizImpl) Kill(killParam KillParam) ReturnT
  • func (t *ExecutorBizImpl) Log(logParam LogParam) ReturnT
  • func (t *ExecutorBizImpl) Run(triggerParam TriggerParam) ReturnT
• type ExecutorBizServer
  • func NewExecutorBizServer(ip string, port int32, accessToken string, executorBiz biz.ExecutorBiz) *ExecutorBizServer
  • func (t *ExecutorBizServer) Start()
  • func (t *ExecutorBizServer) Stop()
• type XxlRpcRequest
  • func (XxlRpcRequest) JavaClassName() string
  • func (t XxlRpcRequest) String() string
• type XxlRpcResponse
  • func (XxlRpcResponse) JavaClassName() string
• type XxlRpcResponse2
  • func NewXxlRpcResponse2(r *XxlRpcResponse) XxlRpcResponse2
  • func (XxlRpcResponse2) JavaClassName() string

Constants

const (
	SERIAL_EXECUTION = "SERIAL_EXECUTION"
	DISCARD_LATER    = "DISCARD_LATER"
	COVER_EARLY      = "COVER_EARLY"
)

const (
	BEAT_ID = "BEAT_PING_PONG"
)

Functions

func Deal404

func Deal404(c *gin.Context)

func Recovery

func Recovery(c *gin.Context)

Types

type Beat

type Beat struct {
}

func (Beat) JavaClassName

func (Beat) JavaClassName() string

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