Versions in this module Expand all Collapse all v0 v0.0.1 Feb 11, 2022 Changes in this version + const MAX_INDEX + const MAX_PROTO_PACK_SIZE + var CLIENT_TYPE_name = map[int32]string + var CLIENT_TYPE_value = map[string]int32 + var FRAME_TYPE_name = map[int32]string + var FRAME_TYPE_value = map[string]int32 + var PROXY_PROTO_name = map[int32]string + var PROXY_PROTO_value = map[string]int32 + func MarshalSrpFrame(f *ProxyFrame, compress int, encrpyt string) ([]byte, error) + type CLIENT_TYPE int32 + const CLIENT_TYPE_PROXY + const CLIENT_TYPE_REVERSE_PROXY + const CLIENT_TYPE_REVERSE_SOCKS5 + const CLIENT_TYPE_SOCKS5 + const CLIENT_TYPE_SS_PROXY + func (CLIENT_TYPE) EnumDescriptor() ([]byte, []int) + func (x CLIENT_TYPE) String() string + type Client struct + func NewClient(config *Config, serverproto string, server string, name string, ...) (*Client, error) + func (c *Client) Close() + type ClientConn struct + type CloseFrame struct + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseFrame) Descriptor() ([]byte, []int) + func (*CloseFrame) ProtoMessage() + func (m *CloseFrame) GetId() string + func (m *CloseFrame) Reset() + func (m *CloseFrame) String() string + func (m *CloseFrame) XXX_DiscardUnknown() + func (m *CloseFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseFrame) XXX_Merge(src proto.Message) + func (m *CloseFrame) XXX_Size() int + func (m *CloseFrame) XXX_Unmarshal(b []byte) error + type Config struct + Compress int + Congestion string + ConnBuffer int + ConnTimeout int + ConnectTimeout int + Encrypt string + EstablishedTimeout int + Key string + MainBuffer int + MainWriteChannelTimeoutMs int + MaxClient int + MaxMsgSize int + MaxSonny int + Password string + PingInter int + PingTimeoutInter int + ShowPing bool + Username string + func DefaultConfig() *Config + type DataFrame struct + Compress bool + Crc string + Data []byte + Id string + Index int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataFrame) Descriptor() ([]byte, []int) + func (*DataFrame) ProtoMessage() + func (m *DataFrame) GetCompress() bool + func (m *DataFrame) GetCrc() string + func (m *DataFrame) GetData() []byte + func (m *DataFrame) GetId() string + func (m *DataFrame) GetIndex() int32 + func (m *DataFrame) Reset() + func (m *DataFrame) String() string + func (m *DataFrame) XXX_DiscardUnknown() + func (m *DataFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataFrame) XXX_Merge(src proto.Message) + func (m *DataFrame) XXX_Size() int + func (m *DataFrame) XXX_Unmarshal(b []byte) error + type DeadLock struct + type FRAME_TYPE int32 + const FRAME_TYPE_CLOSE + const FRAME_TYPE_DATA + const FRAME_TYPE_LOGIN + const FRAME_TYPE_LOGINRSP + const FRAME_TYPE_OPEN + const FRAME_TYPE_OPENRSP + const FRAME_TYPE_PING + const FRAME_TYPE_PONG + func (FRAME_TYPE) EnumDescriptor() ([]byte, []int) + func (x FRAME_TYPE) String() string + type Inputer struct + func NewInputer(wg *group.Group, proto string, addr string, clienttype CLIENT_TYPE, ...) (*Inputer, error) + func NewSocks5Inputer(wg *group.Group, proto string, addr string, clienttype CLIENT_TYPE, ...) (*Inputer, error) + func (i *Inputer) Close() + type LoginFrame struct + Clienttype CLIENT_TYPE + Fromaddr string + Key string + Name string + Proxyproto PROXY_PROTO + Toaddr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoginFrame) Descriptor() ([]byte, []int) + func (*LoginFrame) ProtoMessage() + func (m *LoginFrame) GetClienttype() CLIENT_TYPE + func (m *LoginFrame) GetFromaddr() string + func (m *LoginFrame) GetKey() string + func (m *LoginFrame) GetName() string + func (m *LoginFrame) GetProxyproto() PROXY_PROTO + func (m *LoginFrame) GetToaddr() string + func (m *LoginFrame) Reset() + func (m *LoginFrame) String() string + func (m *LoginFrame) XXX_DiscardUnknown() + func (m *LoginFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoginFrame) XXX_Merge(src proto.Message) + func (m *LoginFrame) XXX_Size() int + func (m *LoginFrame) XXX_Unmarshal(b []byte) error + type LoginRspFrame struct + Msg string + Ret bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoginRspFrame) Descriptor() ([]byte, []int) + func (*LoginRspFrame) ProtoMessage() + func (m *LoginRspFrame) GetMsg() string + func (m *LoginRspFrame) GetRet() bool + func (m *LoginRspFrame) Reset() + func (m *LoginRspFrame) String() string + func (m *LoginRspFrame) XXX_DiscardUnknown() + func (m *LoginRspFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LoginRspFrame) XXX_Merge(src proto.Message) + func (m *LoginRspFrame) XXX_Size() int + func (m *LoginRspFrame) XXX_Unmarshal(b []byte) error + type OpenConnFrame struct + Id string + Toaddr string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenConnFrame) Descriptor() ([]byte, []int) + func (*OpenConnFrame) ProtoMessage() + func (m *OpenConnFrame) GetId() string + func (m *OpenConnFrame) GetToaddr() string + func (m *OpenConnFrame) Reset() + func (m *OpenConnFrame) String() string + func (m *OpenConnFrame) XXX_DiscardUnknown() + func (m *OpenConnFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OpenConnFrame) XXX_Merge(src proto.Message) + func (m *OpenConnFrame) XXX_Size() int + func (m *OpenConnFrame) XXX_Unmarshal(b []byte) error + type OpenConnRspFrame struct + Id string + Msg string + Ret bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenConnRspFrame) Descriptor() ([]byte, []int) + func (*OpenConnRspFrame) ProtoMessage() + func (m *OpenConnRspFrame) GetId() string + func (m *OpenConnRspFrame) GetMsg() string + func (m *OpenConnRspFrame) GetRet() bool + func (m *OpenConnRspFrame) Reset() + func (m *OpenConnRspFrame) String() string + func (m *OpenConnRspFrame) XXX_DiscardUnknown() + func (m *OpenConnRspFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OpenConnRspFrame) XXX_Merge(src proto.Message) + func (m *OpenConnRspFrame) XXX_Size() int + func (m *OpenConnRspFrame) XXX_Unmarshal(b []byte) error + type Outputer struct + func NewOutputer(wg *group.Group, proto string, clienttype CLIENT_TYPE, config *Config, ...) (*Outputer, error) + func NewSSOutputer(wg *group.Group, proto string, clienttype CLIENT_TYPE, config *Config, ...) (*Outputer, error) + func (o *Outputer) Close() + type PROXY_PROTO int32 + const PROXY_PROTO_KCP + const PROXY_PROTO_RICMP + const PROXY_PROTO_RUDP + const PROXY_PROTO_TCP + const PROXY_PROTO_UDP + func (PROXY_PROTO) EnumDescriptor() ([]byte, []int) + func (x PROXY_PROTO) String() string + type PingFrame struct + Time int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PingFrame) Descriptor() ([]byte, []int) + func (*PingFrame) ProtoMessage() + func (m *PingFrame) GetTime() int64 + func (m *PingFrame) Reset() + func (m *PingFrame) String() string + func (m *PingFrame) XXX_DiscardUnknown() + func (m *PingFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PingFrame) XXX_Merge(src proto.Message) + func (m *PingFrame) XXX_Size() int + func (m *PingFrame) XXX_Unmarshal(b []byte) error + type PongFrame struct + Time int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PongFrame) Descriptor() ([]byte, []int) + func (*PongFrame) ProtoMessage() + func (m *PongFrame) GetTime() int64 + func (m *PongFrame) Reset() + func (m *PongFrame) String() string + func (m *PongFrame) XXX_DiscardUnknown() + func (m *PongFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PongFrame) XXX_Merge(src proto.Message) + func (m *PongFrame) XXX_Size() int + func (m *PongFrame) XXX_Unmarshal(b []byte) error + type ProxyConn struct + type ProxyFrame struct + CloseFrame *CloseFrame + DataFrame *DataFrame + LoginFrame *LoginFrame + LoginRspFrame *LoginRspFrame + OpenFrame *OpenConnFrame + OpenRspFrame *OpenConnRspFrame + PingFrame *PingFrame + PongFrame *PongFrame + Type FRAME_TYPE + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func UnmarshalSrpFrame(b []byte, encrpyt string) (*ProxyFrame, error) + func (*ProxyFrame) Descriptor() ([]byte, []int) + func (*ProxyFrame) ProtoMessage() + func (m *ProxyFrame) GetCloseFrame() *CloseFrame + func (m *ProxyFrame) GetDataFrame() *DataFrame + func (m *ProxyFrame) GetLoginFrame() *LoginFrame + func (m *ProxyFrame) GetLoginRspFrame() *LoginRspFrame + func (m *ProxyFrame) GetOpenFrame() *OpenConnFrame + func (m *ProxyFrame) GetOpenRspFrame() *OpenConnRspFrame + func (m *ProxyFrame) GetPingFrame() *PingFrame + func (m *ProxyFrame) GetPongFrame() *PongFrame + func (m *ProxyFrame) GetType() FRAME_TYPE + func (m *ProxyFrame) Reset() + func (m *ProxyFrame) String() string + func (m *ProxyFrame) XXX_DiscardUnknown() + func (m *ProxyFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ProxyFrame) XXX_Merge(src proto.Message) + func (m *ProxyFrame) XXX_Size() int + func (m *ProxyFrame) XXX_Unmarshal(b []byte) error + type Server struct + func NewServer(config *Config, proto []string, listenaddrs []string) (*Server, error) + func (s *Server) Close() + type ServerConn struct + type State struct + CheckFps int32 + CheckFrames int32 + CopyFps int32 + CopyFrames int32 + MainRecvNum int32 + MainRecvSize int64 + MainSendNum int32 + MainSendSize int64 + RecvCompSaveSize int64 + RecvFps int32 + RecvFrames int32 + RecvNum int32 + RecvSize int64 + RecvSonnyFps int32 + RecvSonnyFrames int32 + SendCompSaveSize int64 + SendFps int32 + SendFrames int32 + SendNum int32 + SendSize int64 + SendSonnyFps int32 + SendSonnyFrames int32 + type StateThreadNum struct + CheckThread int32 + CopyThread int32 + RecvSonnyThread int32 + RecvThread int32 + SendSonnyThread int32 + SendThread int32 + ThreadNum int32
Go to main page