Documentation
¶
Index ¶
Constants ¶
View Source
const ( MAX_JSONRPC_ID = 0x7FFFFFFF VERSION = "2.0" )
View Source
const ( // Errors defined in the JSON-RPC spec. See // http://www.jsonrpc.org/specification#error_object. CodeParseError = -32700 CodeInvalidRequest = -32600 CodeMethodNotFound = -32601 CodeInvalidParams = -32602 CodeInternalError = -32603 )
View Source
const ( DefaultMaxSleepTime = 1 * time.Second // accept中间最大sleep interval DefaultHTTPRspBufferSize = 1024 PathPrefix = byte('/') )
View Source
const JSONRPC = "jsonrpc"
Variables ¶
View Source
var (
Version = "2.0"
)
Functions ¶
func GetProtocol ¶
Types ¶
type Error ¶
type Error struct {
Code int `json:"code"`
Message string `json:"message"`
Data interface{} `json:"data,omitempty"`
}
rsponse Error
type HTTPClient ¶
type HTTPClient struct {
ID int64
// contains filtered or unexported fields
}
func NewHTTPClient ¶
func NewHTTPClient(opt *HTTPOptions) *HTTPClient
func (*HTTPClient) Do ¶
!!The high level of complexity and the likelihood that the fasthttp client has not been extensively used in production means that you would need to expect a very large benefit to justify the adoption of fasthttp today.
func (*HTTPClient) NewRequest ¶
func (c *HTTPClient) NewRequest(service common.URL, method string, args interface{}) *Request
type HTTPOptions ¶
type JsonrpcExporter ¶
type JsonrpcExporter struct {
protocol.BaseExporter
}
func NewJsonrpcExporter ¶
func (*JsonrpcExporter) Unexport ¶
func (je *JsonrpcExporter) Unexport()
type JsonrpcInvoker ¶
type JsonrpcInvoker struct {
protocol.BaseInvoker
// contains filtered or unexported fields
}
func NewJsonrpcInvoker ¶
func NewJsonrpcInvoker(url common.URL, client *HTTPClient) *JsonrpcInvoker
func (*JsonrpcInvoker) Invoke ¶
func (ji *JsonrpcInvoker) Invoke(invocation protocol.Invocation) protocol.Result
type JsonrpcProtocol ¶
type JsonrpcProtocol struct {
protocol.BaseProtocol
// contains filtered or unexported fields
}
func NewJsonrpcProtocol ¶
func NewJsonrpcProtocol() *JsonrpcProtocol
func (*JsonrpcProtocol) Destroy ¶
func (jp *JsonrpcProtocol) Destroy()
type ServerCodec ¶
type ServerCodec struct {
// contains filtered or unexported fields
}
func (*ServerCodec) ReadBody ¶
func (c *ServerCodec) ReadBody(x interface{}) error
func (*ServerCodec) ReadHeader ¶
func (c *ServerCodec) ReadHeader(header map[string]string, body []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.