MCPcopy Create free account

hub / github.com/acking-you/static_flow / functions

Functions7,843 in github.com/acking-you/static_flow

↓ 5 callersFunctionnormalize_relative_path
(relative: &str)
crates/media-service/src/fs.rs:54
↓ 5 callersFunctionnormalize_requester_email_input
(value: Option<String>)
crates/llm-access/src/submission.rs:713
↓ 5 callersFunctionnormalize_requester_email_input
(value: Option<String>)
crates/backend/src/email.rs:229
↓ 5 callersFunctionnow_ms
()
crates/store/src/music_wish_store.rs:471
↓ 5 callersFunctionnow_ms
()
crates/store/src/article_request_store.rs:480
↓ 5 callersMethodobserve_stream_write
(&mut self, bytes_len: usize, event_type: Option<&str>)
crates/llm-access/src/provider/usage_meta.rs:219
↓ 5 callersMethodopen_table
(&self, table_name: &str)
crates/store/src/interactive_store.rs:189
↓ 5 callersMethodopen_table
(&self, table_name: &str)
crates/store/src/music_wish_store.rs:202
↓ 5 callersMethodopen_table
(&self, table_name: &str)
crates/store/src/article_request_store.rs:179
↓ 5 callersFunctionoptimize_table_indexes
(table: &Table)
crates/cli/src/db.rs:223
↓ 5 callersFunctionoptional_flag_value
(args: &'a [String], flag: &str)
crates/llm-usage-journal/src/cli.rs:212
↓ 5 callersMethodoverlay_admin_key
(&self, mut key: AdminKey)
crates/llm-access/src/runtime.rs:990
↓ 5 callersFunctionoverride_kiro_thinking_from_model_name
(payload: &mut MessagesRequest)
crates/llm-access/src/provider/kiro_model.rs:63
↓ 5 callersFunctionpage_moderation_keywords
Apply the admin keyword search and pagination contract to an in-memory list.
crates/llm-access-core/src/store/moderation.rs:123
↓ 5 callersFunctionparse_auth_parts_allow_missing_access
(auth_json: &str)
crates/llm-access/src/codex_refresh.rs:289
↓ 5 callersFunctionparse_usage_from_value
Parse standard Anthropic usage from either a response object or a usage object.
crates/llm-access-anthropic-pool/src/lib.rs:124
↓ 5 callersMethodpayload_as_json
(&self)
crates/llm-access-kiro/src/parser/frame.rs:39
↓ 5 callersFunctionpop_context_if_armed_for_current_page
()
crates/frontend/src/navigation_context.rs:159
↓ 5 callersFunctionprefix_pages_token_count
(pages: &[CanonicalTokenPage])
crates/llm-access-kiro/src/cache_sim/prefix_tree.rs:763
↓ 5 callersFunctionprefix_tree_config
()
crates/llm-access-kiro/src/cache_sim/mod.rs:230
↓ 5 callersMethodproxy_configs_table
(&self)
crates/store/src/llm_gateway_store/mod.rs:200
↓ 5 callersFunctionproxy_json_request_with_bearer
( state: &Gpt2ApiRsState, bearer: String, method: Method, path: &str, query: Option<&[(&st
crates/backend/src/gpt2api_rs.rs:1296
↓ 5 callersFunctionproxy_usage_query
(state: &HttpState, uri: &Uri)
crates/llm-access/src/admin.rs:5771
↓ 5 callersFunctionpublish_pending_segment_async
( config: &TieredDuckDbUsageConfig, catalog_backend: &TieredUsageCatalogBackend, pending_path: &Pa
crates/llm-access-store/src/duckdb/segment.rs:343
↓ 5 callersFunctionquery_comment_tasks
( table: &Table, filter: Option<&str>, limit: Option<usize>, )
crates/store/src/comments_store.rs:1315
↓ 5 callersFunctionquery_segment_field_rollups
( conn: &duckdb::Connection, field_name: UsageCatalogFieldName, value_sql: &str, )
crates/llm-access-store/src/duckdb/segment.rs:559
↓ 5 callersFunctionquote_name
(name: str)
skills/kiro-social-onboarder/scripts/onboard_kiro_social_github.py:101
↓ 5 callersMethodrate_limit_reset_credits_available
(&self)
crates/llm-access/src/codex_status.rs:193
↓ 5 callersMethodread_bytes
(&mut self, len: usize)
crates/llm-access-kiro/src/cache_sim/snapshot.rs:219
↓ 5 callersFunctionread_local_media_config_for_test
(vars: &[(&str, &str)])
crates/media-service/src/config.rs:103
↓ 5 callersFunctionrecord_codex_usage
( control_store: &dyn ControlStore, key: &AuthenticatedKey, prepared: &PreparedGatewayRequest,
crates/llm-access/src/provider/codex_sse.rs:287
↓ 5 callersFunctionreload
()
crates/frontend/gpt2api-app/src/components/AdminPanel.tsx:43
↓ 5 callersMethodremember
( &self, affinity_id: &CodexAffinityId, error_class: CodexUpstreamErrorClass,
crates/llm-access/src/provider/codex_session_rejection.rs:67
↓ 5 callersFunctionresolve_codex_client_version
(raw: Option<&str>)
crates/llm-access/src/provider/codex_auth.rs:58
↓ 5 callersFunctionresolve_effective_kiro_cache_policy
( runtime_policy: &KiroCachePolicy, override_json: Option<&str>, )
crates/llm-access-kiro/src/cache_policy.rs:122
↓ 5 callersFunctionresolve_input_tokens_with_threshold
( request_input_tokens: i32, context_input_tokens: Option<i32>, context_usage_min_request_tokens:
crates/llm-access-kiro/src/anthropic/stream/usage.rs:58
↓ 5 callersFunctionresolve_page_limit
Preserve explicit client `limit`, otherwise report the actual payload length.
crates/backend/src/handlers.rs:3735
↓ 5 callersFunctionresolve_request_cache_config
Resolve the optional request-path cache config into the store-layer shape.
crates/llm-access/src/config.rs:56
↓ 5 callersFunctionsample_account_contribution_request
( requester_email: &str, )
crates/llm-access/src/admin.rs:8476
↓ 5 callersMethodsave_admin_kiro_status_cache
( &self, _update: AdminKiroStatusCacheUpdate, )
crates/llm-access-core/src/store/empty.rs:1022
↓ 5 callersFunctionselect_admin_kiro_probe_proxy
( inline_proxy: Option<core_store::ProviderProxyConfig>, proxy_config_proxy: Option<core_store::Provid
crates/llm-access/src/admin.rs:6684
↓ 5 callersFunctionselect_codex_route_with_account_permit
( limiter: &Arc<RequestLimiter>, codex_account_cooldowns: &Arc<CodexAccountCooldowns>, routes: &[P
crates/llm-access/src/provider/route_selection.rs:65
↓ 5 callersMethodshutdown
(&self)
crates/llm-access/src/runtime.rs:1384
↓ 5 callersFunctionsite_base_url
()
crates/backend/src/seo.rs:17
↓ 5 callersFunctionsong_cover_url
(cover: Option<&str>)
crates/frontend/src/api.rs:4635
↓ 5 callersMethodsponsor_requests_table
(&self)
crates/store/src/llm_gateway_store/mod.rs:222
↓ 5 callersMethodstatus_snapshot
Return producer-side journal status.
crates/llm-access/src/usage_journal.rs:66
↓ 5 callersMethodstream_batches
Open a streaming batch reader that validates and decodes one block at a time.
crates/llm-usage-journal/src/reader.rs:103
↓ 5 callersFunctionsubmit_context
( headers: &HeaderMap, guard: &Arc<PublicSubmitGuard>, geoip: &GeoIpResolver, )
crates/llm-access/src/submission.rs:688
↓ 5 callersMethodsubtract_batch
(&self, batch: &UsageRollupBatch)
crates/llm-access/src/runtime.rs:755
↓ 5 callersFunctiontest_usage_event
(event_id: &str)
crates/llm-access/src/usage_journal.rs:403
↓ 5 callersFunctiontiered_compacting_dir
(config: &TieredDuckDbUsageConfig)
crates/llm-access-store/src/duckdb/segment.rs:54
↓ 5 callersFunctiontokenize_text_atoms
(text: &str)
crates/llm-access-kiro/src/cache_sim/projection.rs:557
↓ 5 callersMethodtransaction
(&self)
crates/llm-access-store/src/postgres.rs:277
↓ 5 callersMethodupsert_codex_account
( &self, record: &CodexAccountRecord, )
crates/llm-access-store/src/postgres/codex_account.rs:701
↓ 5 callersFunctionupsert_images
(table: &Table, records: &[ImageRecord])
crates/cli/src/db.rs:245
↓ 5 callersFunctionvalidate_kiro_cache_policy
(policy: &KiroCachePolicy)
crates/store/src/llm_gateway_store/kiro_cache_policy.rs:163
↓ 5 callersFunctionwait_for_usage_event_count
(store: &RecordingControlStore, expected: usize)
crates/llm-access/src/provider/tests.rs:1397
↓ 5 callersMethodwith_tool_results
(mut self, results: Vec<ToolResult>)
crates/llm-access-kiro/src/wire.rs:156
↓ 5 callersMethodwith_tool_uses
(mut self, tool_uses: Vec<ToolUseEntry>)
crates/llm-access-kiro/src/wire.rs:320
↓ 5 callersFunctionwrite_zigzag
Append a zigzag-encoded signed varint.
crates/llm-access-kiro/src/cache_sim/snapshot.rs:285
↓ 4 callersFunctionaccess_token_is_expired
(token: &str)
crates/llm-access/src/codex_refresh.rs:403
↓ 4 callersMethodaccount_auth_key
(&self, provider: &str, account_name: &str)
crates/llm-access-store/src/request_cache.rs:450
↓ 4 callersMethodaccount_contribution_requests_table
(&self)
crates/store/src/llm_gateway_store/mod.rs:212
↓ 4 callersFunctionaccount_name
(account: dict[str, Any])
skills/kiro-social-onboarder/scripts/onboard_kiro_social_github.py:115
↓ 4 callersFunctionaccount_ready_status
( account: &A, checked_at: i64, buckets: &[CodexRateLimitBucket], )
crates/llm-access/src/codex_status.rs:1382
↓ 4 callersFunctionaccount_ready_status_with_reset
( account: &A, checked_at: i64, buckets: &[CodexRateLimitBucket], reset_credits_available: Opt
crates/llm-access/src/codex_status.rs:1395
↓ 4 callersMethodactive_upstream_addr
Resolved socket address for the active upstream slot.
crates/gateway/src/config.rs:127
↓ 4 callersFunctionadapt_codex_upstream_response_from_parts
( parts: CodexUpstreamResponseParts, ctx: CodexCompletedResponseContext, )
crates/llm-access/src/provider/codex_dispatch.rs:1699
↓ 4 callersFunctionadd_codex_upstream_headers
( mut upstream: reqwest::RequestBuilder, request_headers: &HeaderMap, prepared: &PreparedGatewayRe
crates/llm-access/src/provider/codex_auth.rs:285
↓ 4 callersMethodadmin_codex_account_from_record
( &self, record: &CodexAccountRecord, )
crates/llm-access-store/src/postgres/codex_account.rs:693
↓ 4 callersFunctionadmin_group_total_pages
(total: usize, page_size: usize)
crates/frontend/src/pages/admin_llm_gateway.rs:128
↓ 4 callersFunctionadmin_post_task_action
( task_id: &str, action: &str, request: &AdminTaskActionRequest, )
crates/frontend/src/api.rs:4490
↓ 4 callersFunctionadmin_proxy_config_scope_view
(state: &HttpState)
crates/llm-access/src/admin.rs:8403
↓ 4 callersFunctionanthropic_messages_bad_request
(index: usize, message: impl AsRef<str>)
crates/llm-access-codex/src/anthropic_messages.rs:96
↓ 4 callersFunctionanthropic_usage_json_with_policy
( policy: &KiroCachePolicy, input_tokens_total: i32, output_tokens: i32, cache_read_input_toke
crates/llm-access/src/provider/kiro_usage.rs:117
↓ 4 callersFunctionapi_behavior_schema
()
crates/store/src/lancedb_api.rs:2749
↓ 4 callersMethodappend_usage_events
Append one or more usage event rows to the events table (append-only). Does not update the key record; callers maintain usage totals via in-memory rol
crates/store/src/llm_gateway_store/mod.rs:919
↓ 4 callersFunctionapply_cached_codex_status_to_admin_accounts
( mut accounts: Vec<core_store::AdminCodexAccount>, status: Option<core_store::CodexRateLimitStatus>,
crates/llm-access/src/admin.rs:1945
↓ 4 callersFunctionapply_codex_fast_policy
Apply the per-key Codex fast policy to the upstream request body.
crates/llm-access-codex/src/request/policy.rs:46
↓ 4 callersFunctionapply_effective_kiro_cache_policies
( mut keys: Vec<core_store::AdminKey>, config: &AdminRuntimeConfig, )
crates/llm-access/src/admin.rs:6932
↓ 4 callersFunctionapply_kiro_candidate_credit_summaries
( mut keys: Vec<core_store::AdminKey>, accounts: &[core_store::AdminKiroAccount], groups: &[core_s
crates/llm-access/src/admin.rs:6977
↓ 4 callersFunctionapply_upstream_response_headers
Copy selected upstream headers onto the final downstream response.
crates/llm-access-codex/src/response.rs:1449
↓ 4 callersFunctionapply_view_analytics_config_update
( current: ViewAnalyticsRuntimeConfig, request: UpdateViewAnalyticsConfigRequest, )
crates/backend/src/handlers.rs:3886
↓ 4 callersFunctionarchived_segments_for_query
( catalog_backend: &TieredUsageCatalogBackend, query: &UsageEventQuery, )
crates/llm-access-store/src/duckdb/query.rs:297
↓ 4 callersMethodauth_key
(&self, secret_hash: &str)
crates/llm-access-store/src/request_cache.rs:417
↓ 4 callersFunctionbinary_works
(path: &Path)
crates/media-service/src/ffmpeg.rs:55
↓ 4 callersFunctionbuild_anthropic_upstream_client
( proxy: Option<&ProviderProxyConfig>, )
crates/llm-access/src/provider/client.rs:22
↓ 4 callersFunctionbuild_kiro_cache_policy_override_json
( global: &KiroCachePolicyForm, edited: &KiroCachePolicyForm, )
crates/frontend/src/pages/admin_kiro_gateway.rs:487
↓ 4 callersMethodbuild_resume_anchor_hash
(&self, assistant_message: &AssistantMessage)
crates/llm-access-kiro/src/cache_sim/projection.rs:106
↓ 4 callersFunctionbuild_token_page
A page key is the hash of the packed token atom stream. The tree stores only this compact page identity plus token count; it does not retain the origi
crates/llm-access-kiro/src/cache_sim/projection.rs:546
↓ 4 callersFunctionbytes_contains
(haystack: &[u8], needle: &[u8])
crates/llm-access/src/provider/cctest.rs:577
↓ 4 callersFunctioncanonical_anthropic_upstream_pool_mode
Canonicalize a possibly missing direct Anthropic pool mode.
crates/llm-access-core/src/store/anthropic_upstream.rs:43
↓ 4 callersFunctionclamp_page
(page: usize, total_pages: usize)
crates/frontend/src/hooks.rs:119
↓ 4 callersFunctionclickText
(label)
skills/github-password-rotator/scripts/drive_github_password_change.mjs:116
↓ 4 callersFunctioncmp_option_i64_desc
(left: Option<i64>, right: Option<i64>)
crates/llm-access-store/src/duckdb/metrics.rs:52
↓ 4 callersFunctioncodex_account_primary_pct
(account: &AdminCodexAccount)
crates/llm-access-core/src/store/codex_account.rs:191
↓ 4 callersFunctioncodex_account_secondary_pct
(account: &AdminCodexAccount)
crates/llm-access-core/src/store/codex_account.rs:195
↓ 4 callersFunctioncodex_default_instructions
Default Codex system instructions embedded into model catalogs and requests. Return the default Codex system instructions embedded in client payloads.
crates/llm-access-codex/src/instructions.rs:4
↓ 4 callersFunctioncodex_error_disposition
( error: &CodexClassifiedUpstreamError, )
crates/llm-access/src/provider/codex_error_disposition.rs:40
← previousnext →701–800 of 7,843, ranked by callers