postgres

package

Go to main page

Versions in this module

v0

v0.13.0

Aug 5, 2026

v0.12.0

Aug 5, 2026

v0.11.0

Aug 5, 2026

Changes in this version

type Store

+ func (s *Store) UsersForProfile(ctx context.Context, profileID string) ([]domain.User, error)

v0.10.1

Aug 5, 2026

v0.10.0

Aug 5, 2026

Changes in this version

type ProvisionedUser

+ WGIndex int64

+ WGPublicKey string

type Store

+ func (s *Store) SetWireGuardKeys(ctx context.Context, id, private, public string) error

+ func (s *Store) UsersMissingWireGuardKeys(ctx context.Context, limit int) ([]string, error)

type UserSecrets

+ WGPrivateKey string

+ WGPublicKey string

v0.9.0

Aug 5, 2026

Changes in this version

+ type Attention struct

+ Expiring []PendingWarning

+ NearQuota []PendingWarning

+ NodesDegraded int

+ NodesOffline int

+ NodesOverQuota int

+ PaymentsDueSoon int

+ UsersExpiring int

+ UsersLimited int

+ UsersNearQuota int

+ type PendingWarning struct

+ DaysLeft int

+ LimitBytes int64

+ Percent int

+ UsedBytes int64

+ UserID string

+ Username string

type Store

+ func (s *Store) Attention(ctx context.Context, expiryDays, quotaPercent int) (*Attention, error)

+ func (s *Store) ClaimExpiryWarnings(ctx context.Context, within time.Duration) ([]PendingWarning, error)

+ func (s *Store) ClaimQuotaWarnings(ctx context.Context, percent int) ([]PendingWarning, error)

v0.8.0

Aug 5, 2026

v0.7.0

Aug 4, 2026

Changes in this version

type Store

+ func (s *Store) ClaimTOTPStep(ctx context.Context, id string, step int64) (bool, error)

+ func (s *Store) ConfirmTOTP(ctx context.Context, id string, step int64, recoveryHashes []string) error

+ func (s *Store) ConsumeRecoveryCode(ctx context.Context, id, digest string) (bool, error)

+ func (s *Store) DisableTOTP(ctx context.Context, id string) error

+ func (s *Store) ReplaceRecoveryCodes(ctx context.Context, id string, hashes []string) error

+ func (s *Store) StageTOTPSecret(ctx context.Context, id, secret string) error

v0.6.0

Aug 3, 2026

Changes in this version

+ type Session struct

+ Bytes int64

+ Country string

+ LastSeen time.Time

+ NodeID string

+ NodeName string

+ OnlineAt *time.Time

+ Status string

+ UserID string

+ Username string

type Store

+ func (s *Store) Sessions(ctx context.Context, within time.Duration, limit int) ([]Session, error)

v0.5.0

Aug 3, 2026

Changes in this version

+ type ResponseRule struct

+ CreatedAt time.Time

+ Format string

+ Hits int64

+ IsEnabled bool

+ MatchUA string

+ Name string

+ Priority int

+ UUID string

+ UpdatedAt time.Time

type Store

+ func (s *Store) CreateRule(ctx context.Context, r ResponseRule) (*ResponseRule, error)

+ func (s *Store) DeleteRule(ctx context.Context, id string) error

+ func (s *Store) ListRules(ctx context.Context) ([]ResponseRule, error)

+ func (s *Store) MatchRule(ctx context.Context, userAgent string) (string, bool)

+ func (s *Store) PreviewRule(ctx context.Context, userAgent string) (string, bool)

+ func (s *Store) UpdateRule(ctx context.Context, id string, r ResponseRule) (*ResponseRule, error)

v0.4.0

Aug 3, 2026

Changes in this version

type Store

+ func (s *Store) AllDevices(ctx context.Context, search string, limit int) ([]domain.Device, error)

+ func (s *Store) PruneSubscriptionRequests(ctx context.Context, keepFor time.Duration) error

+ func (s *Store) RecordSubscriptionRequest(ctx context.Context, r SubscriptionRequest)

+ func (s *Store) SubscriptionRequests(ctx context.Context, userID string, failedOnly bool, limit int) ([]SubscriptionRequest, error)

+ type SubscriptionRequest struct

+ At time.Time

+ Format string

+ HWID string

+ ID int64

+ IP string

+ Status int

+ Token string

+ UserAgent string

+ UserID *string

+ Username string

v0.3.0

Aug 3, 2026

Changes in this version

+ type Snapshot struct

+ Counts map[string]int

+ Schema string

+ Tables map[string][]map[string]any

+ TakenAt string

+ Types map[string]map[string]string

type Store

+ func (s *Store) ExportSnapshot(ctx context.Context) (*Snapshot, error)

+ func (s *Store) ImportSnapshot(ctx context.Context, snap *Snapshot, currentSchema string) error

+ func (s *Store) SchemaVersion(ctx context.Context) (string, error)

v0.2.0

Aug 3, 2026

Changes in this version

type Store

+ func (s *Store) Channel(ctx context.Context, id string) (*domain.NotificationChannel, error)

+ func (s *Store) ChannelDeliveries(ctx context.Context, id string, limit int) ([]domain.NotificationDelivery, error)

+ func (s *Store) CreateAnnouncement(ctx context.Context, a domain.Announcement) (*domain.Announcement, error)

+ func (s *Store) CreateChannel(ctx context.Context, c domain.NotificationChannel) (*domain.NotificationChannel, error)

+ func (s *Store) DeleteAnnouncement(ctx context.Context, id string) error

+ func (s *Store) DeleteChannel(ctx context.Context, id string) error

+ func (s *Store) EnabledChannels(ctx context.Context) ([]domain.NotificationChannel, error)

+ func (s *Store) ListAnnouncements(ctx context.Context) ([]domain.Announcement, error)

+ func (s *Store) ListChannels(ctx context.Context) ([]domain.NotificationChannel, error)

+ func (s *Store) LiveAnnouncements(ctx context.Context) ([]domain.Announcement, error)

+ func (s *Store) NodeMetrics(ctx context.Context, nodeID string, since time.Duration) ([]domain.NodeMetric, error)

+ func (s *Store) OnEvent(fn func(domain.Event))

+ func (s *Store) PruneDeliveries(ctx context.Context, keepFor time.Duration) error

+ func (s *Store) PruneNodeMetrics(ctx context.Context, keepFor time.Duration) error

+ func (s *Store) RecordDelivery(ctx context.Context, d domain.NotificationDelivery) error

+ func (s *Store) RecordNodeMetric(ctx context.Context, nodeID string, m domain.NodeMetric) error

+ func (s *Store) UpdateAnnouncement(ctx context.Context, id string, a domain.Announcement) (*domain.Announcement, error)

+ func (s *Store) UpdateChannel(ctx context.Context, id string, c domain.NotificationChannel) (*domain.NotificationChannel, error)

v0.1.1

Aug 3, 2026

v0.1.0

Aug 1, 2026

Changes in this version

+ var ErrConflict = errors.New("already exists")

+ var ErrNotFound = errors.New("not found")

+ type HostInput struct

+ ALPN string

+ Address string

+ AllowInsecure bool

+ Fingerprint string

+ Flow string

+ HostHeader string

+ InboundID string

+ IsDisabled bool

+ Path string

+ Port int

+ PublicKey string

+ Remark string

+ SNI string

+ Security string

+ ShortID string

+ SpiderX string

+ Tags []string

+ ViewPosition int

+ type NodeConnectedInfo struct

+ AgentVersion string

+ Arch string

+ CPUCount int

+ CPUModel string

+ ConfigHash string

+ Hostname string

+ Kernel string

+ OS string

+ TotalRAMBytes int64

+ XrayVersion string

+ type NodeHeartbeat struct

+ CPUUsage float64

+ ConfigHash string

+ Health domain.NodeHealth

+ LoadAvg1 float64

+ Message string

+ OnlineUsers int

+ TotalRAMBytes int64

+ UsedRAMBytes int64

+ XrayRunning bool

+ XrayStartedAt *time.Time

+ XrayVersion string

+ type NodeInput struct

+ ActiveInboundTags []string

+ Address string

+ BillingCycle domain.BillingCycle

+ BillingNotes string

+ ConfigProfileID *string

+ Consumption float64

+ CostAmount float64

+ CostCurrency string

+ CountryCode string

+ Description string

+ IsDisabled bool

+ Name string

+ NextPaymentAt *time.Time

+ NotifyPercent int

+ Provider string

+ ProviderURL string

+ Tags []string

+ TrafficLimitBytes int64

+ TrafficReset domain.TrafficResetStrategy

+ ViewPosition int

+ type NodeSeries struct

+ NodeID string

+ NodeName string

+ Points []TrafficPoint

+ Total int64

+ type Overview struct

+ HostsTotal int

+ NodesDisabled int

+ NodesOnline int

+ NodesTotal int

+ ProfilesTotal int

+ SquadsTotal int

+ TrafficDay int64

+ TrafficMonth int64

+ TrafficTotal int64

+ TrafficWeek int64

+ UsersActive int

+ UsersDisabled int

+ UsersExpired int

+ UsersLimited int

+ UsersOnline int

+ UsersTotal int

+ type ProviderSpend struct

+ Monthly float64

+ Nodes int

+ Provider string

+ type ProvisionedUser struct

+ InboundTag string

+ SSPassword string

+ TrojanPassword string

+ UUID string

+ Username string

+ VlessUUID string

+ type SpendSummary struct

+ BilledNodes int

+ ByProvider []ProviderSpend

+ CostPerTB float64

+ Currency string

+ MonthlyTotal float64

+ Overdue int

+ TrafficMonthTB float64

+ Upcoming []UpcomingBill

+ YearlyTotal float64

+ type Store struct

+ func Connect(ctx context.Context, dsn string) (*Store, error)

+ func (s *Store) APITokenByHash(ctx context.Context, hash string) (*domain.APIToken, error)

+ func (s *Store) AddAllUsersToSquad(ctx context.Context, squadID string) (int64, error)

+ func (s *Store) AddNodeTraffic(ctx context.Context, id string, bytes int64) error

+ func (s *Store) AddUserTraffic(ctx context.Context, userID string, bytes int64) (used, limit int64, status domain.UserStatus, err error)

+ func (s *Store) AdminByUUID(ctx context.Context, id string) (*domain.Admin, error)

+ func (s *Store) AdminByUsername(ctx context.Context, username string) (*domain.Admin, error)

+ func (s *Store) ApplyNodeHeartbeat(ctx context.Context, id string, hb NodeHeartbeat) error

+ func (s *Store) Close()

+ func (s *Store) CountAdmins(ctx context.Context) (int, error)

+ func (s *Store) CreateAPIToken(ctx context.Context, name, hash, preview, createdBy string, ...) (*domain.APIToken, error)

+ func (s *Store) CreateAdmin(ctx context.Context, username, passwordHash string, role domain.AdminRole) (*domain.Admin, error)

+ func (s *Store) CreateHost(ctx context.Context, in HostInput) (*domain.Host, error)

+ func (s *Store) CreateNode(ctx context.Context, in NodeInput, tokenHash, tokenPreview string) (*domain.Node, error)

+ func (s *Store) CreateProfile(ctx context.Context, name string, config json.RawMessage, ...) (*domain.ConfigProfile, error)

+ func (s *Store) CreateSquad(ctx context.Context, name, info string, inboundIDs []string) (*domain.Squad, error)

+ func (s *Store) CreateUser(ctx context.Context, in UserInput, sec UserSecrets) (*domain.User, error)

+ func (s *Store) DeleteAPIToken(ctx context.Context, id string) error

+ func (s *Store) DeleteAdmin(ctx context.Context, id string) error

+ func (s *Store) DeleteDevice(ctx context.Context, userID, hwid string) error

+ func (s *Store) DeleteHost(ctx context.Context, id string) error

+ func (s *Store) DeleteNode(ctx context.Context, id string) error

+ func (s *Store) DeleteProfile(ctx context.Context, id string) error

+ func (s *Store) DeleteSquad(ctx context.Context, id string) error

+ func (s *Store) DeleteUser(ctx context.Context, id string) error

+ func (s *Store) ExpireUsers(ctx context.Context) (int64, error)

+ func (s *Store) Host(ctx context.Context, id string) (*domain.Host, error)

+ func (s *Store) HostsForInbounds(ctx context.Context, inboundIDs []string) ([]domain.Host, error)

+ func (s *Store) Inbound(ctx context.Context, id string) (*domain.ConfigProfileInbound, error)

+ func (s *Store) ListAPITokens(ctx context.Context) ([]domain.APIToken, error)

+ func (s *Store) ListAdmins(ctx context.Context) ([]domain.Admin, error)

+ func (s *Store) ListEvents(ctx context.Context, limit int, kind string) ([]domain.Event, error)

+ func (s *Store) ListHosts(ctx context.Context) ([]domain.Host, error)

+ func (s *Store) ListNodes(ctx context.Context) ([]domain.Node, error)

+ func (s *Store) ListProfiles(ctx context.Context) ([]domain.ConfigProfile, error)

+ func (s *Store) ListSquads(ctx context.Context) ([]domain.Squad, error)

+ func (s *Store) ListUsers(ctx context.Context, f UserFilter) ([]domain.User, int, error)

+ func (s *Store) LogEvent(ctx context.Context, kind domain.EventKind, actor, subject, message string, ...)

+ func (s *Store) MarkAllNodesDisconnected(ctx context.Context) error

+ func (s *Store) MarkNodeConnected(ctx context.Context, id string, info NodeConnectedInfo) error

+ func (s *Store) MarkNodeDisconnected(ctx context.Context, id, reason string) error

+ func (s *Store) MarkUserOnline(ctx context.Context, userID string)

+ func (s *Store) Migrate(ctx context.Context) error

+ func (s *Store) Node(ctx context.Context, id string) (*domain.Node, error)

+ func (s *Store) NodeTrafficSeries(ctx context.Context, since time.Time, interval string) ([]NodeSeries, error)

+ func (s *Store) NodesUsingProfile(ctx context.Context, profileID string) ([]domain.Node, error)

+ func (s *Store) Overview(ctx context.Context) (*Overview, error)

+ func (s *Store) Pool() *pgxpool.Pool

+ func (s *Store) Profile(ctx context.Context, id string) (*domain.ConfigProfile, error)

+ func (s *Store) ProfileInbounds(ctx context.Context, profileID string) ([]domain.ConfigProfileInbound, error)

+ func (s *Store) PruneUsage(ctx context.Context, retention time.Duration) error

+ func (s *Store) RecordNodeUsage(ctx context.Context, nodeID string, at time.Time, bytes int64) error

+ func (s *Store) RecordUserUsage(ctx context.Context, userID, nodeID string, at time.Time, bytes int64) error

+ func (s *Store) RemoveAllUsersFromSquad(ctx context.Context, squadID string) (int64, error)

+ func (s *Store) ReorderHosts(ctx context.Context, order []string) error

+ func (s *Store) ResetDevices(ctx context.Context, userID string) error

+ func (s *Store) ResetDueUserTraffic(ctx context.Context) (int64, error)

+ func (s *Store) ResetNodeTraffic(ctx context.Context, id string) error

+ func (s *Store) ResetUserTraffic(ctx context.Context, id string) error

+ func (s *Store) RevokeUserSubscription(ctx context.Context, ...) (*domain.User, error)

+ func (s *Store) RollDuePayments(ctx context.Context) ([]domain.Node, error)

+ func (s *Store) RotateNodeToken(ctx context.Context, id, tokenHash, tokenPreview string) error

+ func (s *Store) SetNodeConfigHash(ctx context.Context, id, hash string) error

+ func (s *Store) SetNodeDisabled(ctx context.Context, id string, disabled bool) error

+ func (s *Store) SetNodeHealth(ctx context.Context, id string, health domain.NodeHealth, message string) error

+ func (s *Store) SetUserStatus(ctx context.Context, id string, status domain.UserStatus) error

+ func (s *Store) Settings(ctx context.Context) (*domain.Settings, error)

+ func (s *Store) Spend(ctx context.Context, defaultCurrency string) (*SpendSummary, error)

+ func (s *Store) Squad(ctx context.Context, id string) (*domain.Squad, error)

+ func (s *Store) TopUsers(ctx context.Context, since time.Time, limit int) ([]TopUser, error)

+ func (s *Store) TotalTrafficSeries(ctx context.Context, since time.Time, interval string) ([]TrafficPoint, error)

+ func (s *Store) TouchAdminLogin(ctx context.Context, id string)

+ func (s *Store) TouchDevice(ctx context.Context, userID, hwid, userAgent, platform string, limit int) (allowed bool, count int, err error)

+ func (s *Store) TouchSubscriptionOpen(ctx context.Context, id, userAgent string)

+ func (s *Store) UpdateAdmin(ctx context.Context, id string, role domain.AdminRole, disabled bool) (*domain.Admin, error)

+ func (s *Store) UpdateAdminPassword(ctx context.Context, id, passwordHash string) error

+ func (s *Store) UpdateHost(ctx context.Context, id string, in HostInput) (*domain.Host, error)

+ func (s *Store) UpdateNode(ctx context.Context, id string, in NodeInput) (*domain.Node, error)

+ func (s *Store) UpdateProfile(ctx context.Context, id, name string, config json.RawMessage, ...) (*domain.ConfigProfile, error)

+ func (s *Store) UpdateSettings(ctx context.Context, in domain.Settings) (*domain.Settings, error)

+ func (s *Store) UpdateSquad(ctx context.Context, id, name, info string, inboundIDs []string) (*domain.Squad, error)

+ func (s *Store) UpdateUser(ctx context.Context, id string, in UserInput) (*domain.User, error)

+ func (s *Store) User(ctx context.Context, id string) (*domain.User, error)

+ func (s *Store) UserByShortUUID(ctx context.Context, short string) (*domain.User, error)

+ func (s *Store) UserBySubscription(ctx context.Context, subUUID string) (*domain.User, error)

+ func (s *Store) UserDevices(ctx context.Context, userID string) ([]domain.Device, error)

+ func (s *Store) UserInboundIDs(ctx context.Context, userID string) ([]string, error)

+ func (s *Store) UserTags(ctx context.Context) ([]string, error)

+ func (s *Store) UserTrafficSeries(ctx context.Context, userID string, since time.Time) ([]TrafficPoint, error)

+ func (s *Store) UsersForNode(ctx context.Context, profileID string, inboundTags []string) ([]ProvisionedUser, error)

+ type TopUser struct

+ Bytes int64

+ UserID string

+ Username string

+ type TrafficPoint struct

+ At time.Time

+ Bytes int64

+ type UpcomingBill struct

+ Amount float64

+ Currency string

+ DaysLeft int

+ DueAt time.Time

+ NodeID string

+ NodeName string

+ Provider string

+ type UserFilter struct

+ Desc bool

+ Limit int

+ Offset int

+ Search string

+ SortBy string

+ SquadID string

+ Status string

+ Tag string

+ type UserInput struct

+ Description string

+ Email string

+ ExpireAt *time.Time

+ HWIDDeviceLimit int

+ SquadIDs []string

+ Status domain.UserStatus

+ Tag string

+ TelegramID *int64

+ TrafficLimitBytes int64

+ TrafficReset domain.TrafficResetStrategy

+ Username string

+ type UserSecrets struct

+ SSPassword string

+ ShortUUID string

+ SubscriptionUUID string

+ TrojanPassword string

+ VlessUUID string

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