rpc

Documentation

Index

• func Read(conn net.Conn, headerBuffer []byte, payloadBuffer []byte, maxHeaderSize int, ...) (reqType api.RPCType, header []byte, payload []byte, err error)
• func Write(conn net.Conn, reqType api.RPCType, header []byte, payload []byte, ...) (err error)

Functions

func Read

func Read(
	conn net.Conn,
	headerBuffer []byte,
	payloadBuffer []byte,
	maxHeaderSize int,
	maxPayloadSize int,
) (
	reqType api.RPCType,
	header []byte,
	payload []byte,
	err error,
)

Read the rpc request from the connection, If a payload or header buffer is passed, then this buffer will be used if the capacity is sufficient.

func Write

func Write(
	conn net.Conn,
	reqType api.RPCType,
	header []byte,
	payload []byte,
	maxHeaderSize int,
	maxPayloadSize int,
) (err error)

Write the rpc request to the connection.