protocol

Oct 3, 2023

Changes in this version

type Connection

+ ConnProtocol func() string

Sep 18, 2022

Changes in this version

+ const HEADER

+ const HEAD_SIZE

+ const MAX_LENGTH

+ var ExceededErr = errors.New("The maximum length of the packet is exceeded")

+ var HeaderErr = errors.New("The message header is incorrect")

+ func GenerateTLSConfigForClient() *tls.Config

+ func GenerateTLSConfigForServer() *tls.Config

+ func NewTLSConfigFromFile(tlsCertFile, tlsKeyFile string, insecureSkipVerifyForClient ...bool) (*tls.Config, error)

+ type Connection interface

+ Addr func() string

+ Close func() error

+ ReadMsg func() ([]byte, error)

+ WriteMsg func(data []byte) error

+ type FlowProtocol struct

+ func NewFlowProtocol(header string, bufLength int, conn io.Reader) *FlowProtocol

+ func (this *FlowProtocol) Pack(data []byte) ([]byte, error)

+ func (this *FlowProtocol) ReadMsg() ([]byte, error)

+ type Proto interface

+ Pack func([]byte) ([]byte, error)

+ ReadMsg func() ([]byte, error)

+ type Protocol interface

+ Dial func(addr string) (Connection, error)

+ ListenAndServe func(port int64, onConnect func(conn Connection)) error

+ type Session struct

+ ClientId string

+ Conn Connection

+ func (s *Session) CasClientId(newClientId string) string

+ func (s *Session) LoadClientId() string

+ func (s *Session) StoreClientId(newClientId string)