Functions — github.com/Ember-Moth/ppanel

hub / github.com/Ember-Moth/ppanel / functions

Functions1,586 in github.com/Ember-Moth/ppanel

⨍ Functions 1,586◇ Types & classes 763

Methodquery_server_sorts

(&self)

src/repository/node/pg.rs:242

Methodquery_server_sorts

(&self)

src/repository/node/mysql.rs:265

Functionquery_server_total_data

( _repos: &Repositories, )

src/service/admin/console/query_server_total_data_service.rs:4

Functionquery_server_total_data

(State(state): State<AppState>)

src/handler/admin/console/query_server_total_data_handler.rs:7

Methodquery_server_traffic_by_day

( &self, server_id: i64, date: i64, )

src/repository/traffic/pg.rs:91

Methodquery_server_traffic_by_day

( &self, server_id: i64, date: i64, )

src/repository/traffic/mysql.rs:95

Methodquery_server_traffic_ranking

( &self, start: i64, end: i64, )

src/repository/traffic/mysql.rs:223

Functionquery_subscribe_group_list

Backwards-compatible alias used by older callers.

src/service/admin/subscribe/get_subscribe_group_list_service.rs:24

Functionquery_subscribe_group_list

(State(state): State<AppState>)

src/handler/public/subscribe/query_subscribe_group_list_handler.rs:6

Methodquery_subscribe_ids_by_filter

( &self, filter: &SubscribeFilter, )

src/repository/user/mysql.rs:1158

Functionquery_subscribe_list

( State(state): State<AppState>, Query(req): Query<QuerySubscribeListRequest>, )

src/handler/public/subscribe/query_subscribe_list_handler.rs:8

Methodquery_task_list

( &self, filter: &TaskFilter, )

src/repository/task/mysql.rs:98

Methodquery_ticket_detail

(&self, id: i64)

src/repository/ticket/pg.rs:87

Methodquery_ticket_detail

(&self, id: i64)

src/repository/ticket/mysql.rs:102

Methodquery_ticket_list

( &self, page: i64, size: i64, user_id: i64, status: Option<i16>,

src/repository/ticket/mysql.rs:109

Functionquery_ticket_wait_reply

( repo: &dyn TicketRepo, )

src/service/admin/console/query_ticket_wait_reply_service.rs:6

Functionquery_ticket_wait_reply

(State(state): State<AppState>)

src/handler/admin/console/query_ticket_wait_reply_handler.rs:7

Methodquery_total_orders

(&self)

src/repository/order/mysql.rs:321

Methodquery_total_user_counts

(&self)

src/repository/order/mysql.rs:408

Methodquery_trade

(&self, order_no: &str)

crates/payment/src/alipay.rs:93

Methodquery_traffic_by_day

(&self, date: i64)

src/repository/traffic/mysql.rs:112

Methodquery_traffic_by_monthly

(&self, date: i64)

src/repository/traffic/mysql.rs:124

Methodquery_traffic_log_details

( &self, filter: &TrafficLogDetailsFilter, )

src/repository/traffic/pg.rs:278

Methodquery_traffic_log_details

( &self, filter: &TrafficLogDetailsFilter, )

src/repository/traffic/mysql.rs:282

Methodquery_traffic_log_page_list

( &self, user_id: i64, subscribe_id: i64, page: i64, size: i64, )

src/repository/traffic/pg.rs:251

Methodquery_traffic_log_page_list

( &self, user_id: i64, subscribe_id: i64, page: i64, size: i64, )

src/repository/traffic/mysql.rs:255

Methodquery_traffic_summary

( &self, start: i64, end: i64, )

src/repository/traffic/mysql.rs:136

Functionquery_user_affiliate

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, )

src/handler/public/user/query_user_affiliate_handler.rs:9

Functionquery_user_affiliate_list

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Query(req): Query<QueryU

src/handler/public/user/query_user_affiliate_list_handler.rs:10

Functionquery_user_balance_log

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Query(req): Query<Filter

src/handler/public/user/query_user_balance_log_handler.rs:10

Functionquery_user_commission_log

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Query(req): Query<Filter

src/handler/public/user/query_user_commission_log_handler.rs:10

Functionquery_user_info

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, )

src/handler/public/user/query_user_info_handler.rs:9

Functionquery_user_statistics

( user_repo: &dyn UserRepo, order_repo: &dyn OrderRepo, )

src/service/admin/console/query_user_statistics_service.rs:8

Functionquery_user_statistics

(State(state): State<AppState>)

src/handler/admin/console/query_user_statistics_handler.rs:7

Functionquery_user_subscribe

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, )

src/handler/public/user/query_user_subscribe_handler.rs:9

Methodquery_user_subscribe

( &self, user_id: i64, statuses: &[i64], )

src/repository/user/pg.rs:898

Methodquery_user_subscribe

( &self, user_id: i64, statuses: &[i64], )

src/repository/user/mysql.rs:934

Functionquery_user_subscribe_node_list

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, )

src/handler/public/subscribe/query_user_subscribe_node_list_handler.rs:9

Methodquery_user_traffic_ranking

( &self, start: i64, end: i64, )

src/repository/traffic/mysql.rs:239

Methodquery_wait_reply_total

(&self)

src/repository/ticket/mysql.rs:201

Functionquery_withdrawal_log

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Query(req): Query<QueryW

src/handler/public/user/query_withdrawal_log_handler.rs:10

Methodquery_yearly_reset_subscribe_ids

( &self, subscribe_ids: &[i64], _now: i64, )

src/repository/user/mysql.rs:853

Functionrandom_uuid

Generate a random UUID suitable for use as an idempotency key.

crates/turnstile/src/lib.rs:72

Functionrate_limit_layer

Axum middleware that enforces a per-IP (or per-custom-key) rate limit. The key is extracted from the `X-Original-Forwarded-For` / `X-Forwarded-For` h

src/middleware/rate_limit_middleware.rs:100

Functionrecharge

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<Recharge

src/handler/public/order/recharge_handler.rs:11

Methodredis_url

Build a Redis URL from our config (compatible with `redis://` scheme).

src/scheduler/mod.rs:17

Methodregister

( scheduler: &Scheduler, task_type: &str, cron: &str, queue: &str, )

src/scheduler/mod.rs:78

Methodregister

(&self, req: TelephoneRegisterRequest)

src/service/auth/telephone_user_register_service.rs:28

Methodregister

(&self, req: UserRegisterRequest)

src/service/auth/user_register_service.rs:28

Functionreload_handler

( )

src/handler/admin/plugin/reload.rs:3

Methodremove_worker

(&self, id: i64)

crates/email/src/manager.rs:78

Functionrenewal

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<RenewalO

src/handler/public/order/renewal_handler.rs:11

Methodreset

(&self, req: TelephoneResetPasswordRequest)

src/service/auth/telephone_reset_password_service.rs:27

Functionreset_all_subscribe_token

( repo: &dyn SubscribeRepo, )

src/service/admin/subscribe/reset_all_subscribe_token_service.rs:6

Functionreset_all_subscribe_token

( State(state): State<AppState>, )

src/handler/admin/subscribe/reset_all_subscribe_token_handler.rs:7

Functionreset_password

( State(state): State<AppState>, Extension(device): Extension<DeviceContext>, Json(mut req): Json<

src/handler/auth/reset_password_handler.rs:9

Functionreset_sort_with_node

( repo: &dyn NodeRepo, req: ResetSortRequest, )

src/service/admin/server/reset_sort_with_node_service.rs:6

Functionreset_sort_with_node

( State(state): State<AppState>, Json(req): Json<ResetSortRequest>, )

src/handler/admin/server/reset_sort_with_node_handler.rs:9

Functionreset_sort_with_server

( repo: &dyn NodeRepo, req: ResetSortRequest, )

src/service/admin/server/reset_sort_with_server_service.rs:6

Functionreset_sort_with_server

( State(state): State<AppState>, Json(req): Json<ResetSortRequest>, )

src/handler/admin/server/reset_sort_with_server_handler.rs:9

Methodreset_subscribe

Record a subscribe traffic reset event. `type_` should be one of the `RESET_SUBSCRIBE_TYPE_*` constants. Go counterpart: `resetTrafficLogic`, `activa

src/service/telemetry.rs:252

Methodreset_subscribe_traffic_by_ids

(&self, ids: &[i64])

src/repository/user/mysql.rs:874

Functionreset_traffic

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<ResetTra

src/handler/public/order/reset_traffic_handler.rs:11

Functionreset_user_subscribe_token

Mint a fresh token + uuid for a UserSubscribe. The old token is invalidated implicitly because the row is updated.

src/service/admin/user/reset_user_subscribe_token_service.rs:13

Functionreset_user_subscribe_token

( State(state): State<AppState>, Extension(auth): Extension<AuthContext>, Json(req): Json<ResetUse

src/handler/public/user/reset_user_subscribe_token_handler.rs:11

Functionreset_user_subscribe_token

( State(state): State<AppState>, Json(req): Json<ResetUserSubscribeTokenRequest>, )

src/handler/admin/user/reset_user_subscribe_token_handler.rs:9

Functionreset_user_subscribe_traffic

Reset `download` and `upload` counters to zero for a single UserSubscribe and emit a `RESET_SUBSCRIBE` business audit log.

src/service/admin/user/reset_user_subscribe_traffic_service.rs:14

Functionreset_user_subscribe_traffic

( State(state): State<AppState>, Json(req): Json<ResetUserSubscribeTrafficRequest>, )

src/handler/admin/user/reset_user_subscribe_traffic_handler.rs:9

Functionresolve_ip

(input: &str)

crates/ip/src/lib.rs:25

Functionrestart_system

()

src/service/admin/tool/restart_system_service.rs:1

Functionrestart_system

()

src/handler/admin/tool/restart_system_handler.rs:4

Methodretrieve_payment_method

( &self, id: &str, )

crates/payment/src/stripe.rs:152

Functionsecurity_config_json

(p: &Protocol)

src/service/server/get_server_config_service.rs:124

Methodsend

(&self, area: &str, phone: &str, code: &str, _expire: u32)

crates/sms/src/providers/alibabacloud.rs:131

Methodsend

(&self, area: &str, phone: &str, code: &str, _expire: u32)

crates/sms/src/providers/smsbao.rs:50

Methodsend

(&self, area: &str, phone: &str, code: &str, _expire: u32)

crates/sms/src/providers/twilio.rs:37

Methodsend

(&self, area: &str, phone: &str, code: &str, _expire: u32)

crates/sms/src/providers/abosend.rs:50

Methodsend_code

( &self, req: SendCodeRequest, )

src/service/common/send_email_code_service.rs:33

Functionsend_email_code

( State(state): State<AppState>, Json(req): Json<SendCodeRequest>, )

src/handler/common/send_email_code_handler.rs:8

Functionsend_sms_code

( State(state): State<AppState>, Json(req): Json<SendSmsCodeRequest>, )

src/handler/common/send_sms_code_handler.rs:8

Methodserialize

(&self, serializer: S)

src/model/dto/misc.rs:16

Functionserver_middleware

( State(state): State<AppState>, req: Request, next: Next, )

src/middleware/server_middleware.rs:19

Functionserver_middleware

Placeholder — may be extended with axum middleware later.

src/handler/server/helpers.rs:8

Functionserver_push_status

( repos: Arc<Repositories>, _config: Arc<Config>, _cache: Arc<Cache>, req: ServerPushStatusReq

src/service/server/server_push_status_service.rs:7

Functionserver_push_status

( State(state): State<AppState>, headers: HeaderMap, Json(req): Json<ServerPushStatusRequest>, )

src/handler/server/server_push_status_handler.rs:14

Functionserver_push_user_traffic

Accepts a traffic report from a node and enqueues a traffic-statistics task.

src/service/server/server_push_user_traffic_service.rs:16

Functionserver_push_user_traffic

( State(state): State<AppState>, headers: HeaderMap, Json(req): Json<ServerPushUserTrafficRequest>

src/handler/server/server_push_user_traffic_handler.rs:14

Functionserver_to_dto

(s: Server)

src/service/admin/server/filter_server_list_service.rs:32

Methodserver_traffic

Record per-server traffic statistics for a time window. Go counterpart: `trafficStatLogic`.

src/service/telemetry.rs:230

Methodserver_traffic_rank

Record the daily/periodic server traffic ranking snapshot. Go counterpart: `trafficStatLogic`.

src/service/telemetry.rs:344

Functionset_global_manager

(manager: Arc<WorkerManager>)

crates/email/src/manager.rs:115

Functionset_node_multiplier

Persist a new node-multiplier schedule. Stored as a JSON-encoded `Vec<TimePeriod>` under `(server, NodeMultiplierConfig)`.

src/service/admin/system/set_node_multiplier_service.rs:11

Functionset_node_multiplier

( State(state): State<AppState>, Json(req): Json<SetNodeMultiplierRequest>, )

src/handler/admin/system/set_node_multiplier_handler.rs:9

Functionsetting_telegram_bot_handler

(State(state): State<AppState>)

src/handler/admin/system/setting_telegram_bot_handler.rs:6

Functionsprig_date

`date` — formats a Unix timestamp using a Go-style layout string. Signature: `date <layout-string> <unix-timestamp>`

src/adapter/mod.rs:270

Functionsprig_to_json

`toJson` — serialises first argument to a JSON string.

src/adapter/mod.rs:244

Functionstop_batch_send_email_task

( repo: &dyn TaskRepo, req: StopBatchSendEmailTaskRequest, )

src/service/admin/marketing/stop_batch_send_email_task_service.rs:9

Functionstop_batch_send_email_task

( State(state): State<AppState>, Json(req): Json<StopBatchSendEmailTaskRequest>, )

src/handler/admin/marketing/stop_batch_send_email_task_handler.rs:9

Functionstripe_notify_handler

`POST /v1/notify/stripe/:token`

src/handler/notify/payment_notify_handler.rs:51

Functionstub_reset_traffic

(task: Task)

src/queue/handler/traffic.rs:14

← previous next →1,301–1,400 of 1,586, ranked by callers