protocols

Documentation

Index

• Constants
• type GetProtocolImplInterface
• type ProductionProtocolImpl
  • func (ProductionProtocolImpl) GetProtocolImpl(protocol pbtunnel.Protocol) ProtocolInterface
• type ProtocolConn
• type ProtocolInterface
• type ProtocolListener
• type SctpProtocol
  • func (sp SctpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)
  • func (sp SctpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)
  • func (sp SctpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)
  • func (sp SctpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)
  • func (sp SctpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)
  • func (sp SctpProtocol) ShutdownListener(listener *ProtocolListener) error
  • func (sp SctpProtocol) ShutdownSocket(conn *ProtocolConn) error
• type TcpProtocol
  • func (tp TcpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)
  • func (tp TcpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)
  • func (tp TcpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)
  • func (tp TcpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)
  • func (tp TcpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)
  • func (tp TcpProtocol) ShutdownListener(listener *ProtocolListener) error
  • func (tp TcpProtocol) ShutdownSocket(conn *ProtocolConn) error
• type UdpProtocol
  • func (up UdpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)
  • func (up UdpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)
  • func (up UdpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)
  • func (up UdpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)
  • func (up UdpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)
  • func (up UdpProtocol) ShutdownListener(listener *ProtocolListener) error
  • func (up UdpProtocol) ShutdownSocket(conn *ProtocolConn) error

Constants

const BufferSize = 1500

Types

type GetProtocolImplInterface

type GetProtocolImplInterface interface {
	GetProtocolImpl(protocol pbtunnel.Protocol) ProtocolInterface
}

type ProductionProtocolImpl

type ProductionProtocolImpl struct {
}

func (ProductionProtocolImpl) GetProtocolImpl

func (ProductionProtocolImpl) GetProtocolImpl(protocol pbtunnel.Protocol) ProtocolInterface

type ProtocolConn

type ProtocolConn struct {
	ClosedChan chan error
	// contains filtered or unexported fields
}

type ProtocolInterface

type ProtocolInterface interface {
	SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)
	ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)
	SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)
	ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)
	SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)
	ShutdownSocket(conn *ProtocolConn) error
	ShutdownListener(listener *ProtocolListener) error
}

type ProtocolListener

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

type SctpProtocol

type SctpProtocol struct {
}

func (SctpProtocol) ListenIncomingBytes

func (sp SctpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)

func (SctpProtocol) ReceiveBytesFromSocket

func (sp SctpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)

func (SctpProtocol) SendBytesToSocket

func (sp SctpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)

func (SctpProtocol) SetupIncomingSocket

func (sp SctpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)

func (SctpProtocol) SetupOutgoingSocket

func (sp SctpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)

func (SctpProtocol) ShutdownListener

func (sp SctpProtocol) ShutdownListener(listener *ProtocolListener) error

func (SctpProtocol) ShutdownSocket

func (sp SctpProtocol) ShutdownSocket(conn *ProtocolConn) error

type TcpProtocol

type TcpProtocol struct {
}

func (TcpProtocol) ListenIncomingBytes

func (tp TcpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)

func (TcpProtocol) ReceiveBytesFromSocket

func (tp TcpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)

func (TcpProtocol) SendBytesToSocket

func (tp TcpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)

func (TcpProtocol) SetupIncomingSocket

func (tp TcpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)

func (TcpProtocol) SetupOutgoingSocket

func (tp TcpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)

func (TcpProtocol) ShutdownListener

func (tp TcpProtocol) ShutdownListener(listener *ProtocolListener) error

func (TcpProtocol) ShutdownSocket

func (tp TcpProtocol) ShutdownSocket(conn *ProtocolConn) error

type UdpProtocol

type UdpProtocol struct {
}

func (UdpProtocol) ListenIncomingBytes

func (up UdpProtocol) ListenIncomingBytes(listener *ProtocolListener, localHost string, localPort int32) (*ProtocolConn, error)

func (UdpProtocol) ReceiveBytesFromSocket

func (up UdpProtocol) ReceiveBytesFromSocket(conn *ProtocolConn) ([]byte, error)

func (UdpProtocol) SendBytesToSocket

func (up UdpProtocol) SendBytesToSocket(conn *ProtocolConn, bytes []byte) (int, error)

func (UdpProtocol) SetupIncomingSocket

func (up UdpProtocol) SetupIncomingSocket(localHost string, localPort int32) (*ProtocolListener, error)

func (UdpProtocol) SetupOutgoingSocket

func (up UdpProtocol) SetupOutgoingSocket(remoteHost string, remotePort int32) (*ProtocolConn, error)

func (UdpProtocol) ShutdownListener

func (up UdpProtocol) ShutdownListener(listener *ProtocolListener) error

func (UdpProtocol) ShutdownSocket

func (up UdpProtocol) ShutdownSocket(conn *ProtocolConn) error