Versions in this module Expand all Collapse all v0 v0.2.2 Sep 18, 2023 v0.2.0 Sep 18, 2023 Changes in this version + const LocalPortForwardingType + type BasicPortForwarding struct + func (p *BasicPortForwarding) InitializeStreams(log log.T, agentVersion string) (err error) + func (p *BasicPortForwarding) IsStreamNotSet() (status bool) + func (p *BasicPortForwarding) ReadStream(log log.T) (err error) + func (p *BasicPortForwarding) Stop() + func (p *BasicPortForwarding) WriteStream(outputMessage message.ClientMessage) error + type IPortSession interface + InitializeStreams func(log log.T, agentVersion string) (err error) + IsStreamNotSet func() (status bool) + ReadStream func(log log.T) (err error) + Stop func() + WriteStream func(outputMessage message.ClientMessage) (err error) + type MgsConn struct + type MuxClient struct + type MuxPortForwarding struct + func (p *MuxPortForwarding) InitializeStreams(log log.T, agentVersion string) (err error) + func (p *MuxPortForwarding) IsStreamNotSet() (status bool) + func (p *MuxPortForwarding) ReadStream(log log.T) (err error) + func (p *MuxPortForwarding) Stop() + func (p *MuxPortForwarding) WriteStream(outputMessage message.ClientMessage) error + type PortParameters struct + LocalConnectionType string + LocalPortNumber string + LocalUnixSocket string + PortNumber string + Type string + type PortSession struct + func (PortSession) Name() string + func (s *PortSession) Initialize(log log.T, sessionVar *session.Session) + func (s *PortSession) ProcessStreamMessagePayload(log log.T, outputMessage message.ClientMessage) (isHandlerReady bool, err error) + func (s *PortSession) SetSessionHandlers(log log.T) (err error) + func (s *PortSession) Stop() + type StandardStreamForwarding struct + func (p *StandardStreamForwarding) InitializeStreams(log log.T, agentVersion string) (err error) + func (p *StandardStreamForwarding) IsStreamNotSet() (status bool) + func (p *StandardStreamForwarding) ReadStream(log log.T) (err error) + func (p *StandardStreamForwarding) Stop() + func (p *StandardStreamForwarding) WriteStream(outputMessage message.ClientMessage) error