create

Documentation

Index

• func NewHandler(config *HandlerConfig) (i.Outbound, error)
• func NewInbound(config *configs.ProxyInboundConfig, ha i.Handler, tp i.TimeoutSetting) (proxy.Inbound, error)
• func NewOutHandler(config *Config) (i.Outbound, error)
• func NewPolicy(config *configs.PolicyConfig) *policy.Policy
• func ShadowsocksAccountToMemoryAccount(account *proxyconfigs.ShadowsocksAccount) (*shadowsocks.MemoryAccount, error)
• func SocketConfigToMemoryConfig(config *configs.SocketConfig, readCounter, writeCounter *atomic.Uint64) *dlhelper.SocketSetting
• func TransportConfigToMemoryConfig(config *configs.TransportConfig, readCounter, writeCounter *atomic.Uint64, ...) *transport.Config
• func TransportProtocolConfig(tc *configs.TransportConfig) interface{}
• func TransportSecurityConfig(config interface{}) interface{}
• func UserConfigToUser(config *configs.UserConfig) (*user.User, error)
• type ChainHandler
  • func NewChainHandler(config *ChainHandlerConfig) (*ChainHandler, error)
  • func (c *ChainHandler) HandleFlow(ctx context.Context, dst net.Destination, rw buf.ReaderWriter) error
  • func (c *ChainHandler) HandlePacketConn(ctx context.Context, dst net.Destination, p udp.PacketReaderWriter) error
  • func (c *ChainHandler) Tag() string
• type ChainHandlerConfig
• type Config
• type HandlerConfig

Functions

func NewHandler

func NewHandler(config *HandlerConfig) (i.Outbound, error)

func NewInbound

func NewInbound(config *configs.ProxyInboundConfig, ha i.Handler, tp i.TimeoutSetting) (proxy.Inbound, error)

func NewOutHandler

func NewOutHandler(config *Config) (i.Outbound, error)

TODO: Validate config

func NewPolicy

func NewPolicy(config *configs.PolicyConfig) *policy.Policy

func ShadowsocksAccountToMemoryAccount

func ShadowsocksAccountToMemoryAccount(account *proxyconfigs.ShadowsocksAccount) (*shadowsocks.MemoryAccount, error)

func SocketConfigToMemoryConfig

func SocketConfigToMemoryConfig(config *configs.SocketConfig, readCounter, writeCounter *atomic.Uint64) *dlhelper.SocketSetting

func TransportConfigToMemoryConfig

func TransportConfigToMemoryConfig(config *configs.TransportConfig,
	readCounter, writeCounter *atomic.Uint64, dnsServer i.ECHResolver) *transport.Config

func TransportProtocolConfig

func TransportProtocolConfig(tc *configs.TransportConfig) interface{}

func TransportSecurityConfig

func TransportSecurityConfig(config interface{}) interface{}

func UserConfigToUser

func UserConfigToUser(config *configs.UserConfig) (*user.User, error)

Types

type ChainHandler

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

func NewChainHandler

func NewChainHandler(config *ChainHandlerConfig) (*ChainHandler, error)

func (*ChainHandler) HandleFlow

func (c *ChainHandler) HandleFlow(ctx context.Context, dst net.Destination, rw buf.ReaderWriter) error

func (*ChainHandler) HandlePacketConn

func (c *ChainHandler) HandlePacketConn(ctx context.Context, dst net.Destination, p udp.PacketReaderWriter) error

func (*ChainHandler) Tag

func (c *ChainHandler) Tag() string

type ChainHandlerConfig

type ChainHandlerConfig struct {
	*configs.ChainHandlerConfig
	Policy                      *policy.Policy
	IPResolver                  i.IPResolver
	DF                          transport.DialerFactory
	IPResolverForRequestAddress i.IPResolver
	// used to lookup ech config
	EchResolver i.ECHResolver
	RejectQuic  bool
}

type Config

type Config struct {
	*configs.OutboundHandlerConfig
	DialerFactory transport.DialerFactory
	Policy        i.TimeoutSetting
	// some outbound require it to lookup server addresses
	IPResolver  i.IPResolver
	ECHResolver i.ECHResolver
	// some outbounds need it to lookup ips of request addresses
	IPResolverForRequestAddress i.IPResolver
	RejectQuic                  bool
}

type HandlerConfig

type HandlerConfig struct {
	*configs.HandlerConfig
	DialerFactory transport.DialerFactory
	Policy        *policy.Policy
	// for node domain
	IPResolver                  i.IPResolver
	EchResolver                 i.ECHResolver
	IPResolverForRequestAddress i.IPResolver
	RejectQuic                  bool
}