vmess

Documentation

Index

• func LocalizePassages(passages []server.Passage) (psgs []Passage, manager *Passage)
• func New(valueCtx context.Context, dialer netproxy.Dialer) (server.Server, error)
• func NewJohn(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, ...) (server.Server, error)
• func NewJohnTCP(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, ...) (server.Server, error)
• func NewJohnTlsGrpc(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, ...) (server.Server, error)
• type Passage
• type Server
  • func (s *Server) AddPassages(passages []server.Passage) (err error)
  • func (s *Server) Close() error
  • func (s *Server) ContentionCheck(thisIP net.IP, passage *Passage) (err error)
  • func (s *Server) GetUserContextOrInsert(userIP string) *UserContext
  • func (s *Server) Listen(addr string) (err error)
  • func (s *Server) Passages() (passages []server.Passage)
  • func (s *Server) RemovePassages(passages []server.Passage, alsoManager bool) (err error)
  • func (s *Server) SyncPassages(passages []server.Passage) (err error)
• type UserContext
  • func NewUserContext(passages []Passage) *UserContext
  • func (ctx *UserContext) Auth(probe func(*Passage) ([]byte, bool)) (hit *Passage, content []byte)
  • func (ctx *UserContext) Close() error
  • func (ctx *UserContext) Infra() *lrulist.LruList
• type UserContextPool
  • func (pool *UserContextPool) Infra() *lru.LRU

Functions

func LocalizePassages

func LocalizePassages(passages []server.Passage) (psgs []Passage, manager *Passage)

func New

func New(valueCtx context.Context, dialer netproxy.Dialer) (server.Server, error)

func NewJohn

func NewJohn(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, arg server.Argument, protocol protocol.Protocol) (server.Server, error)

func NewJohnTCP

func NewJohnTCP(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, arg server.Argument) (server.Server, error)

func NewJohnTlsGrpc

func NewJohnTlsGrpc(valueCtx context.Context, dialer netproxy.Dialer, sweetLisaHost config.Lisa, arg server.Argument) (server.Server, error)

Types

type Passage

type Passage struct {
	server.Passage
	// contains filtered or unexported fields
}

type Server

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

func (*Server) AddPassages

func (s *Server) AddPassages(passages []server.Passage) (err error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) ContentionCheck

func (s *Server) ContentionCheck(thisIP net.IP, passage *Passage) (err error)

func (*Server) GetUserContextOrInsert

func (s *Server) GetUserContextOrInsert(userIP string) *UserContext

func (*Server) Listen

func (s *Server) Listen(addr string) (err error)

func (*Server) Passages

func (s *Server) Passages() (passages []server.Passage)

func (*Server) RemovePassages

func (s *Server) RemovePassages(passages []server.Passage, alsoManager bool) (err error)

func (*Server) SyncPassages

func (s *Server) SyncPassages(passages []server.Passage) (err error)

type UserContext

type UserContext lrulist.LruList

UserContext is the context of a user which indicates the preferred servers

func NewUserContext

func NewUserContext(passages []Passage) *UserContext

func (*UserContext) Auth

func (ctx *UserContext) Auth(probe func(*Passage) ([]byte, bool)) (hit *Passage, content []byte)

func (*UserContext) Close

func (ctx *UserContext) Close() error

func (*UserContext) Infra

func (ctx *UserContext) Infra() *lrulist.LruList

type UserContextPool

type UserContextPool lru.LRU

UserContextPool is a pool which saves the UserContext and eliminates unused UserContext over time

func (*UserContextPool) Infra

func (pool *UserContextPool) Infra() *lru.LRU