protocol

Documentation

Index

• Constants
• func CancelTimeout(conn net.Conn)
• func GetRandomTimeoutDuration() time.Duration
• func SetRandomizedTimeout(conn net.Conn)
• type Command
• type ConnSession
• type HasHash
• type NeedAuth
• type NeedConfig
• type NeedRespond
• type PacketReadWriter
• type PacketReader
• type PacketSession
• type PacketWriter
• type Request
  • func (r *Request) Marshal(rr io.Reader) error
  • func (r *Request) Network() string
  • func (r *Request) String() string
  • func (r *Request) Unmarshal(w io.Writer) error

Constants

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

Functions

func CancelTimeout

func CancelTimeout(conn net.Conn)

func GetRandomTimeoutDuration

func GetRandomTimeoutDuration() time.Duration

func SetRandomizedTimeout

func SetRandomizedTimeout(conn net.Conn)

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 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 {
	Command
	*common.Address
}

func (*Request) Marshal

func (r *Request) Marshal(rr io.Reader) error

func (*Request) Network

func (r *Request) Network() string

func (*Request) String

func (r *Request) String() string

func (*Request) Unmarshal

func (r *Request) Unmarshal(w io.Writer) error