connection

Nov 19, 2018

Changes in this version

type MConnection

+ func (c *MConnection) TrafficStatus() (*flowrate.Status, *flowrate.Status)

Jun 19, 2018

Changes in this version

+ type ChannelDescriptor struct

+ ID byte

+ Priority int

+ RecvBufferCapacity int

+ RecvMessageCapacity int

+ SendQueueCapacity int

+ func (chDesc *ChannelDescriptor) FillDefaults()

+ type MConnConfig struct

+ RecvRate int64

+ SendRate int64

+ func DefaultMConnConfig() *MConnConfig

+ type MConnection struct

+ func NewMConnectionWithConfig(conn net.Conn, chDescs []*ChannelDescriptor, onReceive receiveCbFunc, ...) *MConnection

+ func (c *MConnection) CanSend(chID byte) bool

+ func (c *MConnection) OnStart() error

+ func (c *MConnection) OnStop()

+ func (c *MConnection) Send(chID byte, msg interface{}) bool

+ func (c *MConnection) String() string

+ func (c *MConnection) TrySend(chID byte, msg interface{}) bool

+ type SecretConnection struct

+ func MakeSecretConnection(conn io.ReadWriteCloser, locPrivKey crypto.PrivKeyEd25519) (*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.PubKeyEd25519

+ 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)