MCPcopy Create free account

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

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

↓ 8 callersFunctionsource
(media_type: &str, data: impl Into<String>)
crates/llm-access-kiro/src/anthropic/converter/image.rs:231
↓ 8 callersFunctiontable_policy
(table_name: &str)
crates/cli/src/commands/db_manage.rs:1938
↓ 8 callersMethodtransition_request
( &self, request_id: &str, next_status: &str, admin_note: Option<&str>,
crates/store/src/article_request_store.rs:292
↓ 8 callersFunctionts_col
(batch: &'a RecordBatch, name: &str)
crates/store/src/music_wish_store.rs:910
↓ 8 callersFunctionusage_event_detail_payload_expr
( event_columns: &HashSet<String>, detail_columns: Option<&HashSet<String>>, column: &'static str,
crates/llm-access-store/src/duckdb/sql.rs:465
↓ 8 callersMethodwishes_table
(&self)
crates/store/src/music_wish_store.rs:210
↓ 7 callersMethodaccount_view_key
( &self, provider: &str, account_name: &str, scope: &str, )
crates/llm-access-store/src/request_cache.rs:441
↓ 7 callersFunctionadmin_json
( method: str, base_url: str, path: str, body: dict[str, Any] | None = None, token: str |
skills/kiro-social-onboarder/scripts/onboard_kiro_social_github.py:89
↓ 7 callersFunctionanthropic_json_error
(status: StatusCode, error_type: &str, message: &str)
crates/llm-access/src/provider/errors.rs:145
↓ 7 callersMethodapi_behavior_table
(&self)
crates/store/src/lancedb_api.rs:416
↓ 7 callersMethodappend_events
Append usage events to the active file, flushing blocks as thresholds are reached.
crates/llm-usage-journal/src/writer.rs:104
↓ 7 callersMethodappend_usage_event_rows_owned
Append already-enriched fact rows after removing only in-memory duplicates from the same call.
crates/llm-access-store/src/duckdb/repository.rs:295
↓ 7 callersMethodapply_usage_rollup_owned
(&self, event: UsageEvent)
crates/llm-access/src/runtime.rs:1975
↓ 7 callersFunctionassert_ratio
(actual: Option<f64>, expected: f64)
crates/store/src/llm_gateway_store/kiro_cache_policy.rs:296
↓ 7 callersFunctionauth_json
(access_token: String, refresh_token: Option<&str>)
crates/llm-access/src/codex_refresh.rs:678
↓ 7 callersFunctionbuild_client_fingerprint
Build a stable client fingerprint from IP + User-Agent. This is only used as a fallback key when a trustworthy IP cannot be extracted from forwarding
crates/backend/src/public_submit_guard.rs:27
↓ 7 callersFunctionbuild_submit_rate_limit_key
Build the effective rate-limit key for one public submission. We prefer a normalized IP-based key so retries from the same client are blocked even if
crates/backend/src/public_submit_guard.rs:47
↓ 7 callersMethodcache_dir
(&self)
crates/media-service/src/state.rs:99
↓ 7 callersMethodcan_edit_slot_metadata
(&self)
crates/llm-access-store/src/postgres.rs:411
↓ 7 callersFunctionclamp_u64_to_i64
(value: u64)
crates/llm-access/src/provider/util.rs:13
↓ 7 callersFunctionclickText
(label)
skills/kiro-social-onboarder/scripts/drive_kiro_social_google.mjs:89
↓ 7 callersFunctioncodex_route_with_auth
(auth_json: String)
crates/llm-access/src/codex_refresh.rs:653
↓ 7 callersMethodcomplete_admin_codex_import_job_item
( &self, _job_id: &str, _result: AdminCodexImportJobItemResult, )
crates/llm-access-core/src/store/empty.rs:892
↓ 7 callersMethodconnection
(&self)
crates/llm-access-store/src/request_cache.rs:803
↓ 7 callersFunctionconvert_response_event_to_anthropic_sse_chunks
Convert one responses SSE event into zero or more Anthropic SSE chunks.
crates/llm-access-codex/src/anthropic_messages.rs:1384
↓ 7 callersFunctiondecode_codex_account_settings
(value: &str)
crates/llm-access-store/src/postgres/decode.rs:554
↓ 7 callersFunctiondefault_kiro_billable_model_multipliers_json
Return the default Kiro billable multiplier JSON.
crates/llm-access-core/src/store/config.rs:413
↓ 7 callersFunctionderive_protected_signature_bytes
( model: &str, thinking: &str, key_id: &str, secret: &str, label: &[u8], len: usize, )
crates/llm-access-kiro/src/anthropic/stream/signature.rs:173
↓ 7 callersFunctiondowncast_string
(batch: &'a RecordBatch, column: &str)
crates/cli/src/commands/db_manage.rs:2401
↓ 7 callersFunctioneligible_image_routes
Filter resolved Codex routes to the accounts allowed to serve this image request, enforcing the entrypoint-specific per-key gate first. The two entry
crates/llm-access-codex-image/src/dispatch.rs:45
↓ 7 callersFunctionempty_route_store
()
crates/llm-access/src/provider/tests.rs:1484
↓ 7 callersFunctionenforce_moderation
Enforce the keyword moderation gate for one request, shared by every provider dispatch hook. `extract_text` yields the raw request text to scan; the m
crates/llm-access/src/moderation.rs:425
↓ 7 callersFunctionensure_bytes
(data: &[u8], needed: usize)
crates/llm-access-kiro/src/parser/header.rs:218
↓ 7 callersFunctionensure_context_for_route
( route: &ProviderKiroRoute, store: &dyn ProviderRouteStore, force_refresh: bool, )
crates/llm-access/src/kiro_refresh.rs:74
↓ 7 callersFunctionerror_response
( status: StatusCode, message: impl Into<String>, )
crates/media-service/src/handlers.rs:192
↓ 7 callersFunctionformat_from_source
(source: &ImageSource)
crates/llm-access-kiro/src/anthropic/converter/image.rs:243
↓ 7 callersFunctionformat_json_for_textarea
(raw: &str)
crates/frontend/src/pages/admin_kiro_gateway.rs:217
↓ 7 callersFunctiongenerated_fallback
( reason: SessionFallbackReason, source_name: Option<&'static str>, source_value_preview: Option<S
crates/llm-access-kiro/src/anthropic/converter/session.rs:51
↓ 7 callersMethodget_admin_account_contribution_request_row
( &self, request_id: &str, )
crates/llm-access-store/src/postgres/public.rs:184
↓ 7 callersMethodget_admin_codex_account
( &self, _name: &str, )
crates/llm-access-core/src/store/empty.rs:741
↓ 7 callersMethodget_key_by_id
(&self, key_id: &str)
crates/store/src/llm_gateway_store/mod.rs:764
↓ 7 callersMethodget_or_try_insert_mut
(&mut self, key: K, init: F)
crates/embedding/src/cache.rs:24
↓ 7 callersMethodget_request
(&self, request_id: &str)
crates/store/src/article_request_store.rs:228
↓ 7 callersMethodhandle_content_block_start
( &mut self, index: i32, block_type: &str, data: serde_json::Value, )
crates/llm-access-kiro/src/anthropic/stream/state.rs:108
↓ 7 callersFunctionimage_schema
()
crates/cli/src/schema.rs:103
↓ 7 callersMethodimport_snapshot
Restore simulator state from this node's snapshot plus peer snapshots. Prefix tree: own snapshot wins; otherwise the newest decodable peer seeds it (
crates/llm-access-kiro/src/cache_sim/simulator.rs:294
↓ 7 callersFunctioninitialize_duckdb_target
(conn: &::duckdb::Connection)
crates/llm-access-store/src/lib.rs:76
↓ 7 callersFunctioninitialize_tiered_catalog
(config: &TieredDuckDbUsageConfig)
crates/llm-access-store/src/duckdb.rs:729
↓ 7 callersMethodinsert
Record (or refresh) the conversation id behind an anchor, evicting expired entries first.
crates/llm-access-kiro/src/cache_sim/anchor_index.rs:124
↓ 7 callersFunctioninspect_index_for_column
( table: &Table, column: &str, require_fts: bool, )
crates/store/src/lancedb_api.rs:1825
↓ 7 callersFunctioninterpolate_prefix_tree_cache_ratio
( policy: &KiroCachePolicy, credit_usage: Option<f64>, )
crates/store/src/llm_gateway_store/kiro_cache_policy.rs:133
↓ 7 callersFunctionjoin_internal_url
( media_proxy: &MediaProxyState, relative: &str, )
crates/backend/src/media_proxy/handlers.rs:277
↓ 7 callersFunctionkiro_eventstream_body
(frames: Vec<Vec<u8>>)
crates/llm-access/src/provider/tests.rs:5156
↓ 7 callersMethodload_anthropic_upstream_channel_row
( &self, channel_name: &str, )
crates/llm-access-store/src/postgres/anthropic_upstream.rs:224
↓ 7 callersFunctionlocal_table_access_lock_path
(db_uri: &str, table: &str)
crates/store/src/optimize.rs:464
↓ 7 callersFunctionlocal_table_rewrite_lock_path
(db_uri: &str, table: &str)
crates/store/src/optimize.rs:468
↓ 7 callersFunctionlock_unpoisoned
Lock a mutex, recovering the guard if a previous holder panicked. Every gateway lock guards plain bookkeeping (in-flight counters, the log writer, th
crates/llm-access-codex-image/src/util.rs:21
↓ 7 callersMethodmatch_prefix
Match against the global shared prefix tree. The caller is expected to provide a prompt projection built from the corrected `ConversationState`, not t
crates/llm-access-kiro/src/cache_sim/simulator.rs:67
↓ 7 callersMethodnext_block_index
(&mut self)
crates/llm-access-kiro/src/anthropic/stream/state.rs:69
↓ 7 callersFunctionnormalize_key_patch
( request: PatchLlmGatewayKeyRequest, )
crates/llm-access/src/admin.rs:7117
↓ 7 callersFunctionnormalize_kiro_pool_strategy
Parse one Kiro account-pool strategy into its canonical storage form.
crates/llm-access-core/src/store/mod.rs:284
↓ 7 callersFunctionnormalize_optional_string
(value: &str)
crates/llm-access/src/usage_query.rs:813
↓ 7 callersFunctionnormalize_optional_string
(value: Option<&str>)
crates/llm-access-store/src/duckdb/writer.rs:463
↓ 7 callersFunctionnormalize_top
(top: usize)
crates/backend/src/memory_profiler.rs:960
↓ 7 callersFunctionnow_ms
()
crates/llm-access/src/public.rs:846
↓ 7 callersFunctionnow_ms
()
crates/backend/src/comment_worker.rs:867
↓ 7 callersFunctionobject_u64_field
(map: &Map<String, Value>, key: &str)
crates/llm-access-codex/src/response.rs:180
↓ 7 callersMethodopen_table
(&self, table_name: &str)
crates/store/src/comments_store.rs:261
↓ 7 callersFunctionparts_to_ms
(year: u32, month: u32, day: u32, hour: u32, minute: u32)
crates/frontend/src/components/date_range_picker.rs:47
↓ 7 callersMethodprocess_tool_use
Handles a tool_use event: closes any open thinking block, flushes buffered text, then emits tool_use block start/delta/stop events.
crates/llm-access-kiro/src/anthropic/stream/context.rs:866
↓ 7 callersFunctionprotected_thinking_signature
Build a service-authenticated thinking signature. The output uses the same canonical envelope, while the bytes are derived from a server secret and bo
crates/llm-access-kiro/src/anthropic/stream/signature.rs:293
↓ 7 callersFunctionprune_table_versions
( table: &Table, older_than_hours: i64, delete_unverified: bool, error_if_tagged_old_versions:
crates/store/src/optimize.rs:163
↓ 7 callersFunctionpush_generic_tasks
( tasks: &mut Vec<TableMaintenanceTaskDefinition>, db_label: &'static str, db: MaintenanceDb,
crates/backend/src/table_maintenance.rs:354
↓ 7 callersFunctionpush_sse
(body: &mut String, event: &str, data: &Value)
crates/llm-access/src/provider/cctest.rs:729
↓ 7 callersFunctionrandomized_same_account_retry_delay
( reason: SameAccountRetryReason, retry_after: Option<Duration>, )
crates/llm-access/src/provider/errors.rs:85
↓ 7 callersFunctionread_or_generate_id
Keep a caller-provided id when it is non-empty, otherwise generate a new one.
crates/runtime/src/request_ids.rs:18
↓ 7 callersMethodremember_at
(&self, key_id: &str, session_id: &str, account_name: &str, now: Instant)
crates/llm-access/src/provider/kiro_session_affinity.rs:66
↓ 7 callersFunctionrepair_responses_request
Repair responses-style input items in place before final validation.
crates/llm-access-codex/src/conversation_normalizer.rs:16
↓ 7 callersMethodreplace_snapshot
(&self, snapshot: KiroLatencyRoutingSnapshot)
crates/llm-access/src/kiro_latency.rs:57
↓ 7 callersFunctionrequest_json
( method: str, base_url: str, path: str, token: str | None, body: dict[str, Any] | None =
skills/kiro-local-account-importer/scripts/import_kiro_accounts.py:207
↓ 7 callersMethodrun_one_import
Import one sealed journal file if one is available.
crates/llm-access/src/usage_worker.rs:642
↓ 7 callersFunctionsample_key
()
crates/llm-access/src/moderation.rs:881
↓ 7 callersFunctionsave_context_for_current_page
(page_state: BTreeMap<String, String>)
crates/frontend/src/navigation_context.rs:86
↓ 7 callersFunctionseed_test_key_bundle
(database_url: &str)
crates/llm-access-store/src/postgres.rs:905
↓ 7 callersFunctionsend_json
(request: reqwest::RequestBuilder)
crates/backend/src/media_proxy/handlers.rs:255
↓ 7 callersFunctionserialize_canonical_segment
(segment: &T)
crates/llm-access-kiro/src/cache_sim/projection.rs:643
↓ 7 callersFunctiontest_catalog_backend
( config: &super::TieredDuckDbUsageConfig, )
crates/llm-access-store/src/duckdb/tests.rs:159
↓ 7 callersFunctiontest_state
()
crates/llm-access/src/provider/tests.rs:3032
↓ 7 callersMethodthinking_parser_enabled
(&self)
crates/llm-access-kiro/src/anthropic/stream/context.rs:217
↓ 7 callersMethodtry_acquire
Attempt to reserve one local request slot for `account_name` without blocking. Callers can rotate to another account when this returns [`AccountLocalT
crates/llm-access-kiro/src/scheduler.rs:81
↓ 7 callersMethodusage_events_table
(&self)
crates/store/src/llm_gateway_store/mod.rs:188
↓ 6 callersMethodaccount_groups_table
(&self)
crates/store/src/llm_gateway_store/mod.rs:196
↓ 6 callersFunctionaccumulate_usage_metrics_from_conn
( accumulator: &mut UsageMetricsAccumulator, conn: &duckdb::Connection, query: &UsageMetricsQuery,
crates/llm-access-store/src/duckdb/metrics.rs:605
↓ 6 callersFunctionaddSectionSlide
(actLabel, title, subtitle)
docs/create-pptx.js:66
↓ 6 callersMethodadd_assign
Add another delta for the same key.
crates/llm-access-core/src/store/usage.rs:56
↓ 6 callersMethodadd_batch
(&self, batch: &UsageRollupBatch)
crates/llm-access/src/runtime.rs:739
↓ 6 callersMethodadd_events
(&self, events: &[UsageEvent])
crates/llm-access/src/runtime.rs:717
↓ 6 callersMethodadmin_config_store
Admin config store used by local admin endpoints.
crates/llm-access/src/runtime.rs:514
↓ 6 callersFunctionadmin_page_request
(query: AdminListQuery)
crates/llm-access/src/admin.rs:5272
↓ 6 callersFunctionalign_responses_store_with_upstream
Align the outgoing native responses `store` field with the selected upstream provider semantics.
crates/llm-access-codex/src/request/policy.rs:93
← previousnext →401–500 of 7,843, ranked by callers