Versions in this module Expand all Collapse all v0 v0.35.0 May 28, 2023 v0.34.9 May 28, 2023 v0.34.8 May 28, 2023 v0.34.7 May 28, 2023 v0.34.6 May 28, 2023 v0.34.5 May 28, 2023 v0.34.4 May 28, 2023 v0.34.3 May 28, 2023 v0.34.2 May 28, 2023 v0.34.1 May 28, 2023 v0.34.0 May 28, 2023 v0.33.9 May 28, 2023 v0.33.8 Mar 28, 2023 v0.33.7 Sep 13, 2022 Changes in this version + var ErrSharedSecretIsZero = errors.New("shared secret is all zeroes") + var ErrSmallOrderRemotePubKey = errors.New("detected low order point from remote peer") + func NetPipe() (net.Conn, net.Conn) + func RegisterPacket(cdc *amino.Codec) + 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 + 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 Packet interface + AssertIsPacket func() + type PacketMsg struct + Bytes []byte + ChannelID byte + EOF byte + func (PacketMsg) AssertIsPacket() + func (mp PacketMsg) String() string + type PacketPing struct + func (PacketPing) AssertIsPacket() + type PacketPong struct + func (PacketPong) AssertIsPacket() + 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