transport

Documentation

Index

• Variables
• func AllocateBuffer() []byte
• func DisableIPv6()
• func SetBufferSize(size uint16)
• func SetNetwork(network string)
• type Request
  • func NewRequest(host string, port uint16) *Request
• type Transport

Variables

var (
	ErrPackageLoss     = errors.New("package loss")
	ErrUserNotFound    = errors.New("user not found")
	ErrRequestNotFound = errors.New("request not found")
	ErrTargetACKFailed = errors.New("target ack failed")
	ErrServerFailed    = errors.New("server error")
	ErrBadRequest      = errors.New("bad request")
	ErrBlocked         = errors.New("blocked")
	ErrNotImplemented  = errors.New("not implemented")
)

var BufferSize = 64 * 1024

BufferSize 64K (1K == 1024 Byte)

var DialTimeout = 3 * time.Minute

DialTimeout for transport of direct

var Network = "tcp"

Network is a tcp dial option

Functions

func AllocateBuffer

func AllocateBuffer() []byte

func DisableIPv6

func DisableIPv6()

DisableIPv6 for dial

func SetBufferSize

func SetBufferSize(size uint16)

SetBufferSize in KB

func SetNetwork

func SetNetwork(network string)

SetNetwork to tcp4 or tcp6

Types

type Request

type Request struct {
	Host string
	Port uint16
}

func NewRequest

func NewRequest(host string, port uint16) *Request

type Transport

type Transport interface {
	String() string
	Proxy(ctx context.Context, req *Request, localAddr chan<- string, dst io.Writer, src io.Reader) error
	Dial(network, addr string) (net.Conn, error)
	Close() error
}