protocol

Documentation

Index

• Constants
• func ParseAddress(conn io.Reader, network string) (*common.Address, error)
• func ParsePort(addr net.Addr) (uint16, error)
• func WriteAddress(w io.Writer, request *Request) error
• type Command
• type ConnSession
• type HasHash
• type NeedAuth
• type NeedConfig
• type NeedMeter
• type NeedRespond
• type PacketReadWriter
• type PacketReader
• type PacketSession
• type PacketWriter
• type Request
  • func (r *Request) Network() string
  • func (r *Request) String() string

Constants

const (
	MaxUDPPacketSize = 1024 * 4
	UDPTimeout       = time.Second * 5
	TCPTimeout       = time.Second * 5
)

Functions

func ParseAddress

func ParseAddress(conn io.Reader, network string) (*common.Address, error)

func ParsePort

func ParsePort(addr net.Addr) (uint16, error)

func WriteAddress

func WriteAddress(w io.Writer, request *Request) error

Types

type Command

type Command byte

const (
	Connect   Command = 1
	Bind      Command = 2
	Associate Command = 3
	Mux       Command = 0x7f
)

type ConnSession

type ConnSession interface {
	io.ReadWriteCloser
}

type HasHash

type HasHash interface {
	GetHash() string
}

type NeedAuth

type NeedAuth interface {
	SetAuth(auth stat.Authenticator)
}

type NeedConfig

type NeedConfig interface {
	SetConfig(config *conf.GlobalConfig)
}

type NeedMeter

type NeedMeter interface {
	SetMeter(meter stat.TrafficMeter)
}

type NeedRespond

type NeedRespond interface {
	Respond() error
}

type PacketReadWriter

type PacketReadWriter interface {
	PacketReader
	PacketWriter
}

type PacketReader

type PacketReader interface {
	ReadPacket() (req *Request, payload []byte, err error)
}

type PacketSession

type PacketSession interface {
	PacketReadWriter
	io.Closer
}

type PacketWriter

type PacketWriter interface {
	WritePacket(req *Request, payload []byte) (n int, err error)
}

type Request

type Request struct {
	net.Addr

	*common.Address
	Command Command
}

func (*Request) Network

func (r *Request) Network() string

func (*Request) String

func (r *Request) String() string