qrpc

May 23, 2024

Changes in this version

type Client

+ func (c *Client) OnConnect(handle ConnectedHandler)

+ type ConnectedHandler func(*Client)

May 22, 2024

Changes in this version

type Client

+ func (c *Client) BindLocalIP(localIP string)

May 22, 2024

Changes in this version

type Client

+ func (c *Client) RemoteAddr() net.Addr

+ func (c *Client) SetTimeout(timeout uint)

+ type ClosedHandler func(*RpcConnection)

type Server

+ func (s *Server) OnClose(handle ClosedHandler)

+ func (s *Server) SetTimeout(timeout uint)

May 18, 2024

Changes in this version

type RpcConnection

+ func (c *RpcConnection) RemoteAddr() net.Addr

May 16, 2024

Changes in this version

type RpcConnection

+ func (c *RpcConnection) ID() uint64

May 16, 2024

Changes in this version

type Message

+ Type uint64

May 14, 2024

Changes in this version

+ type Client struct

+ Addr string

+ Port uint

+ RetryDelay time.Duration

+ func NewClient(addr string, port uint) *Client

+ func (c *Client) Connect() error

+ func (c *Client) Disconnect()

+ func (c *Client) GetPingValue() int

+ func (c *Client) OnRequest(handle RequestMessageHandler)

+ func (c *Client) Request(data []byte) ([]byte, error)

+ type ConnectionHandler func(*RpcConnection)

+ type IDGenerator struct

+ func (m *IDGenerator) Next() uint64

+ type Message struct

+ Data []byte

+ ID uint64

+ IsAck bool

+ Timestamp int64

+ func (m *Message) Read(r io.Reader) error

+ func (m *Message) Write(w io.Writer) error

+ type MessageBroker struct

+ func NewMessageBroker(timeout time.Duration) *MessageBroker

+ func (b *MessageBroker) ReceiveResponse(response *Message) bool

+ func (b *MessageBroker) Send(request *Message) (*Message, error)

+ type MessageHandler func(*RpcConnection, []byte) []byte

+ type MessagePair struct

+ Request *Message

+ Response *Message

+ type RequestMessageHandler func(data []byte) []byte

+ type RpcConnection struct

+ func NewRpcConnection(ctx context.Context, conn quic.Connection, timeout uint) *RpcConnection

+ func (c *RpcConnection) AddMetadata(key, value string)

+ func (c *RpcConnection) Close()

+ func (c *RpcConnection) GetMetadata(key string) (string, bool)

+ func (c *RpcConnection) OnClose(handle func())

+ func (c *RpcConnection) OnRequest(handle MessageHandler)

+ func (c *RpcConnection) Ping() (int, error)

+ func (c *RpcConnection) RemoveMetadata(key string)

+ func (c *RpcConnection) Request(data []byte) ([]byte, error)

+ type Server struct

+ func NewServer(port uint) (*Server, error)

+ func (s *Server) Accept(ctx context.Context)

+ func (s *Server) Close() error

+ func (s *Server) OnConnection(handle ConnectionHandler)