udpsctpserver

Documentation

Index

• type BufferedConn
  • func NewBufferedConn(str io.ReadWriteCloser) *BufferedConn
  • func (b BufferedConn) Close() error
  • func (b BufferedConn) Read(p []byte) (n int, err error)
  • func (b BufferedConn) Write(p []byte) (n int, err error)
• type PacketSCTPRelay
  • func NewPacketRelayClient(conn net.Conn, TxChannel chan interfaces.TrafficWithChannelTag, ...) *PacketSCTPRelay
  • func NewPacketRelayServer(conn net.Conn, TxChannel chan interfaces.TrafficWithChannelTag, ...) *PacketSCTPRelay
  • func (s *PacketSCTPRelay) ClientOpen()
  • func (s *PacketSCTPRelay) ClientOpenStream() io.ReadWriteCloser
  • func (s *PacketSCTPRelay) CtlConn(str *sctp.Stream)
  • func (s *PacketSCTPRelay) GetTransmitLayerSentRecvStats() (uint64, uint64)
  • func (s *PacketSCTPRelay) Listen()
  • func (s *PacketSCTPRelay) PacketTx()
  • func (s *PacketSCTPRelay) RateLimitTcpServerWrite(ratelimitServerTCPWriteBytePerSecond int, ...)

Types

type BufferedConn

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

func NewBufferedConn

func NewBufferedConn(str io.ReadWriteCloser) *BufferedConn

func (BufferedConn) Close

func (b BufferedConn) Close() error

func (BufferedConn) Read

func (b BufferedConn) Read(p []byte) (n int, err error)

func (BufferedConn) Write

func (b BufferedConn) Write(p []byte) (n int, err error)

type PacketSCTPRelay

type PacketSCTPRelay struct {
	TxChannel     chan interfaces.TrafficWithChannelTag
	TxDataChannel chan interfaces.TrafficWithChannelTag
	RxChannel     chan interfaces.TrafficWithChannelTag

	Password []byte
	// contains filtered or unexported fields
}

func NewPacketRelayClient

func NewPacketRelayClient(conn net.Conn,
	TxChannel chan interfaces.TrafficWithChannelTag,
	TxDataChannel chan interfaces.TrafficWithChannelTag,
	RxChannel chan interfaces.TrafficWithChannelTag,
	Password []byte,
	ctx context.Context) *PacketSCTPRelay

func NewPacketRelayServer

func NewPacketRelayServer(conn net.Conn,
	TxChannel chan interfaces.TrafficWithChannelTag,
	TxDataChannel chan interfaces.TrafficWithChannelTag,
	RxChannel chan interfaces.TrafficWithChannelTag,
	streamrelay interfaces.StreamRelayer,
	Password []byte,
	ctx context.Context) *PacketSCTPRelay

func (*PacketSCTPRelay) ClientOpen

func (s *PacketSCTPRelay) ClientOpen()

func (*PacketSCTPRelay) ClientOpenStream

func (s *PacketSCTPRelay) ClientOpenStream() io.ReadWriteCloser

func (*PacketSCTPRelay) CtlConn

func (s *PacketSCTPRelay) CtlConn(str *sctp.Stream)

func (*PacketSCTPRelay) GetTransmitLayerSentRecvStats

func (s *PacketSCTPRelay) GetTransmitLayerSentRecvStats() (uint64, uint64)

func (*PacketSCTPRelay) Listen

func (s *PacketSCTPRelay) Listen()

func (*PacketSCTPRelay) PacketTx

func (s *PacketSCTPRelay) PacketTx()

func (*PacketSCTPRelay) RateLimitTcpServerWrite

func (s *PacketSCTPRelay) RateLimitTcpServerWrite(ratelimitServerTCPWriteBytePerSecond int,
	ratelimitServerTCPWriteMaxBucketSize int,
	ratelimitServerTCPWriteInitialSize int)