controller

package

v1.9.2 Latest Latest Go to latest Published: May 13, 2023 License: MPL-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/AikoXrayR-Project/XrayR

Links

Open Source Insights

Documentation ¶

Overview ¶

Package controller Package generate the InboundConfig used by add inbound

Index ¶

Variables
func InboundBuilder(config *Config, nodeInfo *api.NodeInfo, tag string) (*core.InboundHandlerConfig, error)
func OutboundBuilder(config *Config, nodeInfo *api.NodeInfo, tag string) (*core.OutboundHandlerConfig, error)
type AutoSpeedLimitConfig
type Config
type Controller
- func New(server *core.Instance, api api.API, config *Config, panelType string) *Controller
type FallBackConfig
type LimitInfo
type REALITYConfig

Constants ¶

This section is empty.

Variables ¶

View Source

var AEADMethod = map[shadowsocks.CipherType]uint8{
	shadowsocks.CipherType_AES_128_GCM:        0,
	shadowsocks.CipherType_AES_256_GCM:        0,
	shadowsocks.CipherType_CHACHA20_POLY1305:  0,
	shadowsocks.CipherType_XCHACHA20_POLY1305: 0,
}

Functions ¶

func InboundBuilder ¶

func InboundBuilder(config *Config, nodeInfo *api.NodeInfo, tag string) (*core.InboundHandlerConfig, error)

InboundBuilder build Inbound config for different protocol

func OutboundBuilder ¶

func OutboundBuilder(config *Config, nodeInfo *api.NodeInfo, tag string) (*core.OutboundHandlerConfig, error)

OutboundBuilder build freedom outbound config for addOutbound

Types ¶

type AutoSpeedLimitConfig ¶ added in v1.7.5

type AutoSpeedLimitConfig struct {
	Limit         int `mapstructure:"Limit"` // mbps
	WarnTimes     int `mapstructure:"WarnTimes"`
	LimitSpeed    int `mapstructure:"LimitSpeed"`    // mbps
	LimitDuration int `mapstructure:"LimitDuration"` // minute
}

type Config ¶

type Config struct {
	ListenIP             string                    `mapstructure:"ListenIP"`
	SendIP               string                    `mapstructure:"SendIP"`
	UpdatePeriodic       int                       `mapstructure:"UpdatePeriodic"`
	CertConfig           *mylego.CertConfig        `mapstructure:"CertConfig"`
	EnableDNS            bool                      `mapstructure:"EnableDNS"`
	DNSType              string                    `mapstructure:"DNSType"`
	DisableUploadTraffic bool                      `mapstructure:"DisableUploadTraffic"`
	DisableGetRule       bool                      `mapstructure:"DisableGetRule"`
	EnableProxyProtocol  bool                      `mapstructure:"EnableProxyProtocol"`
	EnableFallback       bool                      `mapstructure:"EnableFallback"`
	DisableIVCheck       bool                      `mapstructure:"DisableIVCheck"`
	DisableSniffing      bool                      `mapstructure:"DisableSniffing"`
	AutoSpeedLimitConfig *AutoSpeedLimitConfig     `mapstructure:"AutoSpeedLimitConfig"`
	RedisLimitConfig     *limiter.RedisLimitConfig `mapstructure:"RedisLimitConfig"`
	FallBackConfigs      []*FallBackConfig         `mapstructure:"FallBackConfigs"`
	EnableREALITY        bool                      `mapstructure:"EnableREALITY"`
	REALITYConfigs       *REALITYConfig            `mapstructure:"REALITYConfigs"`
}

type Controller ¶

type Controller struct {
	Tag string
	// contains filtered or unexported fields
}

func New ¶

func New(server *core.Instance, api api.API, config *Config, panelType string) *Controller

New return a Controller service with default parameters.

func (*Controller) AddInboundLimiter ¶

func (c *Controller) AddInboundLimiter(tag string, nodeSpeedLimit uint64, userList *[]api.UserInfo, RedisLimitConfig *limiter.RedisLimitConfig) error

func (*Controller) Close ¶

func (c *Controller) Close() error

Close implement the Close() function of the service interface

func (*Controller) DeleteInboundLimiter ¶

func (c *Controller) DeleteInboundLimiter(tag string) error

func (*Controller) GetDetectResult ¶

func (c *Controller) GetDetectResult(tag string) (*[]api.DetectResult, error)

func (*Controller) GetOnlineDevice ¶

func (c *Controller) GetOnlineDevice(tag string) (*[]api.OnlineUser, error)

func (*Controller) Start ¶

func (c *Controller) Start() error

Start implement the Start() function of the service interface

func (*Controller) UpdateInboundLimiter ¶

func (c *Controller) UpdateInboundLimiter(tag string, updatedUserList *[]api.UserInfo) error

func (*Controller) UpdateRule ¶

func (c *Controller) UpdateRule(tag string, newRuleList []api.DetectRule) error

type FallBackConfig ¶

type FallBackConfig struct {
	SNI              string `mapstructure:"SNI"`
	Alpn             string `mapstructure:"Alpn"`
	Path             string `mapstructure:"Path"`
	Dest             string `mapstructure:"Dest"`
	ProxyProtocolVer uint64 `mapstructure:"ProxyProtocolVer"`
}

type LimitInfo ¶ added in v1.7.5

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

type REALITYConfig ¶ added in v1.9.2

type REALITYConfig struct {
	Show             bool     `mapstructure:"Show"`
	Dest             string   `mapstructure:"Dest"`
	ProxyProtocolVer uint64   `mapstructure:"ProxyProtocolVer"`
	ServerNames      []string `mapstructure:"ServerNames"`
	PrivateKey       string   `mapstructure:"PrivateKey"`
	MinClientVer     string   `mapstructure:"MinClientVer"`
	MaxClientVer     string   `mapstructure:"MaxClientVer"`
	MaxTimeDiff      uint64   `mapstructure:"MaxTimeDiff"`
	ShortIds         []string `mapstructure:"ShortIds"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL