forwarder

type BaseProxy struct {
	// TCPUDPProxyCommonConf 包含TCP和UDP代理共用的配置
	TCPUDPProxyCommonConf

	// RelayRuleOptions 字段
	RelayRuleOptions RelayRuleOptions
	// contains filtered or unexported fields
}

type BaseProxyConf struct {
	// 流量统计
	TrafficIn  int64 // 入站总流量计数器
	TrafficOut int64 // 出站总流量计数器

	ProxyType string // 代理类型 (tcp/tcp4/tcp6/udp/udp4/udp6)
	// contains filtered or unexported fields
}

type CreateProxyOptions struct {
	ProxyType         string           // 代理类型
	ListenIP          string           // 监听IP
	ListenPort        int              // 监听端口
	TargetAddressList []string         // 目标地址列表
	RelayOptions      RelayRuleOptions // 转发规则选项
}

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

type Logger interface {
	Debugf(format string, args ...any)
	Infof(format string, args ...any)
	Warnf(format string, args ...any)
	Errorf(format string, args ...any)
}

type Manager interface {
	// 代理管理方法
	AddProxy(proxy Proxy)
	RemoveProxy(id int, proxyType string)
	GetProxy(id int, proxyType string) (Proxy, bool)
	GetAllProxiesList() map[int]ProxyInfo

	// TCP代理相关方法
	GetTCPProxy(id int) (*TCPProxy, bool)
	GetAllTCPProxies() map[int]*TCPProxy
	RemoveTCPProxy(id int)

	// UDP代理相关方法
	GetUDPProxy(id int) (*UDPProxy, bool)
	GetAllUDPProxies() map[int]*UDPProxy
	RemoveUDPProxy(id int)

	// 网络连接方法
	GetTCPListener(addr string) (net.Listener, error)
	GetUDPConn(addr string) (net.PacketConn, error)

	// CreateProxy 创建新的代理实例
	CreateProxy(opts CreateProxyOptions) (Proxy, error)
}

type ManagerOptions func(*_MrgConfig)

type Proxy interface {
	// 基本控制方法
	Start() error    // 启动代理
	Stop() error     // 停止代理
	Restart() error  // 重启代理
	IsRunning() bool // 检查代理是否正在运行

	// 流量统计相关方法
	ReceiveDataCallback(int64)  // 接收数据时的回调函数
	SendDataCallback(int64)     // 发送数据时的回调函数
	GetTrafficIn() int64        // 获取入站总流量
	GetTrafficOut() int64       // 获取出站总流量
	GetTrafficInRate() float64  // 获取入站流量速率
	GetTrafficOutRate() float64 // 获取出站流量速率

	// 状态查询方法
	GetTargetAddress() string     // 获取目标地址
	GetType() string              // 获取代理类型
	GetStatus() (ok bool)         // 获取代理状态
	GetCurrentConnections() int64 // 获取当前连接数

	// 配置相关方法
	GetListenIP() string          // 获取监听IP
	GetListenPort() int           // 获取监听端口
	GetKey() string               // 获取代理唯一标识
	GetID() int                   // 获取代理ID
	GetDescription() string       // 获取代理描述
	GetLastUpdateTime() time.Time // 获取代理最后更新时间

	// 安全相关方法
	SafeCheck(ip string) bool               // IP安全检查
	SetRateLimit(inLimit, outLimit float64) // 设置流量限制
	GetRateLimit() (float64, float64)       // 获取流量限制

	String() string // 获取代理的字符串表示
}

type ProxyInfo struct {
	ID          int        `json:"proxyId" toml:"proxyId"`
	Type        string     `json:"proxyType" toml:"proxyType"`
	ListenAddr  string     `json:"listenAddr" toml:"listenAddr"`
	RemoteAddr  string     `json:"remoteAddr" toml:"remoteAddr"`
	Status      bool       `json:"proxyStatus" toml:"proxyStatus"`
	RateIn      float64    `json:"rateIn" toml:"rateIn"`
	RateOut     float64    `json:"rateOut" toml:"rateOut"`
	TrafficIn   int64      `json:"trafficIn" toml:"trafficIn"`
	TrafficOut  int64      `json:"trafficOut" toml:"trafficOut"`
	RateLimit   _RateLimit `json:"rateLimit" toml:"rateLimit"`
	UpdateTime  time.Time  `json:"updateTime" toml:"updateTime"`
	Description string     `json:"description" toml:"description"`
	Connections int64      `json:"connections" toml:"connections"`
}

type RelayRuleOptions struct {
	// UDPPackageSize UDP包大小，用于设置缓冲区大小
	UDPPackageSize int `json:"UDPPackageSize,omitempty"`

	// SingleProxyMaxTCPConnections 单个TCP代理允许的最大连接数
	SingleProxyMaxTCPConnections int64 `json:"SingleProxyMaxTCPConnections,omitempty"`

	// SingleProxyMaxUDPReadTargetDataRoutineCount 单个UDP代理允许的最大目标数据读取协程数
	SingleProxyMaxUDPReadTargetDataRoutineCount int64 `json:"SingleProxyMaxUDPReadTargetDataRoutineCount"`

	// UDPProxyPerformanceMode UDP代理性能模式开关，启用时会优化性能
	UDPProxyPerformanceMode bool `json:"UDPProxyPerformanceMode,omitempty"`

	// UDPShortMode UDP短连接模式开关，启用时会优化短连接场景
	UDPShortMode bool `json:"UDPShortMode,omitempty"`

	// SafeMode 安全模式设置，用于控制访问限制
	SafeMode string `json:"SafeMode,omitempty"`

	// InRateLimit 入站流量限制（单位：KB/s）
	InRateLimit float64 `json:"InRateLimit,omitempty"`

	// OutRateLimit 出站流量限制（单位：KB/s）
	OutRateLimit float64 `json:"OutRateLimit,omitempty"`

	// UDPBufferSize UDP缓冲区大小
	UDPBufferSize int `json:"UDPBufferSize,omitempty"`

	// UDPQueueSize UDP队列大小
	UDPQueueSize int `json:"UDPQueueSize,omitempty"`

	Description string `json:"Description,omitempty"`
}

type SafeCheck func(mode, ip string) (allowed bool)

type TCPProxy struct {
	BaseProxy
	// contains filtered or unexported fields
}

type TCPUDPProxyCommonConf struct {
	CurrentConnectionsCount   int64
	SingleProxyMaxConnections int64

	BaseProxyConf
	// contains filtered or unexported fields
}

type UDPProxy struct {
	BaseProxy

	Upm       bool
	ShortMode bool

	SingleProxyMaxUDPReadTargetDatagoroutineCount int64
	// contains filtered or unexported fields
}