controller

package

v1.3.10 Latest Latest Go to latest Published: Aug 19, 2023 License: MPL-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/AikoCute-Offical/AikoR

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 Config
type Controller
- func New(server *core.Instance, api api.API, config *Config, panelType string) *Controller
type DynamicSpeedConfig
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 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"`
	DynamicSpeedConfig   *DynamicSpeedConfig  `mapstructure:"DynamicSpeedConfig"`
	RedisConfig          *limiter.RedisConfig `mapstructure:"RedisConfig"`
	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, RedisConfig *limiter.RedisConfig) 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 DynamicSpeedConfig ¶ added in v1.1.7

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

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 v0.7.0

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

type REALITYConfig ¶ added in v1.3.1

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