svc

package

v1.19.0 Latest Latest Go to latest Published: Aug 28, 2026 License: GPL-3.0 Imports: 43 Imported by: 0

Details

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

Repository

github.com/perfect-panel/server

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DownloadGeoIPDatabase(url, path string) error
func NewAsynqClient(c config.Config) *asynqx.Client
func NewAsynqInspector(c config.Config) *asynq.Inspector
func NewDeviceManager(srv *Application) *device.DeviceManager
func NewStore(db *gorm.DB, rds *redis.Client) *repository.GormStore
type Application
- func NewApplication(c config.Config) *Application
type DeviceMessage
- func (dm *DeviceMessage) Json() string
type DeviceMessageMethod
type IPLocation
- func NewIPLocation(path string) (*IPLocation, error)
- func (ipLoc *IPLocation) Close() error

Constants ¶

View Source

const GeoIPDBURL = "https://raw.githubusercontent.com/adysec/IP_database/main/geolite/GeoLite2-City.mmdb"

Variables ¶

This section is empty.

Functions ¶

func DownloadGeoIPDatabase ¶ added in v1.2.0

func DownloadGeoIPDatabase(url, path string) error

func NewAsynqClient ¶

func NewAsynqClient(c config.Config) *asynqx.Client

NewAsynqClient returns the tracing asynq client: EnqueueContext stamps the caller's trace context onto the task for the worker-side middleware to resume. Pass task options to EnqueueContext, not NewTask — wrapping rebuilds the task.

func NewAsynqInspector ¶ added in v1.14.8

func NewAsynqInspector(c config.Config) *asynq.Inspector

func NewDeviceManager ¶

func NewDeviceManager(srv *Application) *device.DeviceManager

func NewStore ¶ added in v1.15.2

func NewStore(db *gorm.DB, rds *redis.Client) *repository.GormStore

NewStore assembles the shared store from the module-owned repo builders (falling back to the repository package's legacy builders for implementations that have not migrated yet). One connection pool, module- owned persistence (ADR-001 step-6 preparation).

Types ¶

type Application ¶ added in v1.19.0

type Application struct {
	Redis        *redis.Client
	Runtime      *appstate.State
	Queue        *asynqx.Client
	Inspector    *asynq.Inspector
	ExchangeRate *exchangeRate.Cache
	GeoIP        *IPLocation
	Store        repository.Store

	// Domain modules (see docs/adr-001-modular-monolith.md). Application is
	// their composition root; handlers call the module facades.
	Support      support.Service
	Billing      billing.Service
	Platform     platform.Service
	Subscription subscription.Service
	Identity     identity.Service
	Network      network.Service
	Notification notification.Service
	EventBus     *eventbus.Bus

	//NodeCache   *cache.NodeCacheClient
	AuthLimiter   *limit.PeriodLimit
	DeviceManager *device.DeviceManager
}

func NewApplication ¶ added in v1.19.0

func NewApplication(c config.Config) *Application

type DeviceMessage ¶

type DeviceMessage struct {
	Method DeviceMessageMethod `json:"method"`
}

func (*DeviceMessage) Json ¶

func (dm *DeviceMessage) Json() string

type DeviceMessageMethod ¶

type DeviceMessageMethod string

const (
	// DeviceKickedMax 设备数量超出限制
	DeviceKickedMax DeviceMessageMethod = "kicked_device"
	// DeviceKickedAdmin 管理员踢下线
	DeviceKickedAdmin DeviceMessageMethod = "kicked_admin"
	// SubscribeUpdate 订阅有更新
	SubscribeUpdate DeviceMessageMethod = "subscribe_update"
)

type IPLocation ¶ added in v1.2.0

type IPLocation struct {
	Path string
	DB   *geoip2.Reader
}

func NewIPLocation ¶ added in v1.2.0

func NewIPLocation(path string) (*IPLocation, error)

func (*IPLocation) Close ¶ added in v1.2.0

func (ipLoc *IPLocation) Close() error

Source Files ¶

View all Source files

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