Versions in this module Expand all Collapse all v100 v100.2.4 Sep 4, 2024 v100.2.3 Sep 4, 2024 v100.2.2 Sep 4, 2024 v100.2.1 Sep 4, 2024 v100.2.0 Sep 4, 2024 v100.1.0 Sep 3, 2024 v100.0.4 Sep 3, 2024 v100.0.3 Sep 3, 2024 v100.0.2 Sep 3, 2024 v100.0.1 Sep 3, 2024 v100.0.0 Sep 3, 2024 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 + MessageType proto.Message + 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 + TestFuzz bool + TestFuzzConfig *config.FuzzConnConfig + 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) Other modules containing this package github.com/KYVENetwork/cometbft/v34 github.com/KYVENetwork/cometbft/v37 github.com/KYVENetwork/cometbft/v38
Go to main page