rpc

Sep 18, 2022

Changes in this version

+ func MessageFromJson(data []byte, m *Message) error

type Connection

+ func Dial(ctx context.Context, url string) (*Connection, error)

+ func (c *Connection) Close()

+ func (c *Connection) Done() <-chan struct{}

+ func (c *Connection) Id() string

+ func (c *Connection) Read() []byte

+ func (c *Connection) ReadJSON(v interface{}) error

+ func (c *Connection) Write(data []byte)

+ func (c *Connection) WriteJSON(v interface{}) error

type Hub

+ func (h *Hub) Broadcast(data []byte)

+ func (h *Hub) BroadcastJSON(v interface{}) error

+ func (h *Hub) Requests() <-chan *Request

+ func (h *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Message struct

+ Error RpcError

+ Id uint64

+ Method string

+ Params map[string]any

+ Result any

+ Version string

+ type MessageHandler interface

+ HandleMessage func(m Message) error

+ type Request struct

+ func (r Request) AsData() []byte

+ func (r Request) AsJSON(v interface{}) error

+ func (r Request) Broadcast(data []byte)

+ func (r Request) BroadcastJSON(v interface{}) error

+ func (r Request) Error() error

+ func (r Request) Reply(data []byte)

+ func (r Request) ReplyJSON(data interface{}) error

+ type RequestHandler interface

+ HandleRequest func(m Request) error

Aug 16, 2022

Changes in this version

type RpcRequest

+ func (r RpcRequest) Reply(msg RpcMessage)

Aug 9, 2022

Changes in this version

+ func NextId() uint64

+ func ReadJsonMessages(r io.Reader, sleepDuration time.Duration, emitter chan RpcMessage) error

+ func ReadJsonMessagesFromFile(fn string, sleepDuration time.Duration, emitter chan RpcMessage)

+ type Connection struct

+ func NewConnection(server *Hub, conn *websocket.Conn) *Connection

+ func (c *Connection) BroadCast(m RpcMessage)

+ func (c *Connection) Send(m RpcMessage)

+ type Hub struct

+ func NewHub(writer RpcRequestHandler) *Hub

+ func (h *Hub) HandleWebsocketRequest(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) SendMessage(m RpcMessage)

+ type RpcError struct

+ Code int

+ Message string

+ type RpcMessage struct

+ Error RpcError

+ Id uint64

+ Method string

+ Params map[string]any

+ Result any

+ Version string

+ func MakeCall(method string, params map[string]any) RpcMessage

+ func MakeError(code int, msg string) RpcMessage

+ func MakeNotify(method string, params map[string]any) RpcMessage

+ func MakeResult(id uint64, result any) RpcMessage

+ type RpcMessageHandler interface

+ HandleMessage func(m RpcMessage) error

+ type RpcParams map[string]any

+ type RpcRequest struct

+ Conn *Connection

+ Msg RpcMessage

+ type RpcRequestHandler interface

+ HandleMessage func(m RpcRequest) error

+ type RpcResponse struct

+ Msg RpcMessage

+ type RpcSender struct

+ func NewRpcSender(writer RpcMessageHandler) *RpcSender

+ func (s *RpcSender) Close()

+ func (s *RpcSender) Dial(addr string) error

+ func (s *RpcSender) ReadPump()

+ func (s *RpcSender) SendMessages(emitter chan RpcMessage)