MCPcopy Create free account

hub / github.com/WackyGem/Fleur / functions

Functions3,759 in github.com/WackyGem/Fleur

⨍ Functions 3,759◇ Types & classes 842↳ Endpoints 9
↓ 3 callersFunctionpublish_task_payload
( jetstream: &jetstream::Context, config: &NatsConfig, payload: &T, )
engines/crates/rearview-core/src/nats.rs:179
↓ 3 callersMethodquery_analysis_quote_rows
( &self, security_code: &str, start_date: Option<NaiveDate>, end_date: NaiveDa
engines/crates/rearview-core/src/clickhouse/mod.rs:1125
↓ 3 callersMethodquery_latest_date_sql
( &self, sql: &str, query_id: &str, )
engines/crates/rearview-core/src/clickhouse/mod.rs:1079
↓ 3 callersMethodquery_portfolio_price_bars
( &self, security_codes: &[String], start_date: NaiveDate, end_date: NaiveDate
engines/crates/rearview-core/src/clickhouse/mod.rs:1387
↓ 3 callersMethodquery_strategy_backtest_closed_trades
( &self, filter: &crate::postgres::PortfolioClosedTradeFilter, result_attempt_id: &str
engines/crates/rearview-core/src/clickhouse/mod.rs:2465
↓ 3 callersMethodquery_strategy_backtest_positions
( &self, filter: &crate::postgres::PortfolioPositionFilter, result_attempt_id: &str,
engines/crates/rearview-core/src/clickhouse/mod.rs:2113
↓ 3 callersMethodquery_strategy_backtest_trades
( &self, filter: &crate::postgres::PortfolioTradeFilter, result_attempt_id: &str,
engines/crates/rearview-core/src/clickhouse/mod.rs:1953
↓ 3 callersMethodquery_strategy_portfolio_live_targets
( &self, filter: &crate::postgres::PortfolioTargetFilter, result_attempt_id: &str,
engines/crates/rearview-core/src/clickhouse/mod.rs:1719
↓ 3 callersFunctionquote_identifier
(identifier: str)
scripts/strategy_backtest_fact_snapshot.py:189
↓ 3 callersFunctionquote_select_columns
()
engines/crates/rearview-core/src/clickhouse/mod.rs:3849
↓ 3 callersFunctionraw_table_contracts
( contracts: Sequence[DatasetContract], )
pipeline/contract_tools/src/fleur_contracts/adapters/clickhouse.py:77
↓ 3 callersFunctionreadBoolean
(value: JsonValue | undefined)
app/racingline/src/features/strategy/config-display.ts:676
↓ 3 callersFunctionreadFilterExpr
(value: JsonValue | undefined)
app/racingline/src/features/strategy/config-display.ts:568
↓ 3 callersFunctionreadRuleVersionSpec
(value: JsonValue)
app/racingline/src/features/strategy/config-display.ts:123
↓ 3 callersFunctionreadStringArray
(value: JsonValue | undefined)
app/racingline/src/features/strategy/config-display.ts:661
↓ 3 callersMethodread_bit
(self)
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:90
↓ 3 callersMethodread_latest_snapshot
(self, location: DatasetLocation)
pipeline/scheduler/src/scheduler/defs/storage/dataset_service.py:43
↓ 3 callersFunctionread_pct
(rule: &Value, key: &str)
engines/crates/rearview-portfolio-worker/src/main.rs:1622
↓ 3 callersFunctionread_str
(rule: &'a Value, key: &str)
engines/crates/rearview-portfolio-worker/src/main.rs:1637
↓ 3 callersMethodrecord
(self, row: Mapping[str, object])
pipeline/scheduler/src/scheduler/defs/http/pagination.py:13
↓ 3 callersMethodrepository
(self)
pipeline/scheduler/src/scheduler/defs/resources/database.py:15
↓ 3 callersMethodrequest
(self, payload: bytes, timeout_seconds: float)
pipeline/scheduler/src/scheduler/defs/baostock/client.py:50
↓ 3 callersMethodrequest_json_object
(self, request: HttpRequest)
pipeline/scheduler/tests/fakes/http.py:99
↓ 3 callersFunctionrun_bounded_ocr_batch
( items: Sequence[T], *, max_concurrent_requests: int, process_item: Callable[[T], Awaitable[N
pipeline/scheduler/src/scheduler/defs/ocr/service.py:15
↓ 3 callersFunctionsample_output
()
engines/crates/rearview-core/src/clickhouse/portfolio_write.rs:386
↓ 3 callersFunctionsample_run
()
engines/crates/rearview-core/src/clickhouse/portfolio_write.rs:364
↓ 3 callersMethodset_row_count
(&mut self, name: &str, count: usize)
engines/crates/rearview-portfolio-worker/src/main.rs:1506
↓ 3 callersFunctionsimulate_portfolio_with_diagnostics
( input: &PortfolioSimulationInput, )
engines/crates/rearview-core/src/portfolio/mod.rs:343
↓ 3 callersFunctionsource_schema_hash
(contract: DatasetContract)
pipeline/contract_tools/src/fleur_contracts/loader.py:61
↓ 3 callersMethodstatus
(self)
pipeline/scheduler/src/scheduler/defs/http/protocols.py:68
↓ 3 callersFunctionstrategyPortfolioArchiveErrorMessage
(error: unknown)
app/racingline/src/routes/strategy-detail-utils.ts:7
↓ 3 callersFunctionstrategy_backtest_run_from_row
(row: &sqlx::postgres::PgRow)
engines/crates/rearview-core/src/postgres/mod.rs:3952
↓ 3 callersFunctionstrategy_backtest_run_response
( record: StrategyBacktestRunRecord, )
engines/crates/rearview-core/src/api/mod.rs:6170
↓ 3 callersFunctionstrategy_portfolio_record
(pending_buy_signal_snapshot: Value)
engines/crates/rearview-core/src/api/mod.rs:8564
↓ 3 callersMethodsubmit_step
Submit or execute a planned materialization step and return its terminal result.
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:260
↓ 3 callersFunctionsymbol_where_clause
(symbols: &[String], all_symbols_requested: bool)
engines/crates/furnace-io/src/sql.rs:1
↓ 3 callersFunctionsymbol_where_clause_for_column
( column: &str, symbols: &[String], all_symbols_requested: bool, )
engines/crates/furnace-io/src/sql.rs:5
↓ 3 callersFunctionths_limit_up_pool_to_table
( pages: Sequence[Mapping[str, object]], )
pipeline/scheduler/src/scheduler/defs/http/schemas.py:116
↓ 3 callersFunctiontoBoundedNumber
(value: string, min?: number, max?: number)
app/racingline/src/features/strategy/components/simulation-position-panel.tsx:1271
↓ 3 callersFunctiontoFilterExpr
( node: BuiltFilterNode, path: string, conditionPaths: ConditionFilterPath[] )
app/racingline/src/features/strategy/adapters.ts:776
↓ 3 callersFunctionto_json_each_row_with_run_id_field
Serialize rows after replacing the legacy `portfolio_run_id` JSON field with the concrete family identity field used by split result tables.
engines/crates/rearview-core/src/clickhouse/portfolio_write.rs:326
↓ 3 callersFunctiontrade_calendar_dates_to_table
(trade_dates: TradeCalendarDates)
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:300
↓ 3 callersFunctiontrade_date_partition_keys_for_year
( year: int, *, trade_dates: set[date], refresh_until_trade_date: date | None = None, )
pipeline/scheduler/src/scheduler/defs/market/trade_calendar.py:18
↓ 3 callersMethodtrade_dates
(&self)
engines/crates/rearview-core/src/portfolio/mod.rs:932
↓ 3 callersFunctionvalidateCrossingMetric
( metric: MetricDefinition, conditionId: string | undefined )
app/racingline/src/features/strategy/adapters.ts:716
↓ 3 callersFunctionvalidate_source_tenor
(source_tenor: &str)
engines/crates/rearview-core/src/clickhouse/mod.rs:3479
↓ 3 callersFunctionvalidate_strategy_portfolio_patch_status
(status: &str)
engines/crates/rearview-core/src/api/mod.rs:6625
↓ 3 callersFunctionvirtual_account_nav_row
( trade_date: &str, total_equity: f64, daily_return: Option<f64>, )
engines/crates/rearview-core/src/clickhouse/mod.rs:4532
↓ 3 callersFunctionvirtual_account_record
( latest_nav: &VirtualAccountNavRow, previous_nav: Option<&VirtualAccountNavRow>, holding_unrealiz
engines/crates/rearview-core/src/clickhouse/mod.rs:3583
↓ 3 callersFunctionwait_for_outbox_signal
(notifier: &Notify, idle_sleep: Duration)
engines/crates/rearview-server/src/main.rs:170
↓ 3 callersMethodwrite_ocr_result_table
(self, image_filename: str, table: pa.Table)
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/image_object_store.py:27
↓ 2 callersFunction_action_field_compacted_table
(rows: list[dict[str, object]])
pipeline/scheduler/tests/unit/compacted/test_action_field_compact.py:493
↓ 2 callersFunction_active_parts
(client: ClickHouseMigrationClient, database: str, table: str)
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1383
↓ 2 callersFunction_assets_by_key
(assets: Iterable[dg.AssetsDefinition])
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:1025
↓ 2 callersMethod_base_dir
(self, location: DatasetLocation)
pipeline/scheduler/src/scheduler/defs/storage/dataset_service.py:186
↓ 2 callersFunction_base_url_host
(base_url: str)
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/workflows.py:277
↓ 2 callersMethod_config
(self)
pipeline/scheduler/src/scheduler/defs/io_managers/s3_io_manager.py:166
↓ 2 callersFunction_daily_nav_liquidation_metadata
( *, target_trade_date: str, settlement_target: dict[str, Any], response: dict[str, Any],
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:340
↓ 2 callersFunction_dedupe
(values: Iterable[str])
pipeline/scheduler/src/scheduler/defs/automation/source_raw_backfill.py:994
↓ 2 callersMethod_discard_connection
(self, connection: BaostockTcpConnection)
pipeline/scheduler/src/scheduler/defs/baostock/client.py:506
↓ 2 callersFunction_download_status_from_row
(row: DatabaseRow, field_name: str)
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:583
↓ 2 callersMethod_drop_staging
(self, spec: ClickHouseRawTableSpec)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:181
↓ 2 callersMethod_ensure_connection_logged_in
( self, connection: BaostockTcpConnection, *, force: bool = False, )
pipeline/scheduler/src/scheduler/defs/baostock/client.py:429
↓ 2 callersMethod_ensure_started
(self)
pipeline/scheduler/src/scheduler/defs/baostock/client.py:240
↓ 2 callersFunction_example_0051_live_run_metadata
( *, ensure_response: dict[str, Any], daily_run_response: dict[str, Any], settlement_target: d
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:285
↓ 2 callersFunction_execute_serial_commands
( commands: Sequence[MigrationCommand], *, command_runner: Any, )
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:454
↓ 2 callersFunction_failure_context
(slack: object | None = None)
pipeline/scheduler/tests/unit/automation/test_slack_alerts.py:161
↓ 2 callersFunction_fetch_one_daily_k_table
( client: BaostockClientProtocol, code: str, start_date: date, end_date: date, )
pipeline/scheduler/src/scheduler/defs/baostock/services.py:349
↓ 2 callersFunction_first_row
(result: ClickHouseQueryResult)
pipeline/scheduler/src/scheduler/defs/clickhouse/raw_sync.py:289
↓ 2 callersMethod_flag_at
(self, flags: tuple[bool, ...], index: int)
pipeline/scheduler/src/scheduler/defs/sources/sina/trade_calendar.py:172
↓ 2 callersFunction_flat_model_asset_key
(dbt_resource_props: Mapping[str, Any])
pipeline/scheduler/src/scheduler/components/fleur_dbt.py:34
↓ 2 callersFunction_format_sequence
(values: Sequence[str])
pipeline/scheduler/src/scheduler/defs/automation/slack_alerts.py:110
↓ 2 callersFunction_git_head
()
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1463
↓ 2 callersFunction_has_failed_result
(results: Sequence[MigrationStepResult])
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:532
↓ 2 callersFunction_headers_from_value
(headers: Mapping[str, str] | HeaderFactory)
pipeline/scheduler/src/scheduler/defs/http/client.py:347
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0006_create_portfolio_metric_config.py:19
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0010_strategy_portfolio_example_source.py:19
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0002_create_rearview_schema.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0003_create_rearview_portfolio_schema.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0008_create_strategy_portfolio_control_plane.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0007_create_strategy_backtest_control_plane.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0004_add_current_result_attempt.py:19
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0009_strategy_portfolio_publish_context.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/rearview/0005_drop_portfolio_pg_result_facts.py:20
↓ 2 callersFunction_is_active_target
()
pipeline/migrate/versions/pipeline/0001_create_jiuyan_industry_images.py:19
↓ 2 callersFunction_is_failed_daily_run_status
(run_status: str)
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:256
↓ 2 callersFunction_is_string_type
(data_type: str)
pipeline/elt/scripts/profile_raw_source.py:766
↓ 2 callersFunction_k_history_metadata
( *, candidate_security_count: int, selected_security_count: int, skipped_security_count: int,
pipeline/scheduler/src/scheduler/defs/baostock/services.py:503
↓ 2 callersFunction_kline_runner_metadata
( runner_result: BoundedTaskResult[pa.Table], )
pipeline/scheduler/src/scheduler/defs/baostock/services.py:393
↓ 2 callersFunction_latest_status_by_trade_date
(statuses: dict[str, dict[str, Any]])
pipeline/scheduler/src/scheduler/defs/rearview/assets.py:417
↓ 2 callersFunction_load_yaml
(path: Path)
pipeline/contract_tools/src/fleur_contracts/loader.py:79
↓ 2 callersFunction_load_yaml
(path: Path)
pipeline/elt/scripts/validate_field_glossary.py:516
↓ 2 callersMethod_login_payload
(self)
pipeline/scheduler/src/scheduler/defs/baostock/client.py:458
↓ 2 callersFunction_low_cardinality_inner_type
(clickhouse_type: str)
pipeline/contract_tools/src/fleur_contracts/clickhouse_types.py:47
↓ 2 callersFunction_manifest_missing_objects
(manifest: Mapping[str, object])
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:557
↓ 2 callersFunction_missing_objects
(s3: Any, bucket: str, object_keys: Sequence[str])
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1334
↓ 2 callersFunction_normalize_theme_path_text
(value: str)
pipeline/scheduler/src/scheduler/defs/sources/jiuyan/ocr_schema.py:144
↓ 2 callersFunction_object_manifest_entry
(s3: Any, bucket: str, object_key: str)
pipeline/contract_tools/src/fleur_contracts/clickhouse_layer_migration.py:1313
↓ 2 callersFunction_ocr_status_from_row
(row: DatabaseRow, field_name: str)
pipeline/scheduler/src/scheduler/defs/repositories/industry_images.py:597
↓ 2 callersFunction_op_config_json
(op_name: str, config: dict[str, object])
pipeline/scheduler/src/scheduler/defs/baostock/backfill_controller.py:235
← previousnext →601–700 of 3,759, ranked by callers