MCPcopy Index your code

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

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

↓ 12 callersMethodencode_collab
(&self)
tests/collab/util.rs:89
↓ 12 callersMethodset
Sets a new access token and notifies interested parties of the refresh. This function updates the internal access token state and sends a `TokenState
libs/client-api/src/notify.rs:48
↓ 12 callersMethodset_status
(&self, status: ConnectionStatus)
libs/client-api/src/v2/conn_retry.rs:208
↓ 12 callersMethodstop
(&self)
libs/client-api/src/ping.rs:42
↓ 12 callersMethodupdate_policy
( &self, sub: SubjectType, obj: ObjectType, act: T, )
libs/access-control/src/casbin/access.rs:77
↓ 11 callersMethodbuild
(&self)
libs/workspace-template/src/lib.rs:94
↓ 11 callersFunctioncreate_test_user
( pool: &PgPool, user_uuid: Uuid, email: &str, name: &str, )
tests/sql_test/util.rs:57
↓ 11 callersMethodget_collab
( &self, workspace_id: Uuid, object_id: Uuid, collab_type: CollabType, )
libs/client-api-test/src/test_client.rs:709
↓ 11 callersMethodget_full_encode_collab
( &self, origin: GetCollabOrigin, workspace_id: &Uuid, object_id: &Uuid, collab_type: Coll
services/appflowy-collaborate/src/collab/collab_store.rs:275
↓ 11 callersFunctionget_latest_collab
( collab_storage: &Arc<dyn CollabStore>, collab_origin: GetCollabOrigin, workspace_id: Uuid, object_id
src/biz/collab/utils.rs:265
↓ 11 callersMethodget_workspace_members
( &self, workspace_id: &Uuid, )
libs/client-api/src/http_member.rs:27
↓ 11 callersMethodobject_key
(&self)
src/api/file_storage.rs:626
↓ 11 callersMethodobserve_pg_tx
(&self, duration: std::time::Duration)
services/appflowy-collaborate/src/metrics.rs:235
↓ 11 callersMethodset_connection_status
(&self, status: ConnectionStatus)
libs/client-api/src/v2/actor.rs:252
↓ 11 callersFunctionsetup_db
(pool: &PgPool)
tests/sql_test/util.rs:16
↓ 11 callersFunctionsplit_text_by_max_tokens
( content: String, max_tokens: usize, tokenizer: &CoreBPE, )
libs/indexer/src/vector/open_ai.rs:88
↓ 11 callersMethodtrigger_reconnect
(&self, reason: &str)
libs/client-api/src/v2/conn_retry.rs:79
↓ 10 callersFunctionai_model_from_header
(req: &HttpRequest)
src/api/util.rs:214
↓ 10 callersMethoddisconnect
(&self)
libs/client-api/src/ws/client.rs:381
↓ 10 callersMethodget_published_view_comments
( &self, view_id: &Uuid, )
libs/client-api/src/http_publish.rs:247
↓ 10 callersMethodinto_bytes
(&self)
libs/appflowy-proto/src/shared.rs:32
↓ 10 callersMethodinto_data
(self)
libs/appflowy-ai-client/src/client.rs:385
↓ 10 callersMethodlist_workspace_invitations
( &self, status: Option<AFWorkspaceInvitationStatus>, )
libs/client-api/src/http_member.rs:56
↓ 10 callersMethodmsg_id
(&self)
libs/client-api/src/collab_sync/collab_sink.rs:643
↓ 10 callersMethodobject_id
(&self)
libs/collab-rt-entity/src/client_message.rs:63
↓ 10 callersFunctionpartition_key_from_collab_type
(collab_type: &CollabType)
libs/database/src/collab/mod.rs:8
↓ 10 callersMethodpublish_update
( &self, workspace_id: WorkspaceId, object_id: ObjectId, collab_type: CollabType, sender:
services/appflowy-collaborate/src/collab/collab_manager.rs:239
↓ 10 callersFunctionspawn_reconnection
( manager: Weak<ReconnectionManager>, mut connect_status_rx: tokio::sync::watch::Receiver<ConnectionStatus
libs/client-api/src/v2/controller.rs:370
↓ 10 callersMethodstatus_channel
(&self)
libs/client-api/src/v2/conn_retry.rs:215
↓ 10 callersFunctiontest_enforcer
()
libs/access-control/src/casbin/enforcer.rs:319
↓ 10 callersMethodvalidate
Validates the `ChatMetadataData` instance. This method checks the validity of the data based on the content type and the presence of content or URL.
libs/shared-entity/src/dto/chat_dto.rs:86
↓ 10 callersMethodwith_name
(mut self, name: &str)
libs/workspace-template/src/hierarchy_builder.rs:83
↓ 9 callersMethodas_str
(&self)
services/appflowy-collaborate/src/config.rs:49
↓ 9 callersMethodcreate_chat
Create a new chat
libs/client-api/src/http_chat.rs:27
↓ 9 callersFunctioncreate_document_from_json
( object_id: String, json_str: &str, )
libs/workspace-template/src/document/util.rs:11
↓ 9 callersFunctionfrom_json_response
(resp: reqwest::Response)
admin_frontend/src/ext/mod.rs:9
↓ 9 callersMethodget_collab
( &self, workspace_id: Uuid, object_id: Uuid, collab_type: CollabType, )
libs/client-api-test/src/test_client_v2.rs:769
↓ 9 callersFunctionget_first_workspace
(c: &client_api::Client)
tests/workspace/publish.rs:918
↓ 9 callersMethodget_workspace_trash
( &self, workspace_id: &Uuid, )
libs/client-api/src/http.rs:825
↓ 9 callersMethodhandle_user_connect
( &self, new_user: RealtimeUser, client_message_router: ClientMessageRouter, )
services/appflowy-collaborate/src/connect_state.rs:44
↓ 9 callersMethodinstall
Executes a closure within the thread pool. This method runs the provided closure (`op`) inside the thread pool. If a panic occurs during the executio
libs/infra/src/thread_pool.rs:33
↓ 9 callersMethodpublish_collabs
( &self, workspace_id: &Uuid, items: Vec<PublishCollabItem<Metadata, Data>>, )
libs/client-api/src/http_collab.rs:413
↓ 9 callersMethodput_blob
( &self, url: &str, data: T, mime: &Mime, )
libs/client-api/src/http_blob.rs:26
↓ 9 callersFunctionsetup_log
()
libs/client-api-test/src/log.rs:39
↓ 9 callersMethodsubscribe
(&self)
libs/client-api/src/ws/state.rs:26
↓ 9 callersMethodto_blob
(self)
libs/database/src/file/s3_client_impl.rs:516
↓ 9 callersFunctionto_dto_view_layout
(collab_folder_view_layout: &CollabFolderViewLayout)
src/biz/collab/folder_view.rs:471
↓ 9 callersMethodtry_send
(&self, message: RealtimeMessage)
services/appflowy-collaborate/src/actix_ws/client/rt_client.rs:98
↓ 9 callersMethodwith_name
(mut self, name: T)
libs/shared-entity/src/dto/auth_dto.rs:44
↓ 8 callersMethodclear
(&mut self)
tests/collab/util.rs:54
↓ 8 callersMethodcode
(&self)
libs/app-error/src/lib.rs:233
↓ 8 callersFunctioncollab_from_doc_state
( doc_state: Vec<u8>, object_id: &Uuid, client_id: ClientID, )
src/biz/collab/utils.rs:407
↓ 8 callersMethodconnect
(&self)
libs/client-api/src/ws/client.rs:121
↓ 8 callersMethodcreate_upload
( &self, workspace_id: &Uuid, req: CreateUploadRequest, )
libs/client-api/src/http_file.rs:28
↓ 8 callersFunctionget_or_default
(key: &str, default: &str)
admin_frontend/src/config.rs:51
↓ 8 callersFunctionmock_stream
()
services/appflowy-collaborate/src/connect_state.rs:146
↓ 8 callersMethodobject_id
(&self)
services/appflowy-collaborate/src/group/group_init.rs:168
↓ 8 callersMethodremove_policy
Remove policies for a subject and object type.
libs/access-control/src/casbin/enforcer_v2.rs:340
↓ 8 callersMethodset
(&self, k: K, v: V)
libs/access-control/src/casbin/redis_cache.rs:69
↓ 8 callersMethodsign_up
( &self, email: &str, password: &str, redirect_to: Option<&str>, )
libs/gotrue/src/api.rs:59
↓ 8 callersFunctionto_dto_view_icon
( icon: collab_folder::ViewIcon, )
src/biz/collab/folder_view.rs:452
↓ 8 callersMethodupload_part
Upload a part of a file. The part number should be 1-based. In Amazon S3, the minimum chunk size for multipart uploads is 5 MB,except for the last pa
libs/client-api/src/http_file.rs:51
↓ 7 callersFunctionassert_client_collab_within_secs
( client: &mut TestClient, object_id: &Uuid, key: &str, expected: Value, secs: u64, )
libs/client-api-test/src/test_client.rs:1110
↓ 7 callersMethodbatch_get_collab
Batch retrieves collaboration data for multiple queries. This method first checks if any of the requested collaborations have been deleted and filter
services/appflowy-collaborate/src/collab/cache/disk_cache.rs:446
↓ 7 callersMethodblob_metadata_key
(&self)
src/api/file_storage.rs:630
↓ 7 callersFunctionclient_version_from_headers
Retrieve client version from headers
src/api/util.rs:74
↓ 7 callersMethodcreate_comment_on_published_view
( &self, view_id: &Uuid, comment_content: &str, reply_comment_id: &Option<Uuid>, )
libs/client-api/src/http_publish.rs:108
↓ 7 callersMethodcreate_question
Save a question message to a chat
libs/client-api/src/http_chat.rs:93
↓ 7 callersMethoddelete_blob
(&self, url: &str)
libs/client-api/src/http_blob.rs:238
↓ 7 callersFunctiondeserialize
(deserializer: D)
libs/database-entity/src/dto.rs:33
↓ 7 callersMethodduplicate_published_to_workspace
( &self, workspace_id: Uuid, publish_duplicate: &PublishedDuplicate, )
libs/client-api/src/http_publish.rs:379
↓ 7 callersMethodenforce_policy_with_consistency
( &self, uid: &i64, obj: ObjectType, act: T, consistency: ConsistencyMode, )
libs/access-control/src/casbin/enforcer_v2.rs:419
↓ 7 callersMethodenforce_role_weak
( &self, _uid: &i64, _workspace_id: &Uuid, _role: AFRole, )
libs/access-control/src/noops/workspace.rs:35
↓ 7 callersFunctionfrom_body
(resp: reqwest::Response)
libs/infra/src/reqwest.rs:38
↓ 7 callersMethodget_blob_v1
( &self, workspace_id: &Uuid, parent_dir: &str, file_id: &str, )
libs/client-api/src/http_blob.rs:129
↓ 7 callersFunctionget_latest_collab_database_body
( collab_storage: &Arc<dyn CollabStore>, workspace_id: Uuid, database_id: Uuid, )
src/biz/collab/utils.rs:232
↓ 7 callersMethodhttp_client_without_auth
( &self, method: Method, url: &str, )
libs/client-api/src/http.rs:1122
↓ 7 callersMethodindex_enabled
(&self)
libs/indexer/src/scheduler.rs:113
↓ 7 callersFunctioninsert_into_af_collab_bulk_for_user
( tx: &mut Transaction<'_, Postgres>, uid: &i64, workspace_id: Uuid, collab_params_list: &[CollabParam
libs/database/src/collab/collab_db_ops.rs:141
↓ 7 callersMethodinsert_role
( &self, _uid: &i64, _workspace_id: &Uuid, _role: AFRole, )
libs/access-control/src/noops/workspace.rs:53
↓ 7 callersMethodinvite_workspace_members
( &self, workspace_id: &Uuid, invitations: Vec<WorkspaceMemberInvitation>, )
libs/client-api/src/http_member.rs:41
↓ 7 callersMethodis_exist
Checks if an object with the given ID exists in the cache.
services/appflowy-collaborate/src/collab/cache/mem_cache.rs:90
↓ 7 callersMethodlist_database_row_details
( &self, workspace_id: &Uuid, database_id: &str, row_ids: &[&str], with_doc: bool, )
libs/client-api/src/http_collab.rs:252
↓ 7 callersMethodlist_quick_notes
( &self, workspace_id: Uuid, search_term: Option<String>, offset: Option<i32>, limit: Opti
libs/client-api/src/http_quick_note.rs:36
↓ 7 callersMethodmodel
(&self)
libs/indexer/src/vector/embedder.rs:30
↓ 7 callersMethodpayload
(&self)
libs/collab-rt-entity/src/message.rs:181
↓ 7 callersMethodprepend_with_path_prefix
(&self, path: &str)
admin_frontend/src/models.rs:14
↓ 7 callersMethodreconnect
(&self)
libs/client-api-test/src/test_client.rs:963
↓ 7 callersFunctionresolve_dependencies_when_create_database_linked_view
( database_layout: DatabaseLayout, fields: &[Field], )
src/biz/collab/database.rs:35
↓ 7 callersFunctionretry_with_backoff
Executes a future with retry logic and exponential backoff
libs/client-api-test/src/async_utils.rs:9
↓ 7 callersMethodsend
( &self, workspace_id: &str, object_id: &str, update: &AwarenessStreamUpdate, )
libs/collab-stream/src/awareness_gossip.rs:91
↓ 7 callersMethodset_state
(&self, state: ConnectState)
libs/client-api/src/ws/client.rs:413
↓ 7 callersMethodstart
( &self, awareness: &Awareness, encoder: &mut E, )
libs/collab-rt-protocol/src/protocol.rs:111
↓ 7 callersFunctiontest_encode_collab_v1
(object_id: &Uuid, key: &str, value: &str)
tests/collab/util.rs:153
↓ 7 callersMethodtrigger
(&self, action: WorkspaceAction)
libs/client-api/src/v2/actor.rs:106
↓ 7 callersMethodwith_extra
(mut self, extra: &str)
libs/workspace-template/src/hierarchy_builder.rs:96
↓ 6 callersMethodaccept_workspace_invitation
( &self, invitation_id: &str, )
libs/client-api/src/http_member.rs:82
↓ 6 callersMethodadmin_add_user
( &self, access_token: &str, admin_user_params: &AdminUserParams, )
libs/gotrue/src/api.rs:245
↓ 6 callersFunctionask_question
( test_client: &TestClient, workspace_id: &Uuid, chat_id: &str, question: &str, )
tests/ai_test/chat_with_selected_doc_test.rs:300
↓ 6 callersMethodassert_similarity
( &self, workspace_id: &Uuid, input: &str, expected: &str, score: f64, use_embedding:
libs/client-api-test/src/test_client.rs:673
← previousnext →101–200 of 3,042, ranked by callers