subscription

Documentation

Index

• func BuildHysteriaUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User
• func BuildShadowsocksUsers(subscriptionInfo *[]api.SubscriptionInfo, method string, tag string) []*protocol.User
• func BuildTrojanUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User
• func BuildVlessUsers(subscriptionInfo *[]api.SubscriptionInfo, flow string, tag string) []*protocol.User
• func BuildVmessUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User
• func Compare(old, new *[]api.SubscriptionInfo) (deleted, added, modified []api.SubscriptionInfo)
• func FormatEmails(subscriptions []api.SubscriptionInfo, tag string) []string
• type Manager
  • func NewManager(server *core.Instance, client api.API, ...) *Manager
  • func (m *Manager) Add(subscriptions []*protocol.User, tag string) error
  • func (m *Manager) AddNewSubscription(subscriptionInfo *[]api.SubscriptionInfo, nodeInfo *api.NodeInfo, tag string) (err error)
  • func (m *Manager) GetOnlineIPs(tag string) (*[]api.OnlineIP, error)
  • func (m *Manager) Remove(emails []string, tag string) error
  • func (m *Manager) SubscriptionMonitor(tag string, logPrefix string) error

Functions

func BuildHysteriaUsers

func BuildHysteriaUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User

BuildHysteriaUsers builds Hysteria protocol users from subscription info

func BuildShadowsocksUsers

func BuildShadowsocksUsers(subscriptionInfo *[]api.SubscriptionInfo, method string, tag string) []*protocol.User

BuildShadowsocksUsers builds Shadowsocks protocol users from subscription info

func BuildTrojanUsers

func BuildTrojanUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User

BuildTrojanUsers builds Trojan protocol users from subscription info

func BuildVlessUsers

func BuildVlessUsers(subscriptionInfo *[]api.SubscriptionInfo, flow string, tag string) []*protocol.User

BuildVlessUsers builds Vless protocol users from subscription info

func BuildVmessUsers

func BuildVmessUsers(subscriptionInfo *[]api.SubscriptionInfo, tag string) []*protocol.User

BuildVmessUsers builds Vmess protocol users from subscription info

func Compare

func Compare(old, new *[]api.SubscriptionInfo) (deleted, added, modified []api.SubscriptionInfo)

Compare compares two subscription lists based on ID only deleted: subscriptions whose IDs are in old but not in new added: subscriptions whose IDs are in new but not in old modified: subscriptions whose IDs exist in both but properties changed

func FormatEmails

func FormatEmails(subscriptions []api.SubscriptionInfo, tag string) []string

Types

type Manager

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

Manager handles subscription-related operations

func NewManager

func NewManager(server *core.Instance, client api.API, dispatcher *dispatcher.LimitingDispatcher) *Manager

NewManager creates a new subscription manager

func (*Manager) Add

func (m *Manager) Add(subscriptions []*protocol.User, tag string) error

Add adds new subscriptions to an inbound tag

func (*Manager) AddNewSubscription

func (m *Manager) AddNewSubscription(subscriptionInfo *[]api.SubscriptionInfo, nodeInfo *api.NodeInfo, tag string) (err error)

func (*Manager) GetOnlineIPs

func (m *Manager) GetOnlineIPs(tag string) (*[]api.OnlineIP, error)

func (*Manager) Remove

func (m *Manager) Remove(emails []string, tag string) error

Remove removes subscriptions from an inbound tag

func (*Manager) SubscriptionMonitor

func (m *Manager) SubscriptionMonitor(
	tag string,
	logPrefix string,
) error