session

package

Go to main page

Versions in this module

v1

v1.2.2

Feb 3, 2024

v1.2.1

May 29, 2022

v1.2.0

May 29, 2022

Changes in this version

type Session

+ DisableMuxer bool

v1.1.77

Aug 11, 2021

v1.1.76

Jul 26, 2021

v1.1.75

Jul 26, 2021

Changes in this version

+ const IoTManagerAddr

+ func LoadConfigFromIoTManager() (err error)

v1.1.74

Jul 25, 2021

v1.1.73

Jul 25, 2021

Changes in this version

type SessionsManager

+ func (sm *SessionsManager) UpdateOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.HTTPConfig, error)

v1.1.72

Mar 5, 2021

v1.1.71

Mar 5, 2021

v1.1.70

Mar 5, 2021

v1.1.69

Mar 4, 2021

v1.1.68

Mar 2, 2021

v1.1.67

Mar 2, 2021

v1.1.66

Mar 2, 2021

v1.1.65

Mar 2, 2021

v1.1.64

Mar 2, 2021

v1.1.63

Feb 19, 2021

v1.1.62

Feb 18, 2021

v1.1.61

Feb 18, 2021

v1.1.60

Jan 8, 2021

v1.1.59

Sep 7, 2020

v1.1.58

Sep 6, 2020

v1.1.57

Sep 5, 2020

v1.1.56

Sep 5, 2020

v1.1.55

Sep 4, 2020

v1.1.54

Sep 2, 2020

Changes in this version

+ func InitSessionsCtl()

type Session

+ func (sess *Session) GetNewWorkConn() (net.Conn, error)

+ func (sess *Session) GetStream() (*yamux.Stream, error)

+ func (sess *Session) RequestNewWorkConn() error

type SessionsManager

+ RedisPool *redis.Pool

+ func (sess *SessionsManager) CheckRedisKeyExit(key string) (bool, error)

+ func (sess *SessionsManager) DelRedisByKey(key string) error

+ func (sess *SessionsManager) GetAllRedisKey() ([]string, error)

+ func (sess *SessionsManager) GetNewWorkConnByID(id string) (net.Conn, error)

+ func (sess *SessionsManager) GetRedisConn() (redis.Conn, error)

+ func (sess *SessionsManager) GetRedisValueByKey(key string) (interface{}, error)

+ func (sess *SessionsManager) GetRedisValueByKeyToBool(key string) (bool, error)

+ func (sess *SessionsManager) GetRedisValueByKeyToBytes(key string) ([]byte, error)

+ func (sess *SessionsManager) GetRedisValueByKeyToInt(key string) (int, error)

+ func (sess *SessionsManager) GetRedisValueByKeyToString(key string) (string, error)

+ func (sess *SessionsManager) GetSessionByID(id string) (*Session, error)

+ func (sess *SessionsManager) GetStreamByID(id string) (*yamux.Stream, error)

+ func (sess *SessionsManager) SetRedisKeyValue(key string, value interface{}) error

+ func (sm *SessionsManager) UpdateAllHttpRemotePortStatus()

+ func (sm *SessionsManager) UpdateHttpProxyByMap(HttpProxyMap map[string]*HttpProxy)

v1.1.53

Jul 26, 2020

v1.1.52

Jul 22, 2020

v1.1.51

Jul 22, 2020

Changes in this version

type Session

+ ARCH string

+ OS string

+ Version string

v1.1.50

Jul 19, 2020

v1.1.49

Jul 18, 2020

v1.1.48

Jul 10, 2020

v1.1.47

Jul 3, 2020

v1.1.46

Jul 3, 2020

v1.1.45

Jun 5, 2020

v1.1.44

May 10, 2020

v1.1.43

May 10, 2020

v1.1.42

May 10, 2020

v1.1.41

May 10, 2020

v1.1.39

May 8, 2020

v1.1.38

May 4, 2020

v1.1.37

May 4, 2020

v1.1.36

May 4, 2020

v1.1.35

Apr 30, 2020

v1.1.34

Apr 29, 2020

v1.1.33

Apr 28, 2020

v1.1.32

Apr 28, 2020

v1.1.31

Apr 28, 2020

v1.1.30

Apr 27, 2020

Changes in this version

+ var SessionsCtl = SessionsManager

+ type HttpProxy struct

+ Description string

+ Domain string

+ IfHttps bool

+ Password string

+ RemoteIP string

+ RemotePort int

+ RemotePortStatus bool

+ RunId string

+ UserName string

+ func (hp *HttpProxy) UpdateRemotePortStatus()

type Session

+ GatewaySession *yamux.Session

+ type SessionsManager struct

+ HttpProxyMap map[string]*HttpProxy

+ Session map[string]*Session

+ func (sess *SessionsManager) DelSession(id string)

+ func (sess *SessionsManager) GetSession(id string) (*Session, error)

+ func (sess *SessionsManager) GetStream(id string) (*yamux.Stream, error)

+ func (sess *SessionsManager) SetSession(id string, session *Session)

+ func (sess SessionsManager) RunKCP()

+ func (sess SessionsManager) RunTCP()

+ func (sess SessionsManager) RunTLS()

+ func (sess SessionsManager) StartHttpListenAndServ()

+ func (sm *SessionsManager) AddHttpProxy(httpProxy *HttpProxy) error

+ func (sm *SessionsManager) CheckRemoteStatus(targetType, runId, remoteIp string, remotePort int) (bool, error)

+ func (sm *SessionsManager) ConnectToSSH(runId, remoteIP string, remotePort int, userName, passWord string) (stream *yamux.Stream, err error)

+ func (sm *SessionsManager) ConnectToSerialPort(runId string, msgsd *models.ConnectSerialPort) (*yamux.Stream, error)

+ func (sm *SessionsManager) ConnectToTapTun(runId string) (*yamux.Stream, error)

+ func (sm *SessionsManager) ConnectToTcp(runId, remoteIp string, remotePort int) (*yamux.Stream, error)

+ func (sm *SessionsManager) ConnectToTls(runId, remoteIp string, remotePort int) (*yamux.Stream, error)

+ func (sm *SessionsManager) ConnectToUdp(runId, remoteIp string, remotePort int) (*yamux.Stream, error)

+ func (sm *SessionsManager) ConnectToWs(runId, targetUrl, protocol, origin string) (*yamux.Stream, error)

+ func (sm *SessionsManager) CreateOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.HTTPConfig, error)

+ func (sm *SessionsManager) DelHttpProxy(id string)

+ func (sm *SessionsManager) DeleteOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.Empty, error)

+ func (sm *SessionsManager) GetAllHTTP(ctx context.Context, in *pb.Empty) (*pb.HTTPList, error)

+ func (sm *SessionsManager) GetAllHttpProxy() map[string]*HttpProxy

+ func (sm *SessionsManager) GetOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.HTTPConfig, error)

+ func (sm *SessionsManager) GetOneHttpProxy(id string) (*HttpProxy, error)

+ func (sm *SessionsManager) ListenMulticastUDP(runId, ip string, port uint) (*yamux.Stream, error)

+ func (sm *SessionsManager) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (sm *SessionsManager) StartgRpcListenAndServ()

v1.1.29

Feb 14, 2020

v1.1.28

Feb 14, 2020

v1.1.27

Feb 14, 2020

v1.1.26

Feb 14, 2020

v1.1.25

Feb 13, 2020

v1.1.24

Feb 12, 2020

v1.1.23

Feb 12, 2020

v1.1.22

Feb 12, 2020

v1.1.21

Feb 12, 2020

v1.1.20

Feb 12, 2020

v1.1.19

Feb 12, 2020

v1.1.18

Feb 12, 2020

v1.1.17

Feb 12, 2020

v1.1.16

Feb 12, 2020

v1.1.15

Feb 12, 2020

v1.1.14

Feb 12, 2020

v1.1.13

Feb 12, 2020

v1.1.12

Feb 12, 2020

v1.1.11

Feb 12, 2020

v1.1.10

Feb 12, 2020

v1.1.9

Feb 12, 2020

v1.1.8

Feb 12, 2020

Changes in this version

+ func DelSession(id string)

+ func GetStream(id string) (*mux.Stream, error)

+ func PanicHandler()

+ func RunKCP(port int)

+ func RunTCP(port int)

+ func RunTLS(port int)

+ func SetSession(id string, session *Session)

+ type Session struct

+ Conn *net.Conn

+ Id string

+ Ssession *mux.Session

+ WorkConn chan net.Conn

+ func GetSession(id string) (*Session, error)

+ func (sess *Session) Task()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL