xray

Documentation

Index

• Constants
• func AddInboundUser(ctx context.Context, c proxy.HandlerServiceClient, tag string, user *User) error
• func InProxyTags(tag string) bool
• func NewBandwidthRecorder(metricsURL string) *bandwidthRecorder
• func RemoveInboundUser(ctx context.Context, c proxy.HandlerServiceClient, tag string, user *User) error
• type SyncTrafficReq
  • func (s *SyncTrafficReq) GetTotalTraffic() int64
• type SyncUserConfigsResp
• type User
  • func (u *User) Equal(new *User) bool
  • func (u *User) GenTraffic() *UserTraffic
  • func (u *User) GetEmail() string
  • func (u *User) ResetTraffic()
  • func (u *User) ToXrayUser() *protocol.User
  • func (u *User) UpdateFromServer(serverSideUser *User)
• type UserPool
  • func NewUserPool(grpcEndPoint, remoteConfigURL, metricURL string, proxyTags []string) *UserPool
  • func (up *UserPool) CreateUser(userId, level int, password, method, protocol string, enable bool) *User
  • func (up *UserPool) GetAllUsers() []*User
  • func (up *UserPool) GetUser(id int) (*User, bool)
  • func (up *UserPool) RemoveUser(id int)
  • func (up *UserPool) Start(ctx context.Context) error
  • func (up *UserPool) Stop()
• type UserTraffic
• type XrayServer
  • func NewXrayServer(cfg *config.Config) *XrayServer
  • func (xs *XrayServer) Reload() error
  • func (xs *XrayServer) Setup() error
  • func (xs *XrayServer) Start(ctx context.Context) error
  • func (xs *XrayServer) Stop()

Constants

const (
	XrayAPITag         = "api"
	XraySSProxyTag     = "ss_proxy"
	XrayTrojanProxyTag = "trojan_proxy"
	XrayVmessProxyTag  = "vmess_proxy"
	XrayVlessProxyTag  = "vless_proxy"
	XraySSRProxyTag    = "ssr_proxy"

	SyncTime = 60

	ProtocolSS     = "ss"
	ProtocolTrojan = "trojan"
)

Functions

func AddInboundUser

func AddInboundUser(ctx context.Context, c proxy.HandlerServiceClient, tag string, user *User) error

AddInboundUser add user to inbound by tag

func InProxyTags

func InProxyTags(tag string) bool

func NewBandwidthRecorder

func NewBandwidthRecorder(metricsURL string) *bandwidthRecorder

func RemoveInboundUser

func RemoveInboundUser(ctx context.Context, c proxy.HandlerServiceClient, tag string, user *User) error

RemoveInboundUser remove user from inbound by tag

Types

type SyncTrafficReq

type SyncTrafficReq struct {
	Data              []*UserTraffic `json:"data"`
	UploadBandwidth   int64          `json:"upload_bandwidth"`
	DownloadBandwidth int64          `json:"download_bandwidth"`
}

func (*SyncTrafficReq) GetTotalTraffic

func (s *SyncTrafficReq) GetTotalTraffic() int64

type SyncUserConfigsResp

type SyncUserConfigsResp struct {
	Users []*User `json:"users"`
}

type User

type User struct {
	ID       int    `json:"user_id"`
	Method   string `json:"method"`
	Password string `json:"password"`

	Level           int   `json:"level"`
	Enable          bool  `json:"enable"`
	UploadTraffic   int64 `json:"upload_traffic"`
	DownloadTraffic int64 `json:"download_traffic"`

	Protocol string `json:"protocol"`
	// contains filtered or unexported fields
}

func (*User) Equal

func (u *User) Equal(new *User) bool

func (*User) GenTraffic

func (u *User) GenTraffic() *UserTraffic

func (*User) GetEmail

func (u *User) GetEmail() string

NOTE we use user id as email

func (*User) ResetTraffic

func (u *User) ResetTraffic()

func (*User) ToXrayUser

func (u *User) ToXrayUser() *protocol.User

func (*User) UpdateFromServer

func (u *User) UpdateFromServer(serverSideUser *User)

type UserPool

type UserPool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewUserPool

func NewUserPool(grpcEndPoint, remoteConfigURL, metricURL string, proxyTags []string) *UserPool

func (*UserPool) CreateUser

func (up *UserPool) CreateUser(userId, level int, password, method, protocol string, enable bool) *User

func (*UserPool) GetAllUsers

func (up *UserPool) GetAllUsers() []*User

func (*UserPool) GetUser

func (up *UserPool) GetUser(id int) (*User, bool)

func (*UserPool) RemoveUser

func (up *UserPool) RemoveUser(id int)

func (*UserPool) Start

func (up *UserPool) Start(ctx context.Context) error

func (*UserPool) Stop

func (up *UserPool) Stop()

type UserTraffic

type UserTraffic struct {
	ID              int      `json:"user_id"`
	UploadTraffic   int64    `json:"upload_traffic"`
	DownloadTraffic int64    `json:"download_traffic"`
	IPList          []string `json:"ip_list"`
	TcpCount        int64    `json:"tcp_conn_num"`
}

type XrayServer

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

func NewXrayServer

func NewXrayServer(cfg *config.Config) *XrayServer

func (*XrayServer) Reload

func (xs *XrayServer) Reload() error

func (*XrayServer) Setup

func (xs *XrayServer) Setup() error

func (*XrayServer) Start

func (xs *XrayServer) Start(ctx context.Context) error

func (*XrayServer) Stop

func (xs *XrayServer) Stop()