channel

Documentation

Index

• Constants
• func GetConnData(conn net.Conn, bufferSize int, delay time.Duration) ([]byte, error)
• type CBPacket
• type CBPacketType
• type Channel
  • func NewChannel(typ PeerType, options ChannelOptions) (*Channel, error)
  • func (c *Channel) CloseChannel()
  • func (c *Channel) Receive() []byte
  • func (c *Channel) Send(data []byte)
• type ChannelOptions
• type ControlPacketCallback
• type PeerType
• type PortForwarding
  • func ParsePortForwarding(param string) (*PortForwarding, error)
• type Tunnel
  • func NewTunnel(typ PeerType, options ChannelOptions) (*Tunnel, error)
  • func (c *Tunnel) AddLocalPortForwarding(fwd PortForwarding)
  • func (c *Tunnel) AddRemotePortForwarding(fwd PortForwarding)
  • func (t *Tunnel) ExecuteCommand(cmd string) (output string, err error)
  • func (t *Tunnel) StartClient()
  • func (t *Tunnel) StartServer()
  • func (t *Tunnel) StartSftp() *sftp.Client
  • func (t *Tunnel) StartSocksOnPort(port int)

Constants

const (
	QueueSize = 16
)

Functions

func GetConnData

func GetConnData(conn net.Conn, bufferSize int, delay time.Duration) ([]byte, error)

Types

type CBPacket

type CBPacket struct {
	Target  PeerType
	Type    CBPacketType
	Payload string
	Seq     int
	Ack     int
}

type CBPacketType

type CBPacketType int

const (
	PacketTypeData CBPacketType = iota
	PacketTypeControl
)

type Channel

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

func NewChannel

func NewChannel(typ PeerType, options ChannelOptions) (*Channel, error)

func (*Channel) CloseChannel

func (c *Channel) CloseChannel()

func (*Channel) Receive

func (c *Channel) Receive() []byte

func (*Channel) Send

func (c *Channel) Send(data []byte)

type ChannelOptions

type ChannelOptions struct {
	ControlPacketCallback ControlPacketCallback
	Interval              time.Duration
	Password              string
	Transport             string
	Blocksize             int
	ErrorLogger           *log.Logger
	DebugLogger           *log.Logger
	TraceLogger           *log.Logger
}

type ControlPacketCallback

type ControlPacketCallback func(cmd, arg string)

type PeerType

type PeerType int

const (
	CLIENT PeerType = iota
	SERVER
)

type PortForwarding

type PortForwarding struct {
	Port     string
	Host     string
	HostPort string
}

func ParsePortForwarding

func ParsePortForwarding(param string) (*PortForwarding, error)

type Tunnel

type Tunnel struct {
	Channel
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(typ PeerType, options ChannelOptions) (*Tunnel, error)

func (*Tunnel) AddLocalPortForwarding

func (c *Tunnel) AddLocalPortForwarding(fwd PortForwarding)

func (*Tunnel) AddRemotePortForwarding

func (c *Tunnel) AddRemotePortForwarding(fwd PortForwarding)

func (*Tunnel) ExecuteCommand

func (t *Tunnel) ExecuteCommand(cmd string) (output string, err error)

func (*Tunnel) StartClient

func (t *Tunnel) StartClient()

func (*Tunnel) StartServer

func (t *Tunnel) StartServer()

func (*Tunnel) StartSftp

func (t *Tunnel) StartSftp() *sftp.Client

func (*Tunnel) StartSocksOnPort

func (t *Tunnel) StartSocksOnPort(port int)