rpc

Documentation

Index

• Variables
• func HandleWebSocket(ctx context.Context, w http.ResponseWriter, r *http.Request)
• func MarshalData(data interface{}) ([]byte, error)
• func On(name string, callback func(conn *wsconn.ConnectionWrapper, data interface{}))
• func UnmarshalData(data []byte, dest interface{}) error
• type RPCMap

Variables

var RPCFunctions = struct {
	sync.RWMutex
	m RPCMap
}{/* contains filtered or unexported fields */}

RPCFunctions stores the mapping of function names to function calls.

Functions

func HandleWebSocket

func HandleWebSocket(ctx context.Context, w http.ResponseWriter, r *http.Request)

HandleWebSocket handles incoming WebSocket connections.

It upgrades the HTTP connection to the WebSocket protocol, reads JSON-RPC requests from the client, unmarshals the requests, calls the corresponding function, and sends the response back to the client.

func MarshalData

func MarshalData(data interface{}) ([]byte, error)

MarshalData encodes data into the specified format (either "json" or "msgpack").

func On

func On(name string, callback func(conn *wsconn.ConnectionWrapper, data interface{}))

On registers a callback function that will be executed when called via RPC.

func UnmarshalData

func UnmarshalData(data []byte, dest interface{}) error

UnmarshalData decodes data into the specified format (either "json" or "msgpack").

Types

type RPCMap

type RPCMap map[string]func(*wsconn.ConnectionWrapper, interface{}) error

RPCMap defines the structure for function mappings.