Versions in this module Expand all Collapse all v1 v1.1.0 Aug 27, 2023 v1.0.0 Feb 27, 2023 Changes in this version + var DefaultSendingCap = int64(1024) + var DefaultTimeoutMls = int64(1000) + var ErrIdFieldNotFound = errors.New("request id not found") + var ErrNoMessageType = errors.New("message type not found") + var ErrNoResponse = errors.New("no response") + var ErrRequestNotFound = errors.New("request not found") + var ErrTimeoutError = errors.New("timeout error") + var ErrUnsupportedMessageType = errors.New("message type not supported") + func NewRequestCtx(requestId int64, req value.Map, receiveCap int) *rpcRequestCtx + func NewSyncConn() *syncConn + type Client interface + CallFunction func(name string, args value.Value) (value.Value, error) + CancelRequest func(requestId int64) + Chat func(name string, args value.Value, receiveCap int, putCh <-chan value.Value) (<-chan value.Value, int64, error) + ClientId func() int64 + Close func() error + Connect func() error + GetStream func(name string, args value.Value, receiveCap int) (<-chan value.Value, int64, error) + IsActive func() bool + PutStream func(name string, args value.Value, putCh <-chan value.Value) error + Reconnect func() error + SetConnectionHandler func(ConnectionHandler) + SetErrorHandler func(ErrorHandler) + SetMonitor func(PerformanceMonitor) + SetTimeout func(timeoutMls int64) + Stats func() map[string]int64 + func NewClient(address, socks5 string) Client + type ConnectionHandler func(connected value.Map) + type ErrorHandler interface + BadConnection func(err error) + ProtocolError func(resp value.Map, err error) + StreamError func(requestId int64, err error) + type PerformanceMonitor func(name string, elapsed int64)
Go to main page