Versions in this module Expand all Collapse all v1 v1.1.5 Jun 18, 2024 v1.1.4 Jun 10, 2024 v1.1.3 Mar 4, 2024 v1.1.2 Oct 17, 2023 v1.1.1 Jul 31, 2023 Changes in this version type ChannelDescriptor + MessageType proto.Message v1.1.0 Apr 21, 2023 Changes in this version + var ErrSmallOrderRemotePubKey = errors.New("detected low order point from remote peer") + func NetPipe() (net.Conn, net.Conn) + type Channel struct + Logger log.Logger + func (ch *Channel) SetLogger(l log.Logger) + type ChannelDescriptor struct + ID byte + Priority int + RecvBufferCapacity int + RecvMessageCapacity int + SendQueueCapacity int + func (chDesc ChannelDescriptor) FillDefaults() (filled ChannelDescriptor) + type ChannelStatus struct + ID byte + Priority int + RecentlySent int64 + SendQueueCapacity int + SendQueueSize int + type ConnectionStatus struct + Channels []ChannelStatus + Duration time.Duration + RecvMonitor flow.Status + SendMonitor flow.Status + type MConnConfig struct + FlushThrottle time.Duration + MaxPacketMsgPayloadSize int + PingInterval time.Duration + PongTimeout time.Duration + RecvAsync bool + RecvRate int64 + SendRate int64 + func DefaultMConnConfig() MConnConfig + type MConnection struct + func NewMConnection(conn net.Conn, chDescs []*ChannelDescriptor, onReceive receiveCbFunc, ...) *MConnection + func NewMConnectionWithConfig(conn net.Conn, chDescs []*ChannelDescriptor, onReceive receiveCbFunc, ...) *MConnection + func (c *MConnection) CanSend(chID byte) bool + func (c *MConnection) FlushStop() + func (c *MConnection) OnStart() error + func (c *MConnection) OnStop() + func (c *MConnection) Send(chID byte, msgBytes []byte) bool + func (c *MConnection) SetLogger(l log.Logger) + func (c *MConnection) Status() ConnectionStatus + func (c *MConnection) String() string + func (c *MConnection) TrySend(chID byte, msgBytes []byte) bool + type SecretConnection struct + func MakeSecretConnection(conn io.ReadWriteCloser, locPrivKey crypto.PrivKey) (*SecretConnection, error) + func (sc *SecretConnection) Close() error + func (sc *SecretConnection) LocalAddr() net.Addr + func (sc *SecretConnection) Read(data []byte) (n int, err error) + func (sc *SecretConnection) RemoteAddr() net.Addr + func (sc *SecretConnection) RemotePubKey() crypto.PubKey + func (sc *SecretConnection) SetDeadline(t time.Time) error + func (sc *SecretConnection) SetReadDeadline(t time.Time) error + func (sc *SecretConnection) SetWriteDeadline(t time.Time) error + func (sc *SecretConnection) Write(data []byte) (n int, err error)
Go to main page