interaction

type Compressor interface {
	Compress(rawData []byte) ([]byte, error)
	DeCompress(compressedData []byte) ([]byte, error)
}

type ConnContext struct {
	RemoteAddr string
}

type Default struct {
	ConnType int
	// contains filtered or unexported fields
}

type Encoder interface {
	Encode(data interface{}) ([]byte, error)
	Decode(encodeData []byte, decodeData interface{}) error
}

type ExponentialRetry struct {
	// contains filtered or unexported fields
}

type GeneralWsReq struct {
	ReqIdentifier int    `json:"reqIdentifier"`
	Token         string `json:"token"`
	SendID        string `json:"sendID"`
	OperationID   string `json:"operationID"`
	MsgIncr       string `json:"msgIncr"`
	Data          []byte `json:"data"`
}

type GeneralWsResp struct {
	ReqIdentifier int    `json:"reqIdentifier"`
	ErrCode       int    `json:"errCode"`
	ErrMsg        string `json:"errMsg"`
	MsgIncr       string `json:"msgIncr"`
	OperationID   string `json:"operationID"`
	Data          []byte `json:"data"`
}

type GobEncoder struct {
}

type GzipCompressor struct {
	// contains filtered or unexported fields
}

type LongConn interface {
	//Close this connection
	Close() error
	// WriteMessage Write message to connection,messageType means data type,can be set binary(2) and text(1).
	WriteMessage(messageType int, message []byte) error
	// ReadMessage Read message from connection.
	ReadMessage() (int, []byte, error)
	// SetReadDeadline sets the read deadline on the underlying network connection,
	//after a read has timed out, will return an error.
	SetReadDeadline(timeout time.Duration) error
	// SetWriteDeadline sets to write deadline when send message,when read has timed out,will return error.
	SetWriteDeadline(timeout time.Duration) error
	// Dial Try to dial a connection,url must set auth args,header can control compress data
	Dial(urlStr string, requestHeader http.Header) (*http.Response, error)
	// IsNil Whether the connection of the current long connection is nil
	IsNil() bool
	// SetReadLimit sets the maximum size for a message read from the peer.bytes
	SetReadLimit(limit int64)
	SetPongHandler(handler PongHandler)
	// LocalAddr returns the local network address.
	LocalAddr() string
}

type LongConnMgr struct {
	IsCompression bool
	Syncer        *WsRespAsyn

	IsBackground bool
	// contains filtered or unexported fields
}

type Message struct {
	Message GeneralWsReq
	Resp    chan *GeneralWsResp
}

type MsgSyncer struct {
	PushMsgAndMaxSeqCh chan common.Cmd2Value // channel for receiving push messages and the maximum SEQ number
	// contains filtered or unexported fields
}

type PongHandler func(string) error

type ReconnectStrategy interface {
	GetSleepInterval() time.Duration
	Reset()
}

type WsRespAsyn struct {
	// contains filtered or unexported fields
}