core

Documentation

Index

• type Core
  • func New(c *conf.Conf) *Core
  • func (p *Core) AddInbound(config *core.InboundHandlerConfig) error
  • func (p *Core) AddInboundLimiter(tag string, nodeInfo *panel.NodeInfo, users []panel.UserInfo) error
  • func (p *Core) AddOutbound(config *core.OutboundHandlerConfig) error
  • func (p *Core) AddUserSpeedLimit(tag string, user *panel.UserInfo, speedLimit int, expire int64) error
  • func (p *Core) AddUsers(users []*protocol.User, tag string) error
  • func (p *Core) ClearOnlineIp(tag string)
  • func (p *Core) Close()
  • func (p *Core) DeleteInboundLimiter(tag string) error
  • func (p *Core) GetInboundLimiter(tag string) (*dispatcher.InboundInfo, error)
  • func (p *Core) GetUserManager(tag string) (proxy.UserManager, error)
  • func (p *Core) GetUserTraffic(email string, reset bool) (up int64, down int64)
  • func (p *Core) ListOnlineIp(tag string) ([]dispatcher.UserIpList, error)
  • func (p *Core) RemoveInbound(tag string) error
  • func (p *Core) RemoveOutbound(tag string) error
  • func (p *Core) RemoveUsers(users []string, tag string) error
  • func (p *Core) Restart(v2bXConfig *conf.Conf) error
  • func (p *Core) Start() error
  • func (p *Core) UpdateInboundLimiter(tag string, added []panel.UserInfo, deleted []panel.UserInfo) error
  • func (p *Core) UpdateOnlineIp(tag string, ips []dispatcher.UserIpList)
  • func (p *Core) UpdateRule(tag string, newRuleList []panel.DestinationRule) error

Types

type Core

type Core struct {
	Server *core.Instance
	// contains filtered or unexported fields
}

Core Structure

func New

func New(c *conf.Conf) *Core

func (*Core) AddInbound

func (p *Core) AddInbound(config *core.InboundHandlerConfig) error

func (*Core) AddInboundLimiter

func (p *Core) AddInboundLimiter(tag string, nodeInfo *panel.NodeInfo, users []panel.UserInfo) error

func (*Core) AddOutbound

func (p *Core) AddOutbound(config *core.OutboundHandlerConfig) error

func (*Core) AddUserSpeedLimit

func (p *Core) AddUserSpeedLimit(tag string, user *panel.UserInfo, speedLimit int, expire int64) error

func (*Core) AddUsers

func (p *Core) AddUsers(users []*protocol.User, tag string) error

func (*Core) ClearOnlineIp

func (p *Core) ClearOnlineIp(tag string)

func (*Core) Close

func (p *Core) Close()

Close the core

func (*Core) DeleteInboundLimiter

func (p *Core) DeleteInboundLimiter(tag string) error

func (*Core) GetInboundLimiter

func (p *Core) GetInboundLimiter(tag string) (*dispatcher.InboundInfo, error)

func (*Core) GetUserManager

func (p *Core) GetUserManager(tag string) (proxy.UserManager, error)

func (*Core) GetUserTraffic

func (p *Core) GetUserTraffic(email string, reset bool) (up int64, down int64)

func (*Core) ListOnlineIp

func (p *Core) ListOnlineIp(tag string) ([]dispatcher.UserIpList, error)

func (*Core) RemoveInbound

func (p *Core) RemoveInbound(tag string) error

func (*Core) RemoveOutbound

func (p *Core) RemoveOutbound(tag string) error

func (*Core) RemoveUsers

func (p *Core) RemoveUsers(users []string, tag string) error

func (*Core) Restart

func (p *Core) Restart(v2bXConfig *conf.Conf) error

func (*Core) Start

func (p *Core) Start() error

Start the Core

func (*Core) UpdateInboundLimiter

func (p *Core) UpdateInboundLimiter(tag string, added []panel.UserInfo, deleted []panel.UserInfo) error

func (*Core) UpdateOnlineIp

func (p *Core) UpdateOnlineIp(tag string, ips []dispatcher.UserIpList)

func (*Core) UpdateRule

func (p *Core) UpdateRule(tag string, newRuleList []panel.DestinationRule) error