proxyman

package
v2.15.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2017 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Package proxyman defines applications for manageing inbound and outbound proxies.

Index

Constants

This section is empty.

Variables

View Source 
var AllocationStrategy_Type_name = map[int32]string{
	0: "Always",
	1: "Random",
	2: "External",
}
View Source 
var AllocationStrategy_Type_value = map[string]int32{
	"Always":   0,
	"Random":   1,
	"External": 2,
}

Functions

This section is empty.

Types

type AllocationStrategy 

type AllocationStrategy struct {
	Type AllocationStrategy_Type `protobuf:"varint,1,opt,name=type,enum=v2ray.core.app.proxyman.AllocationStrategy_Type" json:"type,omitempty"`
	// Number of handlers (ports) running in parallel.
	// Default value is 3 if unset.
	Concurrency *AllocationStrategy_AllocationStrategyConcurrency `protobuf:"bytes,2,opt,name=concurrency" json:"concurrency,omitempty"`
	// Number of minutes before a handler is regenerated.
	// Default value is 5 if unset.
	Refresh *AllocationStrategy_AllocationStrategyRefresh `protobuf:"bytes,3,opt,name=refresh" json:"refresh,omitempty"`
}

func (*AllocationStrategy) Descriptor 

func (*AllocationStrategy) Descriptor() ([]byte, []int)

func (*AllocationStrategy) GetConcurrency 

func (m *AllocationStrategy) GetConcurrency() *AllocationStrategy_AllocationStrategyConcurrency

func (*AllocationStrategy) GetConcurrencyValue 

func (s *AllocationStrategy) GetConcurrencyValue() uint32

func (*AllocationStrategy) GetRefresh 

func (m *AllocationStrategy) GetRefresh() *AllocationStrategy_AllocationStrategyRefresh

func (*AllocationStrategy) GetRefreshValue 

func (s *AllocationStrategy) GetRefreshValue() uint32

func (*AllocationStrategy) GetType 

func (m *AllocationStrategy) GetType() AllocationStrategy_Type

func (*AllocationStrategy) ProtoMessage 

func (*AllocationStrategy) ProtoMessage()

func (*AllocationStrategy) Reset 

func (m *AllocationStrategy) Reset()

func (*AllocationStrategy) String 

func (m *AllocationStrategy) String() string

type AllocationStrategy_AllocationStrategyConcurrency 

type AllocationStrategy_AllocationStrategyConcurrency struct {
	Value uint32 `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
}

func (*AllocationStrategy_AllocationStrategyConcurrency) Descriptor 

func (*AllocationStrategy_AllocationStrategyConcurrency) Descriptor() ([]byte, []int)

func (*AllocationStrategy_AllocationStrategyConcurrency) GetValue 

func (m *AllocationStrategy_AllocationStrategyConcurrency) GetValue() uint32

func (*AllocationStrategy_AllocationStrategyConcurrency) ProtoMessage 

func (*AllocationStrategy_AllocationStrategyConcurrency) ProtoMessage()

func (*AllocationStrategy_AllocationStrategyConcurrency) Reset 

func (m *AllocationStrategy_AllocationStrategyConcurrency) Reset()

func (*AllocationStrategy_AllocationStrategyConcurrency) String 

func (m *AllocationStrategy_AllocationStrategyConcurrency) String() string

type AllocationStrategy_AllocationStrategyRefresh 

type AllocationStrategy_AllocationStrategyRefresh struct {
	Value uint32 `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
}

func (*AllocationStrategy_AllocationStrategyRefresh) Descriptor 

func (*AllocationStrategy_AllocationStrategyRefresh) Descriptor() ([]byte, []int)

func (*AllocationStrategy_AllocationStrategyRefresh) GetValue 

func (m *AllocationStrategy_AllocationStrategyRefresh) GetValue() uint32

func (*AllocationStrategy_AllocationStrategyRefresh) ProtoMessage 

func (*AllocationStrategy_AllocationStrategyRefresh) ProtoMessage()

func (*AllocationStrategy_AllocationStrategyRefresh) Reset 

func (m *AllocationStrategy_AllocationStrategyRefresh) Reset()

func (*AllocationStrategy_AllocationStrategyRefresh) String 

func (m *AllocationStrategy_AllocationStrategyRefresh) String() string

type AllocationStrategy_Type 

type AllocationStrategy_Type int32
const (
	// Always allocate all connection handlers.
	AllocationStrategy_Always AllocationStrategy_Type = 0
	// Randomly allocate specific range of handlers.
	AllocationStrategy_Random AllocationStrategy_Type = 1
	// External. Not supported yet.
	AllocationStrategy_External AllocationStrategy_Type = 2
)

func (AllocationStrategy_Type) EnumDescriptor 

func (AllocationStrategy_Type) EnumDescriptor() ([]byte, []int)

func (AllocationStrategy_Type) String 

func (x AllocationStrategy_Type) String() string

type DatagramReceiverConfig 

type DatagramReceiverConfig struct {
	PortRange          *v2ray_core_common_net1.PortRange `protobuf:"bytes,1,opt,name=port_range,json=portRange" json:"port_range,omitempty"`
	Listen             *v2ray_core_common_net.IPOrDomain `protobuf:"bytes,2,opt,name=listen" json:"listen,omitempty"`
	AllocationStrategy *AllocationStrategy               `protobuf:"bytes,3,opt,name=allocation_strategy,json=allocationStrategy" json:"allocation_strategy,omitempty"`
}

func (*DatagramReceiverConfig) Descriptor 

func (*DatagramReceiverConfig) Descriptor() ([]byte, []int)

func (*DatagramReceiverConfig) GetAllocationStrategy 

func (m *DatagramReceiverConfig) GetAllocationStrategy() *AllocationStrategy

func (*DatagramReceiverConfig) GetListen 

func (m *DatagramReceiverConfig) GetListen() *v2ray_core_common_net.IPOrDomain

func (*DatagramReceiverConfig) GetPortRange 

func (m *DatagramReceiverConfig) GetPortRange() *v2ray_core_common_net1.PortRange

func (*DatagramReceiverConfig) ProtoMessage 

func (*DatagramReceiverConfig) ProtoMessage()

func (*DatagramReceiverConfig) Reset 

func (m *DatagramReceiverConfig) Reset()

func (*DatagramReceiverConfig) String 

func (m *DatagramReceiverConfig) String() string

type DatagramSenderConfig 

type DatagramSenderConfig struct {
	// Send traffic through the given IP. Only IP is allowed.
	Via           *v2ray_core_common_net.IPOrDomain          `protobuf:"bytes,1,opt,name=via" json:"via,omitempty"`
	ProxySettings *v2ray_core_transport_internet.ProxyConfig `protobuf:"bytes,2,opt,name=proxy_settings,json=proxySettings" json:"proxy_settings,omitempty"`
}

func (*DatagramSenderConfig) Descriptor 

func (*DatagramSenderConfig) Descriptor() ([]byte, []int)

func (*DatagramSenderConfig) GetProxySettings 

func (m *DatagramSenderConfig) GetProxySettings() *v2ray_core_transport_internet.ProxyConfig

func (*DatagramSenderConfig) GetVia 

func (m *DatagramSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain

func (*DatagramSenderConfig) ProtoMessage 

func (*DatagramSenderConfig) ProtoMessage()

func (*DatagramSenderConfig) Reset 

func (m *DatagramSenderConfig) Reset()

func (*DatagramSenderConfig) String 

func (m *DatagramSenderConfig) String() string

type InboundConfig 

type InboundConfig struct {
}

func (*InboundConfig) Descriptor 

func (*InboundConfig) Descriptor() ([]byte, []int)

func (*InboundConfig) ProtoMessage 

func (*InboundConfig) ProtoMessage()

func (*InboundConfig) Reset 

func (m *InboundConfig) Reset()

func (*InboundConfig) String 

func (m *InboundConfig) String() string

type InboundHandler 

type InboundHandler interface {
}

type InboundHandlerConfig 

type InboundHandlerConfig struct {
	Tag              string                                   `protobuf:"bytes,1,opt,name=tag" json:"tag,omitempty"`
	ReceiverSettings []*v2ray_core_common_serial.TypedMessage `protobuf:"bytes,2,rep,name=receiver_settings,json=receiverSettings" json:"receiver_settings,omitempty"`
	ProxySettings    *v2ray_core_common_serial.TypedMessage   `protobuf:"bytes,3,opt,name=proxy_settings,json=proxySettings" json:"proxy_settings,omitempty"`
}

func (*InboundHandlerConfig) Descriptor 

func (*InboundHandlerConfig) Descriptor() ([]byte, []int)

func (*InboundHandlerConfig) GetProxySettings 

func (m *InboundHandlerConfig) GetProxySettings() *v2ray_core_common_serial.TypedMessage

func (*InboundHandlerConfig) GetReceiverSettings 

func (m *InboundHandlerConfig) GetReceiverSettings() []*v2ray_core_common_serial.TypedMessage

func (*InboundHandlerConfig) GetTag 

func (m *InboundHandlerConfig) GetTag() string

func (*InboundHandlerConfig) ProtoMessage 

func (*InboundHandlerConfig) ProtoMessage()

func (*InboundHandlerConfig) Reset 

func (m *InboundHandlerConfig) Reset()

func (*InboundHandlerConfig) String 

func (m *InboundHandlerConfig) String() string

type InboundHandlerManager 

type InboundHandlerManager interface {
	GetHandler(tag string) (proxy.InboundHandler, int)
}

func InboundHandlerManagerFromSpace 

func InboundHandlerManagerFromSpace(space app.Space) InboundHandlerManager

type OutboundConfig 

type OutboundConfig struct {
}

func (*OutboundConfig) Descriptor 

func (*OutboundConfig) Descriptor() ([]byte, []int)

func (*OutboundConfig) ProtoMessage 

func (*OutboundConfig) ProtoMessage()

func (*OutboundConfig) Reset 

func (m *OutboundConfig) Reset()

func (*OutboundConfig) String 

func (m *OutboundConfig) String() string

type OutboundHandler 

type OutboundHandler interface {
	Dispatch(ctx context.Context, destination net.Destination, outboundRay ray.OutboundRay)
}

type OutboundHandlerConfig 

type OutboundHandlerConfig struct {
	Tag            string                                   `protobuf:"bytes,1,opt,name=tag" json:"tag,omitempty"`
	SenderSettings []*v2ray_core_common_serial.TypedMessage `protobuf:"bytes,2,rep,name=sender_settings,json=senderSettings" json:"sender_settings,omitempty"`
	ProxySettings  *v2ray_core_common_serial.TypedMessage   `protobuf:"bytes,3,opt,name=proxy_settings,json=proxySettings" json:"proxy_settings,omitempty"`
}

func (*OutboundHandlerConfig) Descriptor 

func (*OutboundHandlerConfig) Descriptor() ([]byte, []int)

func (*OutboundHandlerConfig) GetProxyHandler 

func (c *OutboundHandlerConfig) GetProxyHandler(ctx context.Context) (proxy.OutboundHandler, error)

func (*OutboundHandlerConfig) GetProxySettings 

func (m *OutboundHandlerConfig) GetProxySettings() *v2ray_core_common_serial.TypedMessage

func (*OutboundHandlerConfig) GetSenderSettings 

func (m *OutboundHandlerConfig) GetSenderSettings() []*v2ray_core_common_serial.TypedMessage

func (*OutboundHandlerConfig) GetTag 

func (m *OutboundHandlerConfig) GetTag() string

func (*OutboundHandlerConfig) ProtoMessage 

func (*OutboundHandlerConfig) ProtoMessage()

func (*OutboundHandlerConfig) Reset 

func (m *OutboundHandlerConfig) Reset()

func (*OutboundHandlerConfig) String 

func (m *OutboundHandlerConfig) String() string

type OutboundHandlerManager 

type OutboundHandlerManager interface {
	GetHandler(tag string) proxy.OutboundHandler
	GetDefaultHandler() proxy.OutboundHandler
	SetDefaultHandler(handler proxy.OutboundHandler) error
	SetHandler(tag string, handler proxy.OutboundHandler) error
}

func OutboundHandlerManagerFromSpace 

func OutboundHandlerManagerFromSpace(space app.Space) OutboundHandlerManager

type StreamReceiverConfig 

type StreamReceiverConfig struct {
	PortRange          *v2ray_core_common_net1.PortRange           `protobuf:"bytes,1,opt,name=port_range,json=portRange" json:"port_range,omitempty"`
	Listen             *v2ray_core_common_net.IPOrDomain           `protobuf:"bytes,2,opt,name=listen" json:"listen,omitempty"`
	AllocationStrategy *AllocationStrategy                         `protobuf:"bytes,3,opt,name=allocation_strategy,json=allocationStrategy" json:"allocation_strategy,omitempty"`
	StreamSettings     *v2ray_core_transport_internet.StreamConfig `protobuf:"bytes,4,opt,name=stream_settings,json=streamSettings" json:"stream_settings,omitempty"`
}

func (*StreamReceiverConfig) Descriptor 

func (*StreamReceiverConfig) Descriptor() ([]byte, []int)

func (*StreamReceiverConfig) GetAllocationStrategy 

func (m *StreamReceiverConfig) GetAllocationStrategy() *AllocationStrategy

func (*StreamReceiverConfig) GetListen 

func (m *StreamReceiverConfig) GetListen() *v2ray_core_common_net.IPOrDomain

func (*StreamReceiverConfig) GetPortRange 

func (m *StreamReceiverConfig) GetPortRange() *v2ray_core_common_net1.PortRange

func (*StreamReceiverConfig) GetStreamSettings 

func (m *StreamReceiverConfig) GetStreamSettings() *v2ray_core_transport_internet.StreamConfig

func (*StreamReceiverConfig) ProtoMessage 

func (*StreamReceiverConfig) ProtoMessage()

func (*StreamReceiverConfig) Reset 

func (m *StreamReceiverConfig) Reset()

func (*StreamReceiverConfig) String 

func (m *StreamReceiverConfig) String() string

type StreamSenderConfig 

type StreamSenderConfig struct {
	// Send traffic through the given IP. Only IP is allowed.
	Via            *v2ray_core_common_net.IPOrDomain           `protobuf:"bytes,1,opt,name=via" json:"via,omitempty"`
	StreamSettings *v2ray_core_transport_internet.StreamConfig `protobuf:"bytes,2,opt,name=stream_settings,json=streamSettings" json:"stream_settings,omitempty"`
	ProxySettings  *v2ray_core_transport_internet.ProxyConfig  `protobuf:"bytes,3,opt,name=proxy_settings,json=proxySettings" json:"proxy_settings,omitempty"`
}

func (*StreamSenderConfig) Descriptor 

func (*StreamSenderConfig) Descriptor() ([]byte, []int)

func (*StreamSenderConfig) GetProxySettings 

func (m *StreamSenderConfig) GetProxySettings() *v2ray_core_transport_internet.ProxyConfig

func (*StreamSenderConfig) GetStreamSettings 

func (m *StreamSenderConfig) GetStreamSettings() *v2ray_core_transport_internet.StreamConfig

func (*StreamSenderConfig) GetVia 

func (m *StreamSenderConfig) GetVia() *v2ray_core_common_net.IPOrDomain

func (*StreamSenderConfig) ProtoMessage 

func (*StreamSenderConfig) ProtoMessage()

func (*StreamSenderConfig) Reset 

func (m *StreamSenderConfig) Reset()

func (*StreamSenderConfig) String 

func (m *StreamSenderConfig) String() string

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.