point

Documentation

Overview

Package point is a shell of V2Ray to run on various of systems. Point server is a full functionality proxying system. It consists of an inbound and an outbound connection, as well as any number of inbound and outbound detours. It provides a way internally to route network packets.

Index

• Constants
• Variables
• type Config
  • func LoadConfig(init string) (*Config, error)
• type ConfigLoader
• type ConnectionConfig
• type InboundConnectionHandlerWithPort
• type InboundDetourAllocationConfig
• type InboundDetourConfig
• type InboundDetourHandler
• type InboundDetourHandlerAlways
  • func NewInboundDetourHandlerAlways(space app.Space, config *InboundDetourConfig) (*InboundDetourHandlerAlways, error)
  • func (this *InboundDetourHandlerAlways) Close()
  • func (this *InboundDetourHandlerAlways) GetConnectionHandler() (proxy.InboundHandler, int)
  • func (this *InboundDetourHandlerAlways) Start() error
• type InboundDetourHandlerDynamic
  • func NewInboundDetourHandlerDynamic(space app.Space, config *InboundDetourConfig) (*InboundDetourHandlerDynamic, error)
  • func (this *InboundDetourHandlerDynamic) Close()
  • func (this *InboundDetourHandlerDynamic) GetConnectionHandler() (proxy.InboundHandler, int)
  • func (this *InboundDetourHandlerDynamic) Start() error
• type LogConfig
• type OutboundDetourConfig
• type Point
  • func NewPoint(pConfig *Config) (*Point, error)
  • func (this *Point) Close()
  • func (this *Point) DispatchToOutbound(context app.Context, packet v2net.Packet) ray.InboundRay
  • func (this *Point) FilterPacketAndDispatch(packet v2net.Packet, link ray.OutboundRay, dispatcher proxy.OutboundHandler)
  • func (this *Point) GetHandler(context app.Context, tag string) (proxy.InboundHandler, int)
  • func (this *Point) Start() error

Constants

const (
	AllocationStrategyAlways   = "always"
	AllocationStrategyRandom   = "random"
	AllocationStrategyExternal = "external"
)

Variables

var (
	ErrorBadConfiguration = errors.New("Bad configuration.")
)

Types

type Config

type Config struct {
	Port            v2net.Port
	LogConfig       *LogConfig
	RouterConfig    *router.Config
	InboundConfig   *ConnectionConfig
	OutboundConfig  *ConnectionConfig
	InboundDetours  []*InboundDetourConfig
	OutboundDetours []*OutboundDetourConfig
}

func LoadConfig

func LoadConfig(init string) (*Config, error)

type ConfigLoader

type ConfigLoader func(init string) (*Config, error)

type ConnectionConfig

type ConnectionConfig struct {
	Protocol string
	Settings []byte
}

type InboundConnectionHandlerWithPort

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

type InboundDetourAllocationConfig

type InboundDetourAllocationConfig struct {
	Strategy    string // Allocation strategy of this inbound detour.
	Concurrency int    // Number of handlers (ports) running in parallel.
	Refresh     int    // Number of minutes before a handler is regenerated.
}

type InboundDetourConfig

type InboundDetourConfig struct {
	Protocol   string
	PortRange  v2net.PortRange
	Tag        string
	Allocation *InboundDetourAllocationConfig
	Settings   []byte
}

type InboundDetourHandler

type InboundDetourHandler interface {
	Start() error
	Close()
	GetConnectionHandler() (proxy.InboundHandler, int)
}

type InboundDetourHandlerAlways

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

Handler for inbound detour connections.

func NewInboundDetourHandlerAlways

func NewInboundDetourHandlerAlways(space app.Space, config *InboundDetourConfig) (*InboundDetourHandlerAlways, error)

func (*InboundDetourHandlerAlways) Close

func (this *InboundDetourHandlerAlways) Close()

func (*InboundDetourHandlerAlways) GetConnectionHandler

func (this *InboundDetourHandlerAlways) GetConnectionHandler() (proxy.InboundHandler, int)

func (*InboundDetourHandlerAlways) Start

func (this *InboundDetourHandlerAlways) Start() error

Starts the inbound connection handler.

type InboundDetourHandlerDynamic

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

func NewInboundDetourHandlerDynamic

func NewInboundDetourHandlerDynamic(space app.Space, config *InboundDetourConfig) (*InboundDetourHandlerDynamic, error)

func (*InboundDetourHandlerDynamic) Close

func (this *InboundDetourHandlerDynamic) Close()

func (*InboundDetourHandlerDynamic) GetConnectionHandler

func (this *InboundDetourHandlerDynamic) GetConnectionHandler() (proxy.InboundHandler, int)

func (*InboundDetourHandlerDynamic) Start

func (this *InboundDetourHandlerDynamic) Start() error

type LogConfig

type LogConfig struct {
	AccessLog string
	ErrorLog  string
	LogLevel  log.LogLevel
}

type OutboundDetourConfig

type OutboundDetourConfig struct {
	Protocol string
	Tag      string
	Settings []byte
}

type Point

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

Point shell of V2Ray.

func NewPoint

func NewPoint(pConfig *Config) (*Point, error)

NewPoint returns a new Point server based on given configuration. The server is not started at this point.

func (*Point) Close

func (this *Point) Close()

func (*Point) DispatchToOutbound

func (this *Point) DispatchToOutbound(context app.Context, packet v2net.Packet) ray.InboundRay

Dispatches a Packet to an OutboundConnection. The packet will be passed through the router (if configured), and then sent to an outbound connection with matching tag.

func (*Point) FilterPacketAndDispatch

func (this *Point) FilterPacketAndDispatch(packet v2net.Packet, link ray.OutboundRay, dispatcher proxy.OutboundHandler)

func (*Point) GetHandler

func (this *Point) GetHandler(context app.Context, tag string) (proxy.InboundHandler, int)

func (*Point) Start

func (this *Point) Start() error

Start starts the Point server, and return any error during the process. In the case of any errors, the state of the server is unpredicatable.