protocol

package

v0.3.2 Latest Latest Go to latest Published: Apr 24, 2020 License: GPL-3.0 Imports: 8 Imported by: 0

Details

View Source

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

This section is empty.

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 byte

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

type ConnSession interface {
	io.ReadWriteCloser
}

type HasHash interface {
	GetHash() string
}

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

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

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

type NeedRespond interface {
	Respond() error
}

type PacketReadWriter interface {
	PacketReader
	PacketWriter
}

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

type PacketSession interface {
	PacketReadWriter
	io.Closer
}

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

type Request struct {
	net.Addr

	*common.Address
	Command Command
}

func (r *Request) Network() string

func (r *Request) String() string