MCPcopy Create free account

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

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

⨍ Functions 7,843◇ Types & classes 1,680
↓ 13 callersFunctionnow_ms
()
crates/llm-access-store/src/duckdb/util.rs:27
↓ 13 callersFunctionoptional_string
(value)
skills/approving-llm-gateway-account-batches/scripts/approve_account_contribution_batch.py:81
↓ 13 callersFunctiontest_rollup_backlog
()
crates/llm-access/src/runtime.rs:2563
↓ 12 callersFunctionabsolute_url
(path_or_url: &str)
crates/frontend/src/seo.rs:131
↓ 12 callersFunctionacquire_table_access_file_lock
( lock_path: &std::path::Path, mode: TableAccessMode, )
crates/store/src/optimize.rs:106
↓ 12 callersMethodappend_usage_event
(&self, event: &UsageEvent)
crates/llm-access/src/runtime.rs:2278
↓ 12 callersMethodcanonicalize
Normalize fixed-mode ids and clear ids for non-fixed modes.
crates/llm-access-core/src/proxy.rs:44
↓ 12 callersMethodclient
(&self)
crates/backend/src/media_proxy/mod.rs:32
↓ 12 callersFunctioncompare_match
( radix: &mut PrefixTree, plain: &mut PlainPrefixTree, pages: &[CanonicalTokenPage],
crates/llm-access-kiro/src/cache_sim/prefix_tree.rs:1211
↓ 12 callersFunctionconvert_response_value_to_chat_chunk
Convert one responses stream event into an OpenAI chat chunk when possible.
crates/llm-access-codex/src/response.rs:590
↓ 12 callersFunctiondefault_kiro_pool_strategy
Default serialized Kiro account-pool strategy.
crates/llm-access-core/src/store/mod.rs:279
↓ 12 callersFunctionembed_image_bytes
Generate a semantic embedding for an image (bytes should be an encoded image). Use `embed_image_bytes_with_model` if you need a specific vision model
crates/embedding/src/image.rs:72
↓ 12 callersFunctionensure_table
(db: &Connection, name: &str, schema: Arc<Schema>)
crates/cli/src/db.rs:36
↓ 12 callersFunctionescape_literal
(value: &str)
crates/store/src/interactive_store.rs:952
↓ 12 callersMethodhas_more
Return true when at least one row remains after this page.
crates/llm-access-core/src/store/keys.rs:168
↓ 12 callersFunctioni64_to_u64
(value: i64)
crates/llm-access-store/src/duckdb/util.rs:15
↓ 12 callersMethodinvalidate_account_cache
(&self, provider: &str, account_name: &str)
crates/llm-access-store/src/postgres/cache.rs:221
↓ 12 callersMethodmark_account_cooldown
Mark one Codex account as temporarily unavailable for request routing. The write semantics are deliberately "single-flight-like": once one request ha
crates/llm-access/src/provider/limiter.rs:99
↓ 12 callersMethodmark_failed
(&self, error: impl Into<String>)
crates/media-service/src/jobs.rs:56
↓ 12 callersFunctionnormalize_name
(raw: &str)
crates/llm-access/src/admin.rs:7246
↓ 12 callersFunctionnormalize_required_text
(value: String, max_chars: usize, fallback: &str)
crates/store/src/lancedb_api.rs:3225
↓ 12 callersFunctionoptional_i64_to_i32
(value: Option<i64>)
crates/llm-access/src/usage_query.rs:823
↓ 12 callersMethodread_varint
Read an unsigned LEB128 varint.
crates/llm-access-kiro/src/cache_sim/snapshot.rs:239
↓ 12 callersFunctionsample_bucket
(account_name: &str, primary: f64, secondary: f64)
crates/llm-access/src/codex_status.rs:1652
↓ 12 callersFunctionsample_usage_event
(event_id: &str)
crates/llm-access/src/runtime.rs:2474
↓ 12 callersFunctionselect_kiro_route_with_account_permit
( scheduler: &Arc<KiroRequestScheduler>, routes: &[ProviderKiroRoute], failed_accounts: &HashSet<S
crates/llm-access/src/provider/route_selection.rs:201
↓ 12 callersFunctionsleep
(ms)
skills/kiro-social-onboarder/scripts/drive_kiro_social_google.mjs:13
↓ 12 callersMethodtry_acquire
( self: &Arc<Self>, scope: String, max_concurrency: Option<u64>, min_start_int
crates/llm-access/src/provider/limiter.rs:30
↓ 12 callersFunctionusage_event_column_expr
( columns: &HashSet<String>, column: &'static str, missing_sql: &'static str, )
crates/llm-access-store/src/duckdb/sql.rs:447
↓ 12 callersFunctionvalue_string_opt
(array: &StringArray, row: usize)
crates/store/src/lancedb_api.rs:3135
↓ 12 callersMethodwith_kind
(mut self, kind: KiroRouteFailureKind)
crates/llm-access/src/provider/kiro_error.rs:62
↓ 11 callersFunctionacquire_table_access_file_lock
( table: &str, mode: TableAccessMode, )
crates/store/src/lancedb_api.rs:3292
↓ 11 callersFunctionapi_patch
(url: &str)
crates/frontend/src/api.rs:196
↓ 11 callersMethodappend_usage_event
Append a single usage event row to the events table (append-only).
crates/store/src/llm_gateway_store/mod.rs:940
↓ 11 callersFunctionassert_bytecat_shaped_signature
(signature: &str, expected_model: &str)
crates/llm-access-kiro/src/anthropic/stream/context.rs:1673
↓ 11 callersFunctioncctest_claude_code_system
()
crates/llm-access-kiro/src/anthropic/converter/mod.rs:385
↓ 11 callersFunctionconfigured_media_proxy
( state: &AppState, )
crates/backend/src/media_proxy/handlers.rs:247
↓ 11 callersFunctionconflict_error
(message: &str)
crates/backend/src/handlers.rs:3619
↓ 11 callersFunctiondefault_kiro_cache_policy
()
crates/store/src/llm_gateway_store/kiro_cache_policy.rs:57
↓ 11 callersFunctioninspect_cctest_text_probe
(body: &[u8])
crates/llm-access/src/provider/cctest.rs:161
↓ 11 callersFunctioninternal_error
(err: impl std::fmt::Display)
crates/backend/src/gpt2api_rs.rs:1825
↓ 11 callersMethodjobs
(&self)
crates/media-service/src/state.rs:115
↓ 11 callersMethodload_runtime_config_record_cached
( &self, )
crates/llm-access-store/src/postgres/config.rs:90
↓ 11 callersFunctionmark_codex_transient_request_failure_cooldown
( codex_account_cooldowns: &Arc<CodexAccountCooldowns>, account_name: &str, )
crates/llm-access/src/provider/codex_dispatch.rs:1895
↓ 11 callersMethodmatch_prefix
Count the longest shared full-page prefix already resident in the trie. Matching only counts full pages. Partial-page matches are ignored on purpose
crates/llm-access-kiro/src/cache_sim/prefix_tree.rs:92
↓ 11 callersFunctionmatcher
(keywords: &[&str])
crates/llm-access-core/src/moderation.rs:741
↓ 11 callersFunctionprint_json
(value: &T)
crates/cli/src/commands/api.rs:201
↓ 11 callersFunctionresolve_media_path
(root: &Path, relative: &str)
crates/media-service/src/path_guard.rs:5
↓ 11 callersFunctionsample_admin_account
(name: &str)
crates/llm-access/src/codex_status.rs:1613
↓ 11 callersFunctionsanitize_error
(message: &str)
crates/llm-access/src/anthropic_upstream_probe.rs:437
↓ 11 callersFunctiontotal_rows
(batches: &[RecordBatch])
crates/store/src/llm_gateway_store/codec.rs:2000
↓ 11 callersMethodtry_acquire
Attempts to acquire one account image permit without waiting.
crates/llm-access-codex-image/src/limiter.rs:79
↓ 11 callersMethodwith_client
( &self, purpose: &str, action: impl FnOnce(&mut Client) -> anyhow::Result<T> + Send,
crates/llm-access-store/src/usage_catalog.rs:740
↓ 10 callersFunctionaccount_error_status
( account: &A, checked_at: i64, message: &str, )
crates/llm-access/src/codex_status.rs:1419
↓ 10 callersMethodas_str
(&self)
crates/llm-access-kiro/src/parser/header.rs:62
↓ 10 callersFunctionbase_request
(tools: Option<Vec<Tool>>, content: serde_json::Value)
crates/llm-access-kiro/src/anthropic/websearch.rs:448
↓ 10 callersFunctionclamp_duration_ms
(duration: Duration)
crates/llm-access/src/provider/util.rs:19
↓ 10 callersMethodcurrent_dispatch_generation
(&self, provider: &str)
crates/llm-access-store/src/postgres.rs:661
↓ 10 callersFunctionensure_table
( db: &Connection, table_name: &str, schema: Arc<Schema>, storage_options: &[(&str, &str)], )
crates/store/src/llm_gateway_store/schema.rs:575
↓ 10 callersFunctionextract_header_value
Read one trimmed header value as UTF-8 text. Read one trimmed header value as UTF-8 text.
crates/llm-access-codex/src/request/headers.rs:11
↓ 10 callersFunctionfield
(data: dict[str, Any], *names: str)
skills/kiro-social-onboarder/scripts/onboard_kiro_social_github.py:105
↓ 10 callersMethodget_codex_account_row
( &self, name: &str, )
crates/llm-access-store/src/postgres/codex_account.rs:521
↓ 10 callersFunctionnormalize_metrics_optional_string
(value: Option<String>)
crates/llm-access-store/src/duckdb/metrics.rs:22
↓ 10 callersFunctionnormalize_text
(raw: &str)
crates/llm-access-kiro/src/cache_sim/projection.rs:597
↓ 10 callersFunctionnullable_str
(arr: &StringArray, i: usize)
crates/store/src/article_request_store.rs:939
↓ 10 callersMethodopen_table
(&self, table_name: &str)
crates/store/src/lancedb_api.rs:404
↓ 10 callersFunctionoptional_string_array
(batch: &'a RecordBatch, name: &str)
crates/store/src/lancedb_api.rs:3080
↓ 10 callersFunctionparse_named_sse_json
(chunks: &[axum::body::Bytes], event_name: &str)
crates/llm-access-codex/src/anthropic_messages.rs:1657
↓ 10 callersFunctionparse_runner_output
(stdout: &str)
crates/backend/src/comment_worker.rs:561
↓ 10 callersFunctionproto_bytes_field_encoded_len
(field_number: u32, content_len: usize)
crates/llm-access-kiro/src/anthropic/stream/signature.rs:102
↓ 10 callersMethodprune_expired
Drop every edge whose subtree has not been touched within `ttl`.
crates/llm-access-kiro/src/cache_sim/prefix_tree.rs:162
↓ 10 callersFunctionremove_file_if_exists
(path: &Path)
crates/llm-access-store/src/duckdb/segment.rs:150
↓ 10 callersFunctionreplace_meta_content
( html: &str, attr_name: &str, attr_value: &str, new_content: &str, )
crates/backend/src/seo.rs:93
↓ 10 callersMethodroute_store
(&self)
crates/llm-access/src/provider/state.rs:157
↓ 10 callersMethodsnapshot
Return the latest in-memory cluster snapshot.
crates/llm-access/src/cluster.rs:199
↓ 10 callersMethodsuccess
(tool_use_id: impl Into<String>, content: impl Into<String>)
crates/llm-access-kiro/src/wire.rs:367
↓ 10 callersFunctionsum_bigint_sql
(expr: &str)
crates/llm-access-store/src/usage_catalog.rs:771
↓ 10 callersMethodtasks_table
(&self)
crates/store/src/comments_store.rs:269
↓ 10 callersFunctiontest_state_with_dispatcher
(dispatcher: Arc<dyn ProviderDispatcher>)
crates/llm-access/src/provider/tests.rs:3036
↓ 10 callersFunctiontop_usage_metrics_groups
( groups: &BTreeMap<String, UsageMetricsGroupAccumulator>, limit: usize, mut compare: F, )
crates/llm-access-store/src/duckdb/metrics.rs:520
↓ 10 callersMethodtransition_wish
( &self, wish_id: &str, next_status: &str, admin_note: Option<&str>, f
crates/store/src/music_wish_store.rs:307
↓ 10 callersFunctionts_array
(batch: &'a RecordBatch, column: &str)
crates/store/src/comments_store.rs:1713
↓ 10 callersMethodupdate_progress
Persist the current worker progress row.
crates/llm-usage-journal/src/state.rs:126
↓ 10 callersMethodupsert_runtime_config
Insert or replace the singleton runtime-config row.
crates/store/src/llm_gateway_store/mod.rs:428
↓ 10 callersFunctionvalidate_protected_content
( req: &MessagesRequest, key_id: &str, model: &str, secret: &str, )
crates/llm-access-kiro/src/anthropic/protected_content.rs:32
↓ 10 callersFunctionwait_for_archived_duckdb_file_count
(archive_dir: &std::path::Path, expected: usize)
crates/llm-access-store/src/duckdb/tests.rs:2862
↓ 9 callersFunctionacquire_admin_usage_query_permit
( state: &HttpState, )
crates/llm-access/src/admin.rs:5370
↓ 9 callersMethodappend_audit_log
( &self, input: NewCommentAuditInput, )
crates/store/src/comments_store.rs:629
↓ 9 callersMethodas_storage_str
(self)
crates/llm-access-store/src/usage_catalog.rs:65
↓ 9 callersFunctionbad_request_with_detail
Build a `400 Bad Request` error with structured detail text.
crates/llm-access-codex/src/error.rs:34
↓ 9 callersMethodcache_key_segment
(&self)
crates/llm-access-store/src/postgres.rs:403
↓ 9 callersFunctioncaptured_codex_request
( headers: &HeaderMap, path: String, query: Option<String>, body: serde_json::Value, )
crates/llm-access/src/provider/tests.rs:3956
↓ 9 callersFunctioncctest_tag_request_json
(cch: &str, tag: &str, session_id: &str)
crates/llm-access/src/provider/tests.rs:508
↓ 9 callersFunctionchat_message_bad_request
(index: usize, message: impl AsRef<str>)
crates/llm-access-codex/src/request/chat_completions.rs:309
↓ 9 callersFunctionclassify_codex_upstream_failure
( status: StatusCode, headers: &HeaderMap, bytes: Bytes, )
crates/llm-access/src/provider/codex_upstream_error.rs:61
↓ 9 callersFunctionclear_kiro_upstream_envs
()
crates/llm-access/src/kiro_refresh.rs:1024
↓ 9 callersFunctioncodex_upstream_base_url
()
crates/llm-access/src/provider/codex_auth.rs:49
↓ 9 callersFunctioncolorize
(text: str, style: str, enabled: bool)
skills/codex-session-history/scripts/codex_session_history.py:677
↓ 9 callersMethodconnect
(db_uri: &str)
crates/store/src/music_store.rs:710
↓ 9 callersMethodcreate_guarded_text_delta_events
(&mut self, text: &str)
crates/llm-access-kiro/src/anthropic/stream/context.rs:736
← previousnext →201–300 of 7,843, ranked by callers