MCPcopy Create free account

hub / github.com/AppFlowy-IO/AppFlowy-Cloud / functions

Functions3,042 in github.com/AppFlowy-IO/AppFlowy-Cloud

⨍ Functions 3,042◇ Types & classes 910
↓ 3 callersMethodhttp_client_with_auth_compress
( &self, method: Method, url: &str, )
libs/client-api/src/http.rs:1184
↓ 3 callersMethodindex_pending_collab_one
( &self, pending_collab: UnindexedCollabTask, background: bool, )
libs/indexer/src/scheduler.rs:182
↓ 3 callersMethodinit_sync
Returns bool indicating whether the init sync is queued.
libs/client-api/src/collab_sync/sync_control.rs:113
↓ 3 callersFunctioninsert_into_af_collab
( tx: &mut Transaction<'_, sqlx::Postgres>, uid: &i64, workspace_id: &Uuid, params: &CollabParams, )
libs/database/src/collab/collab_db_ops.rs:46
↓ 3 callersMethodinto_owned
Convert into a owned string.
libs/client-websocket/src/message.rs:170
↓ 3 callersMethodinto_update
(self)
libs/collab-stream/src/model.rs:334
↓ 3 callersMethodis_client_init_sync
(&self)
libs/collab-rt-entity/src/client_message.rs:183
↓ 3 callersMethodis_indexing_enabled
(&self, collab_type: CollabType)
libs/indexer/src/scheduler.rs:118
↓ 3 callersMethodis_timeout
(&self)
libs/client-api/src/ws/state.rs:51
↓ 3 callersFunctionkill_existing_process
(process_identifier: &str)
xtask/src/main.rs:211
↓ 3 callersMethodlease
( &self, stream_key: String, ttl: Duration, )
libs/collab-stream/src/lease.rs:74
↓ 3 callersMethodlist_dir
(&self, dir: &str, limit: usize)
libs/database/src/file/s3_client_impl.rs:479
↓ 3 callersFunctionlocalhost_client_with_device_id
(device_id: &str)
libs/client-api-test/src/client.rs:46
↓ 3 callersMethodmark_as_dirty
(&self, object_id: ObjectId, millis_secs: u64)
services/appflowy-collaborate/src/collab/collab_manager.rs:280
↓ 3 callersFunctionmax_sync_message_size
Get the maximum realtime message size from environment variable or use default. Reads from the `APPFLOWY_REALTIME_MESSAGE_SIZE` environment variable.
libs/collab-rt-entity/src/message.rs:21
↓ 3 callersMethodnext
(&mut self)
libs/infra/src/file_util.rs:92
↓ 3 callersFunctionnotify_user
( import_task: &NotionImportTask, result: Result<(), ImportError>, notifier: Arc<dyn ImportNotifier>,
services/appflowy-worker/src/import_worker/worker.rs:1228
↓ 3 callersMethodpolicy_acts
(&self)
libs/access-control/src/act.rs:8
↓ 3 callersMethodpolicy_subject
(&self)
libs/access-control/src/entity.rs:8
↓ 3 callersMethodpost_realtime_msg
( &self, device_id: &str, msg: client_websocket::Message, )
libs/client-api/src/http_collab.rs:330
↓ 3 callersFunctionprepare_default_document_collab_param
( client_id: ClientID, collab_id: Uuid, )
src/biz/workspace/page_view.rs:297
↓ 3 callersFunctionprepare_new_encoded_database
( view_id: &Uuid, database_id: &Uuid, name: &str, fields: Vec<Field>, rows: Vec<CreateRowParams>,
src/biz/workspace/page_view.rs:346
↓ 3 callersFunctionprivate_space_and_trash_view_ids
( uid: i64, folder: &Folder, )
src/biz/collab/folder_view.rs:20
↓ 3 callersFunctionprocess_and_ack_task
( mut context: TaskContext, import_task: ImportTask, stream_name: &str, group_name: &str, entry_id:
services/appflowy-worker/src/import_worker/worker.rs:417
↓ 3 callersMethodput_user_session
(&self, user_session: &UserSession)
admin_frontend/src/session.rs:55
↓ 3 callersFunctionquick_note_resources_url
(base_url: &str, workspace_id: Uuid)
libs/client-api/src/http_quick_note.rs:10
↓ 3 callersMethodread_exact
(&mut self, dest: &mut [u8])
src/api/util.rs:144
↓ 3 callersMethodrecord_failed_stream_count
(&self, count: u64)
src/biz/chat/metrics.rs:66
↓ 3 callersMethodrecord_gen_embedding_time
(&self, num: u32, millis: u128)
libs/indexer/src/metrics.rs:75
↓ 3 callersMethodrecord_total_stream_count
(&self, count: u64)
src/biz/chat/metrics.rs:62
↓ 3 callersMethodrefresh_token
(&self, reason: &str)
libs/client-api/src/http.rs:1052
↓ 3 callersFunctionremove_workspace
(workspace_id: &str, pg_pool: &PgPool)
services/appflowy-worker/src/import_worker/worker.rs:1217
↓ 3 callersMethodrender
(&self, name: &str, param: &T)
libs/mailer/src/sender.rs:58
↓ 3 callersFunctionretry_api_with_constant_interval
Executes an API operation with retry logic and constant intervals, returning AppResponseError
libs/client-api-test/src/async_utils.rs:94
↓ 3 callersMethodrun
(mut self, object_id: Uuid)
services/appflowy-collaborate/src/group/cmd.rs:68
↓ 3 callersMethodsave_update
( &self, object_id: &ObjectId, message_id: Option<Rid>, update_v1: &[u8], action_source: A
libs/client-api/src/v2/db.rs:241
↓ 3 callersMethodschedule_terminate
Schedules a termination signal for the workspace in 1min. If there was a previous termination handle, it will be canceled.
services/appflowy-collaborate/src/ws2/actors/workspace.rs:328
↓ 3 callersFunctionselect_access_request_by_request_id
( executor: E, request_id: Uuid, )
libs/database/src/access_request.rs:50
↓ 3 callersFunctionselect_all_fragments
(pg: &PgPool, object_id: &Uuid)
tests/sql_test/util.rs:106
↓ 3 callersFunctionselect_chat_rag_ids
( executor: E, chat_id: &str, )
libs/database/src/chat/chat_ops.rs:177
↓ 3 callersFunctionselect_publish_info_for_view_ids
( pg_pool: &PgPool, view_ids: &[Uuid], )
libs/database/src/publish.rs:571
↓ 3 callersFunctionselect_published_data_for_view_id
( pg_pool: &PgPool, view_id: &Uuid, )
libs/database/src/publish.rs:449
↓ 3 callersFunctionselect_template_view_by_id
( executor: E, view_id: Uuid, )
libs/database/src/template.rs:557
↓ 3 callersFunctionselect_templates
( executor: E, category_id: Option<Uuid>, is_featured: Option<bool>, is_new_template: Option<bool>,
libs/database/src/template.rs:702
↓ 3 callersFunctionselect_web_user_from_uid
( pool: &PgPool, uid: i64, )
libs/database/src/user.rs:267
↓ 3 callersFunctionselect_workspace_settings
( executor: E, workspace_id: &Uuid, )
libs/database/src/workspace.rs:1210
↓ 3 callersMethodsend_command_with_metrics
Send a command with metrics tracking
libs/access-control/src/casbin/enforcer_v2.rs:229
↓ 3 callersMethodsend_message
(&self, msg: ClientMessage)
libs/client-api/src/v2/actor.rs:397
↓ 3 callersFunctionsession_id_key
(session_id: &str)
admin_frontend/src/session.rs:24
↓ 3 callersFunctionsession_login
( State(state): State<AppState>, token: GotrueTokenResponse, jar: CookieJar, redirect_to: Option<&str>
admin_frontend/src/web_api.rs:583
↓ 3 callersMethodsettings
(&self)
libs/gotrue/src/api.rs:51
↓ 3 callersFunctionstart_sync
( origin: CollabOrigin, sync_object: &SyncObject, collab: &Collab, sink: &Arc<CollabSink<Sink>>, rea
libs/client-api/src/collab_sync/sync_control.rs:174
↓ 3 callersMethodstatus_channel
(&self)
libs/client-api/src/v2/controller.rs:354
↓ 3 callersMethodstream_answer_v2
( &self, workspace_id: &Uuid, chat_id: &str, question_id: i64, )
libs/client-api/src/http_chat.rs:132
↓ 3 callersMethodsubscribe
Subscribes a new connection to the broadcast group for collaborative activities.
services/appflowy-collaborate/src/group/group_init.rs:433
↓ 3 callersMethodsubscribe_sync_state
(&self)
libs/client-api/src/collab_sync/sync_control.rs:108
↓ 3 callersFunctiontemplate_creator_resource_url
(base_url: &str, creator_id: Uuid)
libs/client-api/src/http_template.rs:30
↓ 3 callersFunctiontemplate_resource_url
(base_url: &str, view_id: Uuid)
libs/client-api/src/http_template.rs:42
↓ 3 callersFunctiontest_document_json
(json_str: &str)
libs/workspace-template/src/tests/getting_started_tests.rs:47
↓ 3 callersMethodthread_name
Sets a custom naming function for threads in the pool. # Arguments `closure` - A function that takes a thread index and returns a thread name.
libs/infra/src/thread_pool.rs:79
↓ 3 callersFunctionto_folder_view_layout
(layout: workspace_dto::ViewLayout)
src/biz/collab/folder_view.rs:505
↓ 3 callersMethodtoken
Only expose this method for testing
libs/client-api/src/http.rs:617
↓ 3 callersMethodtry_update_workspace_member
( &self, workspace_id: &Uuid, other_client: &TestClient, role: AFRole, )
libs/client-api-test/src/test_client.rs:409
↓ 3 callersMethodupdate_access_level_policy
( &self, _uid: &i64, _oid: &Uuid, _level: AFAccessLevel, )
libs/access-control/src/noops/collab.rs:48
↓ 3 callersFunctionupdate_chat_settings
( executor: E, chat_id: &Uuid, params: UpdateChatParams, )
libs/database/src/chat/chat_ops.rs:67
↓ 3 callersFunctionupdate_collab_data_with_timeout
( appflowy_web_metrics: &AppFlowyWebMetrics, update_publisher: &impl CollabUpdatePublisher, user: Realti
src/biz/workspace/page_view.rs:2304
↓ 3 callersMethodupdate_web_collab
( &self, workspace_id: &Uuid, object_id: &Uuid, params: UpdateCollabWebParams, )
libs/client-api/src/http_collab.rs:87
↓ 3 callersFunctionupsert_test_chunks
( pg: &PgPool, workspace_id: &Uuid, doc_id: &Uuid, chunks: Vec<AFCollabEmbeddedChunk>, )
tests/sql_test/util.rs:93
↓ 3 callersFunctionvalue_from_headers
( headers: &'a HeaderMap, keys: &[&str], missing_msg: &str, )
src/api/util.rs:57
↓ 3 callersMethodwait_until_get_embedding
( &self, workspace_id: &Uuid, object_id: &Uuid, )
libs/client-api-test/src/test_client.rs:620
↓ 3 callersMethodwith_password
(mut self, password: T)
libs/shared-entity/src/dto/auth_dto.rs:40
↓ 2 callersFunction_index_then_write_embedding_to_disk
( scheduler: &Arc<IndexerScheduler>, unindexed_collabs: Vec<UnindexedCollab>, )
libs/indexer/src/unindexed_workspace.rs:71
↓ 2 callersMethod_insert_data_with_timestamp
Internal implementation of data insertion with timestamp.
services/appflowy-collaborate/src/collab/cache/mem_cache.rs:440
↓ 2 callersFunctionaccept_workspace_invitation
( access_token: &str, invite_id: &str, appflowy_cloud_base_url: &str, )
admin_frontend/src/ext/api.rs:246
↓ 2 callersFunctionadd_new_database_view_for_workspace_database
( workspace_database: &mut WorkspaceDatabase, database_id: &str, view_id: &Uuid, )
src/biz/workspace/page_view.rs:675
↓ 2 callersFunctionadd_to_view_info
(acc: &mut HashMap<Uuid, PublishViewInfo>, view_infos: &[PublishViewInfo])
src/biz/workspace/publish_dup.rs:1124
↓ 2 callersMethodadmin_list_users
( &self, filter: Option<&str>, )
libs/client-api/src/http.rs:605
↓ 2 callersMethodadmin_update_user
( &self, access_token: &str, user_uuid: &str, admin_user_params: &AdminUserParams, )
libs/gotrue/src/api.rs:216
↓ 2 callersFunctionalex_banker_story
()
tests/collab/util.rs:137
↓ 2 callersMethodapply_permission_updates
Apply permission updates and send WebSocket notification
services/appflowy-collaborate/src/ws2/actors/workspace.rs:887
↓ 2 callersMethodas_update
(&self)
libs/collab-rt-entity/src/client_message.rs:352
↓ 2 callersFunctionasync_embed
( client: &Client<C>, request: CreateEmbeddingRequest, )
libs/indexer/src/vector/open_ai.rs:41
↓ 2 callersMethodasync_embed
( &self, params: CreateEmbeddingRequest, )
libs/indexer/src/vector/embedder.rs:20
↓ 2 callersFunctionattach_request_id
( mut err: AppResponseError, request_id: impl std::fmt::Debug, )
libs/client-api/src/http.rs:1275
↓ 2 callersFunctionavatar_object_key
(file_id: &str)
src/biz/template/ops.rs:388
↓ 2 callersMethodbatch_get_collab_embed_info
( &self, workspace_id: &Uuid, params: Vec<EmbeddedCollabQuery>, )
libs/client-api/src/http_collab.rs:451
↓ 2 callersMethodbatch_insert_raw_data
( &self, items: &[(Uuid, Bytes, MillisSeconds, Option<u64>)], )
services/appflowy-collaborate/src/collab/cache/mem_cache.rs:347
↓ 2 callersFunctionbatch_insert_records
( pg_pool: &PgPool, records: Vec<EmbeddingRecord>, )
libs/indexer/src/scheduler.rs:458
↓ 2 callersMethodbinary
Create a new binary WebSocket message by converting to Vec<u8>.
libs/client-websocket/src/message.rs:24
↓ 2 callersMethodbind_and_cache_collab_ref
Binds a collaboration object to the actor and loads its data if needed. This function sets up the necessary callbacks and observers to handle collabor
libs/client-api/src/v2/actor.rs:147
↓ 2 callersFunctionblocking_brotli_compress
( data: Vec<u8>, quality: u32, buffer_size: usize, )
libs/client-api/src/http.rs:1248
↓ 2 callersFunctionblocking_decompress
(data: Vec<u8>, buffer_size: usize)
src/domain/compression.rs:48
↓ 2 callersFunctionbrotli_compress
( data: Vec<u8>, quality: u32, buffer_size: usize, )
libs/client-api/src/http.rs:1234
↓ 2 callersFunctionbulk_from_redis_value
(v: &Value)
libs/collab-stream/src/model.rs:256
↓ 2 callersMethodbulk_insert_collab
FIXME: this and `batch_insert_collab` duplicate similar logic.
services/appflowy-collaborate/src/collab/cache/disk_cache.rs:330
↓ 2 callersMethodcache_collab
( &self, object_id: Uuid, collab_type: CollabType, encode_collab_data: Bytes, mills_secs:
services/appflowy-collaborate/src/collab/cache/collab_cache.rs:626
↓ 2 callersFunctioncalculate_similarity_and_assert
( test_client: &mut TestClient, workspace_id: Uuid, input: String, expected: &str, threshold: f64,
tests/search/document_search.rs:252
↓ 2 callersMethodcan_perform_action
( &self, workspace_id: &Uuid, uid: &i64, _oid: &Uuid, required_action: Action, )
libs/access-control/src/casbin/collab.rs:118
↓ 2 callersMethodcan_write_collab
( &self, store: &Arc<CollabManager>, object_id: &ObjectId, )
services/appflowy-collaborate/src/ws2/actors/workspace.rs:819
↓ 2 callersFunctioncategory_resources_url
(base_url: &str)
libs/client-api/src/http_template.rs:18
← previousnext →401–500 of 3,042, ranked by callers