connection

May 8, 2021

Changes in this version

+ type Channel struct

+ type ChannelConfig struct

+ type ChannelGroup struct

+ type ChannelGroupConfig struct

+ type ChannelSelector interface

+ type Connection struct

+ func CreateConnection(netconn net.Conn, config ConnectionConfig) *Connection

+ func (conn *Connection) AttemptToEnqueueMessage(channelID common.ChannelIDEnum, message interface{}) bool

+ func (conn *Connection) CanEnqueueMessage(channelID common.ChannelIDEnum) bool

+ func (conn *Connection) CancelConnection()

+ func (conn *Connection) DoEncHandshake(prv *ecdsa.PrivateKey, dial *ecdsa.PublicKey) (*crypto.PublicKey, error)

+ func (conn *Connection) EnqueueMessage(channelID common.ChannelIDEnum, message interface{}) bool

+ func (conn *Connection) GetBufNetconn() io.ReadWriter

+ func (conn *Connection) GetBufReader() *bufio.Reader

+ func (conn *Connection) GetNetconn() net.Conn

+ func (conn *Connection) SetErrorHandler(errorHandler ErrorHandler)

+ func (conn *Connection) SetMessageEncoder(messageEncoder MessageEncoder)

+ func (conn *Connection) SetMessageParser(messageParser MessageParser)

+ func (conn *Connection) SetPingTimer(seconds time.Duration)

+ func (conn *Connection) SetReceiveHandler(receiveHandler ReceiveHandler)

+ func (conn *Connection) Start(ctx context.Context) bool

+ func (conn *Connection) Stop()

+ func (conn *Connection) Wait()

+ type ConnectionConfig struct

+ FlushThrottle time.Duration

+ MaxPendingPings uint32

+ PacketBatchSize int64

+ PingTimeout time.Duration

+ RecvRate int64

+ SendRate int64

+ func GetDefaultConnectionConfig() ConnectionConfig

+ type ErrorHandler func(interface{})

+ type MessageEncoder func(channelID common.ChannelIDEnum, message interface{}) (common.Bytes, error)

+ type MessageParser func(channelID common.ChannelIDEnum, rawMessageBytes common.Bytes) (p2ptypes.Message, error)

+ type Packet struct

+ Bytes []byte

+ ChannelID common.ChannelIDEnum

+ IsEOF byte

+ SeqID uint

+ func (p Packet) String() string

+ type ReceiveHandler func(message p2ptypes.Message) error

+ type RecvBuffer struct

+ type RecvBufferConfig struct

+ type RoundRobinChannelSelector struct

+ type SendBuffer struct

+ type SendBufferConfig struct