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
↓ 2 callersFunctionreplaying_updates
( encoding: EncoderVersion, object_id: Uuid, collab_type: CollabType, mut encoded_collab: Option<Encod
services/appflowy-collaborate/src/collab/cache/collab_cache.rs:764
↓ 2 callersMethodrestore_workspace_page_view_from_trash
( &self, workspace_id: Uuid, view_id: &Uuid, )
libs/client-api/src/http_view.rs:105
↓ 2 callersMethodretriable
(&self)
libs/client-api/src/v2/controller.rs:248
↓ 2 callersFunctionretry_later
(weak_notifier: Weak<watch::Sender<SinkSignal>>)
libs/client-api/src/collab_sync/collab_sink.rs:456
↓ 2 callersFunctionrouter
()
admin_frontend/src/web_api.rs:34
↓ 2 callersFunctionrun_import_worker
( pg_pool: PgPool, mut redis_client: ConnectionManager, metrics: Option<Arc<ImportMetrics>>, s3_client
services/appflowy-worker/src/import_worker/worker.rs:74
↓ 2 callersFunctionselect_all_published_collab_info
( pg_pool: &PgPool, workspace_id: &Uuid, )
libs/database/src/publish.rs:622
↓ 2 callersFunctionselect_all_user_workspaces
( executor: E, user_uuid: &Uuid, )
libs/database/src/workspace.rs:840
↓ 2 callersFunctionselect_chat
( executor: E, chat_id: &str, )
libs/database/src/chat/chat_ops.rs:152
↓ 2 callersFunctionselect_collab_meta_from_af_collab
( conn: E, object_id: &Uuid, collab_type: &CollabType, )
libs/database/src/collab/collab_db_ops.rs:258
↓ 2 callersFunctionselect_import_task
( pg_pool: &PgPool, task_id: &Uuid, )
libs/database/src/workspace.rs:1512
↓ 2 callersFunctionselect_most_recent_non_original_namespace
( pg_pool: &PgPool, namespace: &str, )
libs/database/src/publish.rs:550
↓ 2 callersFunctionselect_name_and_email_from_uuid
( pool: &PgPool, user_uuid: &Uuid, )
libs/database/src/user.rs:251
↓ 2 callersFunctionselect_publish_collab_meta
( executor: E, publish_namespace: &str, publish_name: &str, )
libs/database/src/publish.rs:314
↓ 2 callersFunctionselect_published_collab_blob
( executor: E, publish_namespace: &str, publish_name: &str, )
libs/database/src/publish.rs:489
↓ 2 callersFunctionselect_published_metadata_for_view_id
( pg_pool: &PgPool, view_id: &Uuid, )
libs/database/src/publish.rs:431
↓ 2 callersFunctionselect_uid_from_email
( executor: E, email: &str, )
libs/database/src/user.rs:172
↓ 2 callersFunctionselect_user_profile
( executor: E, user_uuid: &Uuid, )
libs/database/src/workspace.rs:653
↓ 2 callersFunctionselect_workspace_member
( executor: E, uid: i64, workspace_id: &Uuid, )
libs/database/src/workspace.rs:569
↓ 2 callersFunctionselect_workspace_member_list_exclude_guest
( pg_pool: &PgPool, workspace_id: &uuid::Uuid, )
libs/database/src/workspace.rs:540
↓ 2 callersFunctionselect_workspace_with_count_and_role
( executor: E, workspace_id: &Uuid, uid: i64, )
libs/database/src/workspace.rs:725
↓ 2 callersMethodsend_batch_collab_request
( &self, method: Method, workspace_id: &Uuid, params: Vec<QueryCollab>, )
libs/client-api/src/http_collab.rs:129
↓ 2 callersFunctionsend_magic_link
( State(state): State<AppState>, email: &str, )
admin_frontend/src/web_api.rs:623
↓ 2 callersMethodset_disconnected
(&self, reason: DisconnectedReason)
libs/client-api/src/v2/conn_retry.rs:230
↓ 2 callersFunctionset_published_collabs_as_unpublished
( executor: E, workspace_id: &Uuid, view_ids: &[Uuid], )
libs/database/src/publish.rs:337
↓ 2 callersMethodset_receive_message
(&self, enabled: bool)
libs/client-api-test/src/workspace_ops.rs:129
↓ 2 callersFunctionsetup_headers
(key: &str, value: &str)
src/api/util.rs:227
↓ 2 callersMethodsign_out
(&self)
libs/client-api/src/http.rs:935
↓ 2 callersMethodsink
Use to send message to server via WebSocket.
libs/client-api/src/ws/handler.rs:49
↓ 2 callersMethodsink
( &self, workspace_id: &Uuid, object_id: &Uuid, )
libs/collab-stream/src/awareness_gossip.rs:104
↓ 2 callersMethodsize
(&self)
libs/collab-rt-entity/src/client_message.rs:54
↓ 2 callersMethodsnapshot_workspace
( &self, workspace_id: WorkspaceId, mut up_to: Rid, )
services/appflowy-collaborate/src/collab/collab_manager.rs:315
↓ 2 callersFunctionspawn_pg_write_embeddings
( mut rx: UnboundedReceiver<EmbeddingRecord>, pg_pool: PgPool, metrics: Arc<EmbeddingMetrics>, latest_
libs/indexer/src/scheduler.rs:411
↓ 2 callersFunctionspawn_server
(command: &str, args: &[&str], name: &str)
xtask/src/main.rs:202
↓ 2 callersMethodsplit_messages_by_object_id
Convert RealtimeMessage to ClientCollabMessage If the message is not a collab message, it will return an empty vec If the message is a collab message,
libs/collab-rt-entity/src/message.rs:75
↓ 2 callersFunctionstart_connect
( request: &HttpRequest, payload: Payload, state: &Data<AppState>, jwt_secret: &Data<Secret<String>>,
src/api/ws.rs:164
↓ 2 callersMethodstream
Use to receive message from server via WebSocket.
libs/client-api/src/ws/handler.rs:64
↓ 2 callersMethodstream_answer_v3
( &self, workspace_id: &Uuid, query: ChatQuestionQuery, chat_model: Option<String>, )
libs/client-api/src/http_chat.rs:162
↓ 2 callersMethodstream_completion_v2
( &self, workspace_id: &Uuid, params: CompleteTextParams, ai_model: Option<String>, )
libs/client-api/src/http_ai.rs:31
↓ 2 callersMethodstream_question_v3
( &self, model: &str, question: ChatQuestion, timeout_secs: Option<u64>, )
libs/appflowy-ai-client/src/client.rs:241
↓ 2 callersMethodsubscribe
Subscribe to token state change Receiver will receive `TokenState::Refresh` when the token is refreshed Receiver will receive `TokenState::Invalid` wh
libs/client-api/src/notify.rs:93
↓ 2 callersMethodsubscribe_collab
Return a [WebSocketChannel] that can be used to send messages to the websocket. Caller should keep the channel alive as long as it wants to receive me
libs/client-api/src/ws/client.rs:346
↓ 2 callersMethodsubscribe_group
( &self, user: &RealtimeUser, object_id: Uuid, collab_origin: &CollabOrigin, )
services/appflowy-collaborate/src/group/cmd.rs:280
↓ 2 callersMethodsubscribe_group_with_message
( &self, user: &RealtimeUser, collab_message: &ClientCollabMessage, )
services/appflowy-collaborate/src/group/cmd.rs:270
↓ 2 callersMethodsubscribe_user_change
(&self, uid: i64)
src/biz/pg_listener.rs:16
↓ 2 callersFunctionsummarize_documents
( client: &Client<C>, question: &str, model_name: &str, documents: Vec<LLMDocument>, only_context: b
libs/llm-client/src/chat.rs:156
↓ 2 callersMethodsummarize_row
( &self, params: SummarizeRowParams, )
libs/client-api/src/http_ai.rs:52
↓ 2 callersFunctiontemplate_creator_resources_url
(base_url: &str)
libs/client-api/src/http_template.rs:26
↓ 2 callersFunctiontemplate_resources_url
(base_url: &str)
libs/client-api/src/http_template.rs:38
↓ 2 callersFunctiontest_concurrent_update_policy_operations_with_count
Helper function to test concurrent update operations with configurable count
libs/access-control/src/casbin/enforcer.rs:692
↓ 2 callersFunctiontest_enforcer_v2
()
libs/access-control/src/casbin/util.rs:28
↓ 2 callersMethodto_bytes
(&self)
libs/database-entity/src/dto.rs:83
↓ 2 callersFunctionto_dto_folder_view_miminal
(collab_folder_view: &collab_folder::View)
src/biz/collab/folder_view.rs:481
↓ 2 callersFunctionto_folder_view_icon
(icon: workspace_dto::ViewIcon)
src/biz/collab/folder_view.rs:490
↓ 2 callersMethodto_policy
(&self)
libs/access-control/src/request.rs:22
↓ 2 callersMethodto_protobuf_bytes
(&self)
libs/database-entity/src/dto.rs:178
↓ 2 callersMethodunpublish_collabs
( &self, workspace_id: &Uuid, view_ids: &[Uuid], user_uuid: &Uuid, )
src/biz/workspace/publish.rs:400
↓ 2 callersMethodunset
(&mut self)
libs/client-api/src/notify.rs:82
↓ 2 callersFunctionupdate_import_task_status
Update import task status 0 => Pending, 1 => Completed, 2 => Failed, 3 => Expire,
libs/database/src/workspace.rs:1579
↓ 2 callersFunctionupdate_page_collab_data
( state: &AppState, user: RealtimeUser, workspace_id: Uuid, object_id: Uuid, collab_type: CollabType
src/biz/workspace/page_view.rs:2347
↓ 2 callersFunctionupdate_page_icon
( state: &AppState, user: RealtimeUser, workspace_id: Uuid, view_id: &str, icon: Option<&ViewIcon>,
src/biz/workspace/page_view.rs:1568
↓ 2 callersMethodupdate_quick_note
( &self, workspace_id: Uuid, quick_note_id: Uuid, data: serde_json::Value, )
libs/client-api/src/http_quick_note.rs:57
↓ 2 callersMethodupdate_workspace_member
( &self, workspace_id: &Uuid, changeset: WorkspaceMemberChangeset, )
libs/client-api/src/http_member.rs:122
↓ 2 callersMethodupdate_workspace_settings
( &self, workspace_id: T, changes: &AFWorkspaceSettingsChange, )
libs/client-api/src/http_settings.rs:30
↓ 2 callersMethodupsert_collab
( &self, workspace_id: &Uuid, uid: &i64, params: CollabParams, )
services/appflowy-collaborate/src/collab/cache/disk_cache.rs:68
↓ 2 callersFunctionupsert_collab_embeddings
( transaction: &mut Transaction<'_, Postgres>, workspace_id: &Uuid, object_id: &Uuid, tokens_used: u32
libs/database/src/index/collab_embeddings_ops.rs:95
↓ 2 callersFunctionupsert_workspace_member_with_txn
( txn: &mut Transaction<'_, sqlx::Postgres>, workspace_id: &uuid::Uuid, member_email: &str, role: AFRo
libs/database/src/workspace.rs:216
↓ 2 callersFunctionurl_missing_param
(param: &str)
libs/client-api/src/http.rs:1229
↓ 2 callersFunctionuser_awareness_object_id
(user_uuid: &Uuid, workspace_id: &Uuid)
libs/client-api-entity/src/id.rs:3
↓ 2 callersFunctionvalidate_encode_collab
( object_id: &Uuid, data: &[u8], collab_type: &CollabType, )
libs/collab-rt-protocol/src/data_validation.rs:28
↓ 2 callersMethodverify
( &self, verify_params: &VerifyParams, )
libs/gotrue/src/api.rs:96
↓ 2 callersFunctionverify_token_cloud
( access_token: &str, appflowy_cloud_base_url: &str, )
admin_frontend/src/ext/api.rs:266
↓ 2 callersFunctionview_info_by_view_id
(meta: &PublishViewMetaData)
src/biz/workspace/publish_dup.rs:1116
↓ 2 callersMethodwait_for_generation
Wait for a specific generation to be processed
libs/access-control/src/casbin/enforcer_v2.rs:478
↓ 2 callersFunctionwait_for_readiness
(process_name: &str)
xtask/src/main.rs:235
↓ 2 callersMethodwait_unit_get_search_result
( &self, workspace_id: &Uuid, query: &str, limit: u32, preview: u32, score_limit: Opti
libs/client-api-test/src/test_client.rs:644
↓ 2 callersFunctionwait_until_num_import_task_complete
(client: &TestClient, num: usize)
tests/workspace/import_test.rs:251
↓ 2 callersMethodweb_api_oauth_redirect
( &mut self, oauth_redirect: &OAuthRedirect, )
admin_frontend/tests/utils/mod.rs:53
↓ 2 callersMethodweb_api_oauth_redirect_token
( &mut self, oauth_redirect: &OAuthRedirectToken, )
admin_frontend/tests/utils/mod.rs:75
↓ 2 callersMethodwith_code
(mut self, code: ErrorCode)
libs/shared-entity/src/response.rs:93
↓ 2 callersMethodwith_email
(mut self, email: T)
libs/shared-entity/src/dto/auth_dto.rs:48
↓ 2 callersMethodwith_payload
(mut self, payload: T)
libs/collab-rt-entity/src/server_message.rs:182
↓ 2 callersMethodwith_role
(mut self, role: T)
libs/shared-entity/src/dto/workspace_dto.rs:85
↓ 2 callersMethodwith_templates
(mut self, templates: Vec<T>)
libs/workspace-template/src/lib.rs:84
↓ 2 callersFunctionwrite_to_database_row
( db_body: &DatabaseBody, db_row_txn: &mut yrs::TransactionMut<'_>, db_row_body: &DatabaseRowBody, cel
src/biz/collab/utils.rs:422
↓ 2 callersMethodws_sink
(&self)
libs/client-api/src/v2/actor.rs:1112
↓ 1 callersFunction_cosine_relevance_score_fn
Converts cosine distance to a relevance score. Distance: Represents the raw vector distance between the query embedding and the document embedding Use
libs/database/src/index/search_ops.rs:111
↓ 1 callersFunction_create_embeddings
( embedder: AFEmbedder, indexer_provider: &Arc<IndexerProvider>, unindexed_records: Vec<UnindexedCollab>
libs/indexer/src/unindexed_workspace.rs:174
↓ 1 callersFunctionaccept_workspace_invite
( pg_pool: &PgPool, workspace_access_control: Arc<dyn WorkspaceAccessControl>, user_uid: i64, user_uui
src/biz/workspace/ops.rs:325
↓ 1 callersFunctionaccess_request_scope
()
src/api/access_request.rs:25
↓ 1 callersFunctionack_task
Acknowledges a task in a Redis stream and optionally removes it from the stream. It is used to acknowledge the processing of a task in a Redis stream
libs/indexer/src/queue.rs:112
↓ 1 callersMethodacquire_workspace_lock
Acquires a distributed lock for workspace snapshotting
services/appflowy-collaborate/src/collab/collab_manager.rs:391
↓ 1 callersFunctionactix_cors_scope
()
src/application.rs:554
↓ 1 callersFunctionadd_background_embed_task
Adds a list of tasks to the Redis stream. This function pushes a batch of `EmbedderTask` items into the Redis stream for processing. The tasks are se
libs/indexer/src/queue.rs:48
↓ 1 callersFunctionadd_database_field
inserts a new field into the database returns the id of the field created
src/biz/collab/ops.rs:782
↓ 1 callersFunctionadd_document_collab
( client: &mut TestClient, workspace_id: &Uuid, file_name: &str, search_term: &str, wait_embedding:
tests/search/document_search.rs:182
↓ 1 callersFunctionadd_new_database_to_workspace
( workspace_database: &mut WorkspaceDatabase, database_id: &Uuid, view_id: &Uuid, )
src/biz/workspace/page_view.rs:695
↓ 1 callersFunctionadd_new_space_to_folder
( uid: i64, workspace_id: &Uuid, view_id: &Uuid, folder: &mut Folder, space_permission: &SpacePermis
src/biz/workspace/page_view.rs:597
↓ 1 callersFunctionadd_recent_pages
( state: &AppState, user: RealtimeUser, workspace_id: Uuid, recent_view_ids: Vec<String>, )
src/biz/workspace/page_view.rs:1447
↓ 1 callersMethodadd_recent_pages
( &self, workspace_id: Uuid, params: &AddRecentPagesParams, )
libs/client-api/src/http_view.rs:140
← previousnext →701–800 of 3,042, ranked by callers