Versions in this module Expand all Collapse all v1 v1.2.2 Feb 3, 2024 Changes in this version + const IoTManagerAddr + func InitSessionsCtl() + func LoadConfigFromIoTManager() (err error) + 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 SessionsManager struct + HttpProxyRuntimeStorage runtimeStorage.RuntimeStorageIfce + Session map[string]*session.Session + var SessionsCtl SessionsManager + func (sess *SessionsManager) DelSession(id string) + func (sess *SessionsManager) GetNewWorkConnByID(id string) (net.Conn, error) + func (sess *SessionsManager) GetSessionByID(id string) (*session.Session, error) + func (sess *SessionsManager) GetStreamByID(id string) (net.Conn, error) + func (sess *SessionsManager) SetSession(id string, session *session.Session) + func (sess SessionsManager) RunKCP() + func (sess SessionsManager) RunTCP() + func (sess SessionsManager) RunTLS() + func (sess SessionsManager) StartHttpListenAndServ() + func (sm *SessionsManager) AddOrUpdateHttpProxy(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 net.Conn, err error) + func (sm *SessionsManager) ConnectToSerialPort(runId string, msgsd *models.ConnectSerialPort) (net.Conn, error) + func (sm *SessionsManager) ConnectToTapTun(runId string) (net.Conn, error) + func (sm *SessionsManager) ConnectToTcp(runId, remoteIp string, remotePort int) (net.Conn, error) + func (sm *SessionsManager) ConnectToTls(runId, remoteIp string, remotePort int) (net.Conn, error) + func (sm *SessionsManager) ConnectToUdp(runId, remoteIp string, remotePort int) (net.Conn, error) + func (sm *SessionsManager) ConnectToWs(runId, targetUrl, protocol, origin string) (net.Conn, error) + func (sm *SessionsManager) CreateOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.HTTPConfig, error) + func (sm *SessionsManager) DelHttpProxy(domain string) + func (sm *SessionsManager) DeleteOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*emptypb.Empty, error) + func (sm *SessionsManager) GetAllHTTP(ctx context.Context, in *pb.Device) (*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(domain string) (*HttpProxy, error) + func (sm *SessionsManager) ListenMulticastUDP(runId, ip string, port uint) (net.Conn, error) + func (sm *SessionsManager) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (sm *SessionsManager) StartgRpcListenAndServ() + func (sm *SessionsManager) UpdateAllHttpRemotePortStatus() + func (sm *SessionsManager) UpdateHttpProxyByMap(HttpProxyMap map[string]*HttpProxy) + func (sm *SessionsManager) UpdateOneHTTP(ctx context.Context, in *pb.HTTPConfig) (*pb.HTTPConfig, error)