Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

jsonrpc

package

Go to main page

Versions in this module

v1

v1.0.4

Jul 17, 2025

v1.0.3

Jul 9, 2025

v1.0.2

Jun 1, 2025

v1.0.1

May 18, 2025

v1.0.0

May 18, 2025

v0

v0.0.29

May 8, 2025

v0.0.28

May 8, 2025

v0.0.27

May 8, 2025

v0.0.26

May 7, 2025

v0.0.25

May 7, 2025

v0.0.24

May 7, 2025

v0.0.23

May 2, 2025

v0.0.22

May 2, 2025

v0.0.21

May 1, 2025

v0.0.20

May 1, 2025

v0.0.19

Apr 11, 2025

v0.0.18

Apr 11, 2025

v0.0.17

Apr 11, 2025

v0.0.16

Apr 11, 2025

v0.0.15

Apr 11, 2025

v0.0.14

Apr 11, 2025

v0.0.13

Apr 6, 2025

v0.0.12

Apr 6, 2025

v0.0.11

Mar 29, 2025

v0.0.10

Mar 29, 2025

v0.0.9

Mar 23, 2025

v0.0.8

Mar 23, 2025

v0.0.7

Mar 23, 2025

v0.0.6

Mar 23, 2025

v0.0.5

Mar 18, 2025

v0.0.4

Mar 18, 2025

v0.0.3

Mar 18, 2025

v0.0.2

Mar 18, 2025

Changes in this version

+ const BUFFERLENGTH

+ const DATAEND

+ const DEFAULT_ERROR_MSG

+ const JSONRPC_100_CONTINUE

+ const JSONRPC_101_SWITCHING_PROTOCOLS

+ const JSONRPC_200_OK

+ const JSONRPC_201_CREATED

+ const JSONRPC_202_ACCEPTED

+ const JSONRPC_203_NON_AUTHORITATIVE_INFORMATION

+ const JSONRPC_204_NO_CONTENT

+ const JSONRPC_205_RESET_CONTENT

+ const JSONRPC_206_PARTIAL_CONTENT

+ const JSONRPC_207_MULTI_STATUS

+ const JSONRPC_300_MULTIPLE_CHOICES

+ const JSONRPC_301_MOVED_PERMANENTLY

+ const JSONRPC_302_FOUND

+ const JSONRPC_303_SEE_OTHER

+ const JSONRPC_304_NOT_MODIFIED

+ const JSONRPC_305_USE_PROXY

+ const JSONRPC_306_RESERVED

+ const JSONRPC_307_TEMPORARY_REDIRECT

+ const JSONRPC_400_BAD_REQUEST

+ const JSONRPC_401_UNAUTHORIZED

+ const JSONRPC_402_PAYMENT_REQUIRED

+ const JSONRPC_403_FORBIDDEN

+ const JSONRPC_404_NOT_FOUND

+ const JSONRPC_405_METHOD_NOT_ALLOWED

+ const JSONRPC_406_NOT_ACCEPTABLE

+ const JSONRPC_407_PROXY_AUTHENTICATION_REQUIRED

+ const JSONRPC_408_REQUEST_TIMEOUT

+ const JSONRPC_409_CONFLICT

+ const JSONRPC_410_GONE

+ const JSONRPC_411_LENGTH_REQUIRED

+ const JSONRPC_412_PRECONDITION_FAILED

+ const JSONRPC_413_REQUEST_ENTITY_TOO_LARGE

+ const JSONRPC_414_REQUEST_URI_TOO_LONG

+ const JSONRPC_415_UNSUPPORTED_MEDIA_TYPE

+ const JSONRPC_416_REQUESTED_RANGE_NOT_SATISFIABLE

+ const JSONRPC_417_EXPECTATION_FAILED

+ const JSONRPC_422_UNPROCESSABLE_ENTITY

+ const JSONRPC_423_LOCKED

+ const JSONRPC_424_FAILED_DEPENDENCY

+ const JSONRPC_425_TOO_EARLY

+ const JSONRPC_428_PRECONDITION_REQUIRED

+ const JSONRPC_429_TOO_MANY_REQUESTS

+ const JSONRPC_431_REQUEST_HEADER_FIELDS_TOO_LARGE

+ const JSONRPC_451_UNAVAILABLE_FOR_LEGAL_REASONS

+ const JSONRPC_500_INTERNAL_SERVER_ERROR

+ const JSONRPC_501_NOT_IMPLEMENTED

+ const JSONRPC_502_BAD_GATEWAY

+ const JSONRPC_503_SERVICE_UNAVAILABLE

+ const JSONRPC_504_GATEWAY_TIMEOUT

+ const JSONRPC_505_JSONRPC_VERSION_NOT_SUPPORTED

+ const JSONRPC_507_INSUFFICIENT_STORAGE

+ const JSONRPC_508_SERVICE_KNOWN_ERROR

+ const JSONRPC_511_NETWORK_AUTHENTICATION_REQUIRED

+ const JSONRPC_600_INPUT_IS_EMPTY

+ const JSONRPC_601_SERVER_NAME_EXIST

+ const JSONRPC_602_FILE_NOT_EXIST

+ const JSONRPC_603_SERVER_NOT_EXIST

+ const JSONRPC_604_PROCESS_ADD_FAILE

+ const JSONRPC_605_SOMETHING_WRONG

+ const JSONRPC_606_NO_SUCH_PROCESS_TASK

+ const JSONRPC_607_PROCESS_WITHOUT_CONFIG

+ const JSONRPC_608_NO_SUCH_TIME_NODE

+ const JSONRPC_609_WRONG_PUNCTUATION

+ const JSONRPC_610_CREATE_YAML_FAIL

+ const JSONRPC_611_CONFIG_NOT_FOUND_SUCH_TASK

+ const JSONRPC_612_YAML_FORMAT_ERROR

+ const JSONRPC_613_FORBIDDEN

+ const JSONRPC_620_NO_SUCH_USER

+ const JSONRPC_621_TWICE_PASSWORD_DIFFRENT

+ const JSONRPC_622_ACCOUNT_EXIST

+ const JSONRPC_623_PERMISSION_DENIED

+ const JSONRPC_624_EXP_TIME_ERROR

+ const JSON_RPC_CONNECTION_CONTEXT_KEY

+ const LOAD_ALGORITHM_POLLING

+ const LOAD_ALGORITHM_PRIORITY

+ const LOAD_ALGORITHM_RAND

+ const LOAD_ALGORITHM_WEIGHT

+ const SESSION

+ var AfterExec func(rpcConn JsonRpcConnection)

+ var BeforExec func(rpcConn JsonRpcConnection)

+ var CODETYPES = NewCodeTypes()

+ var DefaultExec func(rpcConn JsonRpcConnection) = func(rpcConn JsonRpcConnection)

+ var OnMethodNotFound func(rpcConn JsonRpcConnection)

+ var REQ_IV = "3010201735544643"

+ var REQ_KEY = "KHGSI69YBWGS0TWX"

+ func AddInterceptor(args ...func(conn JsonRpcConnection) error)

+ func AddMethodHead(methodHead string)

+ func AesDecrypt(text string) ([]byte, error)

+ func AesEncrypt(text []byte) (encrypt []byte, err error)

+ func Call(method, token string, requestParams any, responseParams any) (err error)

+ func CallEdgeServerNode(method, token string, requestParams any, responseParams any) (err error)

+ func CallGateWay(method, token string, requestParams any, responseParams any) (err error)

+ func ChatHandller(ctx context.Context, tcpConn *TcpConn)

+ func ConnReading(ctx context.Context, tcpConn *TcpConn, ...)

+ func ConnReadingClient(ctx context.Context, tcpClient *TcpClient, tcpConn *TcpConn, ...)

+ func Exec(rpcConn JsonRpcConnection)

+ func GetMethods() (method []string)

+ func HasMethod(method string) bool

+ func HttpHandller(w http.ResponseWriter, r *http.Request)

+ func InitServerApi()

+ func MethodLock(method string)

+ func MethodLockAll(excludeMethods ...string)

+ func MethodToHttpInterface(serveMux *http.ServeMux)

+ func MethodUnlock(method string)

+ func MethodUnlockAll(excludeMethods ...string)

+ func NewCodeTypes() codeTypes

+ func PushToAll(r *Jsonrpcrequest)

+ func PushToGroup(groupName string, request *Jsonrpcrequest)

+ func SetClientCallTimeOut(second int64)

+ func SetFunc(method string, f func(JsonRpcConnection))

+ func SetIv(s string)

+ func SetKey(s string)

+ func SetSecretkey(key string, iv string)

+ func TCPServiceHandller(tcpConn *TcpConn, data string, rpcConn *TcpRpcConnection)

+ type ContextKey string

+ type Dev struct

+ type EdgeServerNode struct

+ EdgeServerNodeConfig EdgeServerNodeConfig

+ Guid string

+ OnClose func(*EdgeServerNode)

+ OnConnect func(*EdgeServerNode)

+ func NewEdgeServerNode(nodeConfig EdgeServerNodeConfig) *EdgeServerNode

+ func (c *EdgeServerNode) Call(request *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (c *EdgeServerNode) Connect()

+ type EdgeServerNodeConfig struct

+ ClusterToken string

+ DisableHealthCheck bool

+ EdgeServerNodeHost string

+ HttpJsonrpcPath string

+ Methods []string

+ ModuleName string

+ Port string

+ Priority int64

+ Schema string

+ ServerUrl string

+ ServerUrls []string

+ Type string

+ WebFrontServerPort string

+ type EdgeServerNodeHttpRoute struct

+ Guid string

+ HostUrl string

+ type Error struct

+ Code int64

+ Data interface{}

+ Message string

+ func New() *Error

+ func (e *Error) AppendChild(es Errors)

+ func (e *Error) Error() string

+ func (e *Error) GetCode() int64

+ func (e *Error) NewChild(code int64, message string) *Error

+ func (e *Error) Set(code int64, message string)

+ type Errors interface

+ AppendChild func(Errors)

+ Error func() string

+ GetCode func() int64

+ NewChild func(int64, string) *Error

+ Set func(int64, string)

+ type GatewayEdgeServerNode struct

+ Guid string

+ RemoteAddr string

+ type GatewayServer struct

+ FrontServer www.WebServer

+ WebsocketServer *WebSocketServer

+ func NewGatewayServer() *GatewayServer

+ func (gs *GatewayServer) CallEdgeServerNode(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (gs *GatewayServer) ProxyHttpHandller(w http.ResponseWriter, r *http.Request)

+ func (gs *GatewayServer) ProxyToEdgeServerNode(sourceRpcConn JsonRpcConnection)

+ func (gs *GatewayServer) SetClusterToken(token string)

+ func (gs *GatewayServer) SetLoadAlgorithm(loadType int)

+ type Group struct

+ ID string

+ func NewGroup(groupName string) *Group

+ func (g *Group) Join(rpcConn JsonRpcConnection)

+ func (g *Group) Leave(rpcConn JsonRpcConnection)

+ func (g *Group) PushToAll(r *Jsonrpcrequest)

+ type HttpClient struct

+ ErrorFunc func(error)

+ func NewHttpClient() *HttpClient

+ func (c *HttpClient) Call(url string, jsonrpcrequest *Jsonrpcrequest, callback func(Jsonrpcresponse))

+ func (c *HttpClient) Push(url string, jsonrpcrequest *Jsonrpcrequest)

+ type HttpRestfulResult struct

+ Message string

+ Result any

+ Status int64

+ type HttpRpcConnection struct

+ func NewHttpRpcConnection(w http.ResponseWriter, r *http.Request) *HttpRpcConnection

+ func (c *HttpRpcConnection) DisableHealthCheck()

+ func (c *HttpRpcConnection) EnableHealthCheck()

+ func (c *HttpRpcConnection) GUID() string

+ func (c *HttpRpcConnection) GetRemoteAddr() string

+ func (c *HttpRpcConnection) GetRpcRequest() *Jsonrpcrequest

+ func (c *HttpRpcConnection) GetRpcResponse() *Jsonrpcresponse

+ func (c *HttpRpcConnection) IsConnected() bool

+ func (c *HttpRpcConnection) LinkType() string

+ func (c *HttpRpcConnection) Push(request *Jsonrpcrequest) error

+ func (c *HttpRpcConnection) Read() string

+ func (c *HttpRpcConnection) ReadParams(destParams ...interface{}) error

+ func (c *HttpRpcConnection) ReadResult(destParams ...interface{}) error

+ func (c *HttpRpcConnection) Write()

+ func (c *HttpRpcConnection) WriteError(code int64, msg string)

+ func (c *HttpRpcConnection) WriteResponse(rpcResponse Jsonrpcresponse)

+ func (c *HttpRpcConnection) WriteResult(result interface{})

+ func (wsc *HttpRpcConnection) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ type JsonRpcConnection interface

+ Call func(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ DisableHealthCheck func()

+ EnableHealthCheck func()

+ GUID func() string

+ GetRemoteAddr func() string

+ GetRpcRequest func() *Jsonrpcrequest

+ GetRpcResponse func() *Jsonrpcresponse

+ IsConnected func() bool

+ LinkType func() string

+ Push func(request *Jsonrpcrequest) error

+ Read func() string

+ ReadParams func(destParams ...interface{}) error

+ ReadResult func(destResult ...interface{}) error

+ Write func()

+ WriteError func(code int64, msg string)

+ WriteResponse func(Jsonrpcresponse)

+ WriteResult func(any interface{})

+ func NewLocalRpcConnection(rpcRequest *Jsonrpcrequest, rpcResponse *Jsonrpcresponse) JsonRpcConnection

+ func NewNilRpcConnection(rpcRequest *Jsonrpcrequest, rpcResponse *Jsonrpcresponse) JsonRpcConnection

+ type Jsonrpcrequest struct

+ Ctx map[ContextKey]interface{}

+ Id string

+ Isencryption bool

+ Jsonrpc string

+ Method string

+ Params interface{}

+ Route Route

+ Session string

+ Timestampin string

+ Timestampout string

+ func NewJsonrpcrequest() *Jsonrpcrequest

+ func ToJsonrpcrequest(s string) (*Jsonrpcrequest, error)

+ func (j *Jsonrpcrequest) Await()

+ func (j *Jsonrpcrequest) Context() context.Context

+ func (j *Jsonrpcrequest) Done()

+ func (j *Jsonrpcrequest) WithContext(ctx context.Context)

+ type Jsonrpcresponse struct

+ Ctx map[ContextKey]interface{}

+ Error Error

+ Id string

+ Jsonrpc string

+ Result interface{}

+ Route Route

+ Timestampin string

+ Timestampout string

+ func NewJsonrpcresponse() *Jsonrpcresponse

+ func ToJsonrpcresponse(s string) (Jsonrpcresponse, error)

+ func (jrr *Jsonrpcresponse) ReadResult(destParams interface{}) error

+ type Jsonrpcresponseclient struct

+ Ctx map[string]interface{}

+ Error interface{}

+ Id string

+ Jsonrpc string

+ Result interface{}

+ Route Route

+ Timestampin string

+ Timestampout string

+ func ToJsonrpcresponseclient(s string) (Jsonrpcresponseclient, error)

+ type LoadBalance struct

+ func (lb *LoadBalance) LoadPolling(method string) JsonRpcConnection

+ func (lb *LoadBalance) LoadPriority(method string) JsonRpcConnection

+ func (lb *LoadBalance) LoadRand(method string) JsonRpcConnection

+ func (lb *LoadBalance) LoadRandHttpRestful(method string) *EdgeServerNodeHttpRoute

+ func (lb *LoadBalance) RandPickRestfulProxy(r *http.Request) *EdgeServerNodeHttpRoute

+ func (lb *LoadBalance) RemoveByGuid(rpcConnGuid string)

+ func (lb *LoadBalance) RemoveMethod(method string)

+ func (lb *LoadBalance) StoreHttpJsonrpcMethod(method string, rpcConn JsonRpcConnection, e EdgeServerNodeConfig)

+ func (lb *LoadBalance) StoreHttpRestfulMethod(method string, rpcConn JsonRpcConnection, e EdgeServerNodeConfig)

+ func (lb *LoadBalance) StoreJsonrpcKeepaliveMethod(method string, rpcConn JsonRpcConnection, priority int64)

+ func (lb *LoadBalance) StoreJsonrpcKeepaliveMethods(methods []string, rpcConn JsonRpcConnection, priority int64)

+ type LoadBalancePriority struct

+ Priority int64

+ RpcConn JsonRpcConnection

+ type LoadBalancePrioritys []*LoadBalancePriority

+ func (m LoadBalancePrioritys) Len() int

+ func (m LoadBalancePrioritys) Less(x, y int) bool

+ func (m LoadBalancePrioritys) Swap(x, y int)

+ type LocalRpcConnection struct

+ func (c *LocalRpcConnection) DisableHealthCheck()

+ func (c *LocalRpcConnection) EnableHealthCheck()

+ func (n *LocalRpcConnection) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (n *LocalRpcConnection) GUID() string

+ func (n *LocalRpcConnection) GetRemoteAddr() string

+ func (n *LocalRpcConnection) GetRpcRequest() *Jsonrpcrequest

+ func (n *LocalRpcConnection) GetRpcResponse() *Jsonrpcresponse

+ func (n *LocalRpcConnection) IsConnected() bool

+ func (n *LocalRpcConnection) LinkType() string

+ func (n *LocalRpcConnection) Push(request *Jsonrpcrequest) error

+ func (n *LocalRpcConnection) Read() string

+ func (n *LocalRpcConnection) ReadParams(destParams ...interface{}) error

+ func (n *LocalRpcConnection) ReadResult(destResult ...interface{}) error

+ func (n *LocalRpcConnection) Write()

+ func (n *LocalRpcConnection) WriteError(code int64, msg string)

+ func (n *LocalRpcConnection) WriteResponse(Jsonrpcresponse)

+ func (n *LocalRpcConnection) WriteResult(any interface{})

+ type NilRpcConnection struct

+ func (c *NilRpcConnection) DisableHealthCheck()

+ func (c *NilRpcConnection) EnableHealthCheck()

+ func (n *NilRpcConnection) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (n *NilRpcConnection) GUID() string

+ func (n *NilRpcConnection) GetRemoteAddr() string

+ func (n *NilRpcConnection) GetRpcRequest() *Jsonrpcrequest

+ func (n *NilRpcConnection) GetRpcResponse() *Jsonrpcresponse

+ func (n *NilRpcConnection) IsConnected() bool

+ func (n *NilRpcConnection) LinkType() string

+ func (n *NilRpcConnection) Push(request *Jsonrpcrequest) error

+ func (n *NilRpcConnection) Read() string

+ func (n *NilRpcConnection) ReadParams(destParams ...interface{}) error

+ func (n *NilRpcConnection) ReadResult(destResult ...interface{}) error

+ func (n *NilRpcConnection) Write()

+ func (n *NilRpcConnection) WriteError(code int64, msg string)

+ func (n *NilRpcConnection) WriteResponse(Jsonrpcresponse)

+ func (n *NilRpcConnection) WriteResult(any interface{})

+ type Route struct

+ DestAddr string

+ SourceAddr string

+ TTL int64

+ type RpcCallback struct

+ Callback func(JsonRpcConnection)

+ Request *Jsonrpcrequest

+ type TcpClient struct

+ CallTimeOut int64

+ OnClose func(tcpClient *TcpClient)

+ OnConnect func(tcpClient *TcpClient)

+ OnMessage func(rpcConn JsonRpcConnection)

+ PingInterval int64

+ func NewTcpClient(ip, port string) (*TcpClient, error)

+ func (tcpClient *TcpClient) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (tcpClient *TcpClient) Close()

+ func (tcpClient *TcpClient) Connect() error

+ func (tcpClient *TcpClient) IsConnected() bool

+ func (tcpClient *TcpClient) Push(rpcRequest *Jsonrpcrequest)

+ type TcpConn struct

+ BUFFERLENGTH int64

+ DATAEND byte

+ PingInterval int64

+ type TcpRpcConnection struct

+ func NewTcpRpcConnection(conn net.Conn, bodyStr string) *TcpRpcConnection

+ func (c *TcpRpcConnection) AnalysisByString(message string)

+ func (c *TcpRpcConnection) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (c *TcpRpcConnection) DisableHealthCheck()

+ func (c *TcpRpcConnection) EnableHealthCheck()

+ func (c *TcpRpcConnection) GUID() string

+ func (c *TcpRpcConnection) GetRemoteAddr() string

+ func (c *TcpRpcConnection) GetRpcRequest() *Jsonrpcrequest

+ func (c *TcpRpcConnection) GetRpcResponse() *Jsonrpcresponse

+ func (c *TcpRpcConnection) IsConnected() bool

+ func (c *TcpRpcConnection) LinkType() string

+ func (c *TcpRpcConnection) Push(request *Jsonrpcrequest) error

+ func (c *TcpRpcConnection) Read() string

+ func (c *TcpRpcConnection) ReadParams(destParams ...interface{}) error

+ func (c *TcpRpcConnection) ReadResult(destParams ...interface{}) error

+ func (c *TcpRpcConnection) Write()

+ func (c *TcpRpcConnection) WriteError(code int64, msg string)

+ func (c *TcpRpcConnection) WriteResponse(rpcResponse Jsonrpcresponse)

+ func (c *TcpRpcConnection) WriteResult(result interface{})

+ type TcpServer struct

+ PingInterval int64

+ func NewTcpServer(ip, port string) (*TcpServer, error)

+ func (tcpserver *TcpServer) Run()

+ func (tcpserver *TcpServer) Stop()

+ type WebScoketClient struct

+ CallTimeOut int64

+ OnClose func(*WebScoketClient)

+ OnConnect func(*WebScoketClient)

+ PingDuringTime int64

+ UserAgent string

+ func NewWebsocketClient(url, origin string) *WebScoketClient

+ func (wsc *WebScoketClient) AutoReConnect(connect bool)

+ func (wsc *WebScoketClient) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (wsc *WebScoketClient) Close()

+ func (wsc *WebScoketClient) Connect()

+ func (wsc *WebScoketClient) DisableHealthCheck()

+ func (wsc *WebScoketClient) EnableHealthCheck()

+ func (wsc *WebScoketClient) IsConnected() bool

+ func (wsc *WebScoketClient) Push(rpcRequest *Jsonrpcrequest)

+ func (wsc *WebScoketClient) ReLoad(url, origin string)

+ type WebSocketRpcConnection struct

+ CallTimeOut int64

+ PingDuringTime int64

+ func NewWebSocketRpcConnection(ws *websocket.Conn) *WebSocketRpcConnection

+ func (*WebSocketRpcConnection) LinkType() string

+ func (w *WebSocketRpcConnection) AnalysisByString(message string)

+ func (w *WebSocketRpcConnection) Duplicate() (new *WebSocketRpcConnection)

+ func (w *WebSocketRpcConnection) GetRemoteAddr() string

+ func (w *WebSocketRpcConnection) GetRpcRequest() *Jsonrpcrequest

+ func (w *WebSocketRpcConnection) GetRpcResponse() *Jsonrpcresponse

+ func (w *WebSocketRpcConnection) Push(request *Jsonrpcrequest) error

+ func (w *WebSocketRpcConnection) Read() string

+ func (w *WebSocketRpcConnection) ReadParams(destParams ...interface{}) error

+ func (w *WebSocketRpcConnection) ReadResult(destResult ...interface{}) error

+ func (w *WebSocketRpcConnection) Write()

+ func (w *WebSocketRpcConnection) WriteError(code int64, msg string)

+ func (w *WebSocketRpcConnection) WriteResponse(response Jsonrpcresponse)

+ func (w *WebSocketRpcConnection) WriteResult(any interface{})

+ func (wsc *WebSocketRpcConnection) Call(rpcRequest *Jsonrpcrequest, callback func(JsonRpcConnection))

+ func (wsc *WebSocketRpcConnection) Close()

+ func (wsc *WebSocketRpcConnection) GUID() string

+ func (wsc *WebSocketRpcConnection) IsConnected() bool

+ func (wsc *WebSocketRpcConnection) MockResponse(response *Jsonrpcresponse)

+ func (wsc *WebSocketRpcConnection) ReceiveMessage() (string, bool)

+ func (wsrc *WebSocketRpcConnection) DisableHealthCheck()

+ func (wsrc *WebSocketRpcConnection) EnableHealthCheck()

+ type WebSocketServer struct

+ WebsocketServiceHandller websocket.Handler

+ var DefaultWebSocketServer *WebSocketServer

+ func NewWebsocketServer() *WebSocketServer

+ func (w *WebSocketServer) OnClose(callback func(rpcConn JsonRpcConnection))

+ func (w *WebSocketServer) OnConnect(callback func(rpcConn JsonRpcConnection))