protocol

package
v1.18.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2016 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RequestCommandTCP = RequestCommand(0x01)
	RequestCommandUDP = RequestCommand(0x02)
)
View Source 
const (
	RequestOptionChunkStream     = RequestOption(0x01)
	RequestOptionConnectionReuse = RequestOption(0x02)
)
View Source 
const (
	UserLevelAdmin     = UserLevel(255)
	UserLevelUntrusted = UserLevel(0)
)
View Source 
const (
	IDBytesLen = 16
)

Variables

View Source 
var (
	ErrInvalidUser    = errors.New("Invalid user.")
	ErrInvalidVersion = errors.New("Invalid version.")
)
View Source 
var (
	InvalidID = errors.New("Invalid ID.")
)
View Source 
var (
	ResponseOptionConnectionReuse = ResponseOption(1)
)

Functions

func DefaultIDHash 

func DefaultIDHash(key []byte) hash.Hash

Types

type Account added in v1.11.2 

type Account interface {
}

type CommandSwitchAccount 

type CommandSwitchAccount struct {
	Host     v2net.Address
	Port     v2net.Port
	ID       *uuid.UUID
	AlterIds uint16
	Level    UserLevel
	ValidMin byte
}

type ID 

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

The ID of en entity, in the form of an UUID.

func NewAlterIDs added in v1.12.8 

func NewAlterIDs(primary *ID, alterIDCount uint16) []*ID

func NewID 

func NewID(uuid *uuid.UUID) *ID

func (*ID) Bytes 

func (this *ID) Bytes() []byte

func (ID) CmdKey 

func (v ID) CmdKey() []byte

func (*ID) Equals 

func (this *ID) Equals(another *ID) bool

func (*ID) String 

func (this *ID) String() string

func (*ID) UUID 

func (this *ID) UUID() *uuid.UUID

type IDHash 

type IDHash func(key []byte) hash.Hash

type RequestCommand 

type RequestCommand byte

type RequestDecoder 

type RequestDecoder interface {
	DecodeRequestHeader(io.Reader) (*RequestHeader, error)
	DecodeRequestBody(io.Reader) io.Reader
}

type RequestEncoder 

type RequestEncoder interface {
	EncodeRequestHeader(*RequestHeader, io.Writer)
	EncodeRequestBody(io.Writer) io.Writer
}

type RequestHeader 

type RequestHeader struct {
	Version byte
	User    *User
	Command RequestCommand
	Option  RequestOption
	Address v2net.Address
	Port    v2net.Port
}

func (*RequestHeader) Destination 

func (this *RequestHeader) Destination() v2net.Destination

type RequestOption 

type RequestOption byte

func (*RequestOption) Clear added in v1.17.2 

func (this *RequestOption) Clear(option RequestOption)

func (RequestOption) Has added in v1.17.2 

func (this RequestOption) Has(option RequestOption) bool

func (*RequestOption) Set added in v1.17.2 

func (this *RequestOption) Set(option RequestOption)

type ResponseCommand 

type ResponseCommand interface{}

type ResponseDecoder 

type ResponseDecoder interface {
	DecodeResponseHeader(io.Reader) (*ResponseHeader, error)
	DecodeResponseBody(io.Reader) io.Reader
}

type ResponseEncoder 

type ResponseEncoder interface {
	EncodeResponseHeader(*ResponseHeader, io.Writer)
	EncodeResponseBody(io.Writer) io.Writer
}

type ResponseHeader 

type ResponseHeader struct {
	Option  ResponseOption
	Command ResponseCommand
}

type ResponseOption added in v1.17.2 

type ResponseOption byte

func (*ResponseOption) Clear added in v1.17.2 

func (this *ResponseOption) Clear(option ResponseOption)

func (ResponseOption) Has added in v1.17.2 

func (this ResponseOption) Has(option ResponseOption) bool

func (*ResponseOption) Set added in v1.17.2 

func (this *ResponseOption) Set(option ResponseOption)

type TimedUserValidator 

type TimedUserValidator struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*TimedUserValidator) Add 

func (this *TimedUserValidator) Add(user *User) error

func (*TimedUserValidator) Get 

func (this *TimedUserValidator) Get(userHash []byte) (*User, Timestamp, bool)

func (*TimedUserValidator) Release added in v1.12.1 

func (this *TimedUserValidator) Release()

type Timestamp 

type Timestamp int64

func NowTime 

func NowTime() Timestamp

func (Timestamp) Bytes 

func (this Timestamp) Bytes(b []byte) []byte

type TimestampGenerator 

type TimestampGenerator func() Timestamp

func NewTimestampGenerator 

func NewTimestampGenerator(base Timestamp, delta int) TimestampGenerator

type User 

type User struct {
	Account Account
	Level   UserLevel
	Email   string
}

func NewUser 

func NewUser(account Account, level UserLevel, email string) *User

type UserLevel 

type UserLevel byte

type UserSettings 

type UserSettings struct {
	PayloadReadTimeout int
}

func GetUserSettings 

func GetUserSettings(level UserLevel) UserSettings

type UserValidator 

type UserValidator interface {
	common.Releasable

	Add(user *User) error
	Get(timeHash []byte) (*User, Timestamp, bool)
}

func NewTimedUserValidator 

func NewTimedUserValidator(hasher IDHash) UserValidator

type VMessAccount added in v1.17.2 

type VMessAccount struct {
	ID       *ID
	AlterIDs []*ID
}

func (*VMessAccount) AnyValidID added in v1.17.2 

func (this *VMessAccount) AnyValidID() *ID

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.