jsonrpc

type BaseMessage struct {
	Jsonrpc string `json:"jsonrpc"`
}

type BuildInError = ResponseError

type CancelParams struct {
	ID interface{} `json:"id"` // the method id should be canceled
}

type CloserReader interface {
	io.Reader
	io.Closer
}

type CloserWriter interface {
	io.Writer
	io.Closer
}

type Conn struct {
	// contains filtered or unexported fields
}

type FnMessageReaderWriter struct {
	ReadMessageFn  func() (msg []byte, err error)
	WriteMessageFn func(msg []byte) error
	CloseFn        func() error
	ClientFn       func() string
}

type JsonRpcWebsocket struct {
	// contains filtered or unexported fields
}

type JsonRpcWebsocketServer struct {
	// contains filtered or unexported fields
}

type JsonRpcWebsocketServerConfig struct {
	Addr      string
	RpcServer *Server

	//defaults to DEFAULT_MAX_IP_WS_CONNS
	MaxWebsocketPerIp int

	//if true only connections from localhost are allowed and
	//the effective value of MaxWebsocketPerIp is set to DEFAULT_MAX_IP_WS_CONNS_IF_BEHIND_PROXY.
	BehindCloudProxy bool
}

type MessageReaderWriter interface {
	//ReadMessage reads an entire message and returns it, the returned bytes should not be modified by the caller.
	ReadMessage() (msg []byte, err error)

	//WriteMessage writes an entire message and returns it, the written bytes should not modified by the implementation.
	WriteMessage(msg []byte) error

	io.Closer

	Client() string
}

type MethodInfo struct {
	Name          string
	NewRequest    func() interface{}
	Handler       func(ctx context.Context, req interface{}) (interface{}, error)
	SensitiveData bool
	AvoidLogging  bool

	// List of the maximum number of calls allowed during windows with increasing durations (1s, 10s, and 100s).
	// Example: [10, 50, 200] means at most 10 calls in 1s, 50 calls in 50s and 200 calls in 100s.
	RateLimits []int
}

type NotificationMessage struct {
	BaseMessage
	Method string          `json:"method"` // starts with "/$", server build-in methods.
	Params json.RawMessage `json:"params"` // params, is some struct or slice
}

type ProgressParams struct {
	Token interface{} `json:"token"` // int or string
	/**
	 * The progress data.
	 */
	Value interface{} `json:"value"`
}

type ReaderWriter interface {
	io.Reader
	io.Writer
	io.Closer
}

type RequestMessage struct {
	BaseMessage
	ID     interface{}     `json:"id"` // may be int or string
	Method string          `json:"method"`
	Params json.RawMessage `json:"params"` // params, is some struct or slice
}

type ResponseError struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data"`
}

type ResponseMessage struct {
	BaseMessage
	ID     interface{}    `json:"id"` // may be int or string
	Result interface{}    `json:"result"`
	Error  *ResponseError `json:"error"`
}

type Server struct {
	// contains filtered or unexported fields
}

type Session struct {
	// contains filtered or unexported fields
}

type SessionCreationCallbackFn func(rpcServerContext *core.Context, session *Session) error