handler

type Chain struct {
	Name string
	// contains filtered or unexported fields
}

type ErrorChangeFun func(ctx context.Context, err error, request *RpcRequest, response *RpcResponse) error

type PanicHandler int

type RpcHandler interface {
	Execute(req *RpcRequest, resp *RpcResponse) error
}

type RpcRequest struct {
	MessageId string             `json:"message_id"`
	Arg       interface{}        `json:"arg"`
	Ctx       context.Context    `json:"-"`
	Cancel    context.CancelFunc `json:"-"`
}

type RpcResponse struct {
	MessageId string      `json:"message_id"`
	Error     string      `json:"error"`
	Result    interface{} `json:"result"`
	Status    int64       `json:"status"`
}