Functions — github.com/AppFlowy-IO/AppFlowy-Cloud

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

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

⨍ Functions 3,042◇ Types & classes 910

↓ 2 callersMethodcheck

(&self, encoder: &mut E, last_sync_at: i64)

libs/collab-rt-protocol/src/protocol.rs:23

↓ 2 callersFunctioncheck_gotrue_result

(resp: reqwest::Response)

libs/gotrue/src/api.rs:377

↓ 2 callersFunctioncheck_maximum_task

(state: &Data<AppState>, uid: i64)

src/api/data_import.rs:293

↓ 2 callersMethodcheck_or_update_permission

( &self, uid: &i64, workspace_id: &WorkspaceId, object_id: &ObjectId, )

services/appflowy-collaborate/src/collab/collab_store.rs:67

↓ 2 callersFunctioncheck_response

(resp: reqwest::Response)

libs/infra/src/reqwest.rs:16

↓ 2 callersFunctioncheck_view_id_publish_name_conflict

Check if the `publish_name` already exists on another view

src/biz/workspace/publish.rs:653

↓ 2 callersMethodclean

(&self)

libs/client-api/src/ws/client.rs:392

↓ 2 callersFunctionclean_up

(s3_client: &Arc<dyn S3Client>, task: &NotionImportTask)

services/appflowy-worker/src/import_worker/worker.rs:1211

↓ 2 callersMethodcmp

(&self, other: &Self)

libs/database-entity/src/dto.rs:556

↓ 2 callersFunctioncode_session_key

(code: &str)

admin_frontend/src/session.rs:28

↓ 2 callersMethodcollab_awareness_stream

( &self, object_id: &Uuid, )

libs/collab-stream/src/awareness_gossip.rs:113

↓ 2 callersFunctioncollab_folder_to_folder_view

Return all folders belonging to a workspace, excluding private sections which the user does not have access to.

src/biz/collab/folder_view.rs:61

↓ 2 callersMethodcollab_origin

(&self)

services/appflowy-collaborate/src/ws2/actors/session.rs:46

↓ 2 callersFunctioncollab_snapshot_key

(workspace_id: &Uuid, object_id: &Uuid, snapshot_id: i64)

services/appflowy-collaborate/src/snapshot/snapshot_control.rs:25

↓ 2 callersFunctioncollab_snapshot_prefix

(workspace_id: &Uuid, object_id: &Uuid)

services/appflowy-collaborate/src/snapshot/snapshot_control.rs:33

↓ 2 callersMethodconnect_info

(&self)

libs/client-api/src/http_file.rs:265

↓ 2 callersFunctionconsume_task

( mut context: TaskContext, mut import_task: ImportTask, stream_name: &str, group_name: &str, entry_

services/appflowy-worker/src/import_worker/worker.rs:270

↓ 2 callersMethodcontains_group

(&self, object_id: &Uuid)

services/appflowy-collaborate/src/group/state.rs:116

↓ 2 callersMethodcontains_user

(&self, object_id: &Uuid, user: &RealtimeUser)

services/appflowy-collaborate/src/group/state.rs:188

↓ 2 callersMethodcreate_access_request

( &self, data: CreateAccessRequestParams, )

libs/client-api/src/http_access_request.rs:25

↓ 2 callersFunctioncreate_chat

( pg_pool: &PgPool, params: CreateChatParams, workspace_id: &Uuid, )

src/biz/chat/ops.rs:23

↓ 2 callersMethodcreate_chat_text_context

(&self, context: CreateChatContext)

libs/appflowy-ai-client/src/client.rs:136

↓ 2 callersMethodcreate_collab_list

( &self, workspace_id: &Uuid, params_list: Vec<CollabParams>, )

libs/client-api/src/http_collab.rs:352

↓ 2 callersFunctioncreate_database_from_params

Create a series of database templates from the given JSON String Notes: The output contains DatabaseCollab, DatabaseRowCollab

libs/workspace-template/src/document/util.rs:39

↓ 2 callersFunctioncreate_empty_workspace

Create an empty workspace with default folder, workspace database and user awareness collab object.

src/biz/workspace/ops.rs:66

↓ 2 callersMethodcreate_group

( &self, user: &RealtimeUser, workspace_id: Uuid, object_id: Uuid, collab_type: collab_ent

services/appflowy-collaborate/src/group/cmd.rs:325

↓ 2 callersFunctioncreate_row_document

( workspace_id: Uuid, uid: i64, new_doc_id: Uuid, collab_instance_cache: &impl WorkspaceCollabInstance

src/biz/collab/utils.rs:483

↓ 2 callersMethodcreate_space

( &self, workspace_id: Uuid, params: &CreateSpaceParams, )

libs/client-api/src/http_view.rs:265

↓ 2 callersMethodcreate_template

( &self, params: &CreateTemplateParams, )

libs/client-api/src/http_template.rs:201

↓ 2 callersFunctioncreate_test_collab_document

( pg_pool: &PgPool, uid: &i64, workspace_id: &Uuid, doc_id: &Uuid, )

tests/sql_test/util.rs:72

↓ 2 callersFunctioncreate_upload_task

( uid: i64, task_id: Uuid, task: serde_json::Value, host: &str, workspace_id: &str, file_size: usi

src/biz/workspace/ops.rs:686

↓ 2 callersFunctioncreate_user

( executor: E, uid: i64, user_uuid: &Uuid, email: &str, name: &str, )

libs/database/src/user.rs:104

↓ 2 callersFunctioncreate_user_awareness

( uid: &i64, user_uuid: &Uuid, workspace_id: Uuid, storage: &Arc<dyn CollabStore>, txn: &mut Transac

src/biz/user/user_init.rs:111

↓ 2 callersFunctioncreate_workspace_database_collab

( workspace_id: Uuid, uid: &i64, object_id: Uuid, storage: &Arc<dyn CollabStore>, txn: &mut Transact

src/biz/user/user_init.rs:189

↓ 2 callersMethodcreate_workspace_view

( &self, _uid: i64, workspace_view_builder: &mut WorkspaceViewBuilder, )

libs/workspace-template/src/document/vault_template.rs:54

↓ 2 callersMethodcurrent_collab_updates

Reads all collab updates for a given `workspace_id`:`object_id` entry, starting from a given message id. Once Redis stream return no more results, the

libs/collab-stream/src/client.rs:102

↓ 2 callersMethoddecode

(data: &[u8])

libs/collab-stream/src/model.rs:301

↓ 2 callersFunctiondecompress

(data: Vec<u8>, buffer_size: usize)

src/domain/compression.rs:37

↓ 2 callersMethoddeep_copy

Deep copy a published collab to the destination workspace. If None is returned, it means the view is not published. If Some is returned, a new view is

src/biz/workspace/publish_dup.rs:349

↓ 2 callersMethoddeep_copy_doc

( &mut self, pub_view_id: Uuid, dup_view_id: Uuid, doc: Document, metadata: PublishViewMet

src/biz/workspace/publish_dup.rs:406

↓ 2 callersMethoddeep_copy_view

Attempts to deep copy a view using `pub_view_id`. Returns None if view is not published else returns the view id of the duplicated view. If view is al

src/biz/workspace/publish_dup.rs:503

↓ 2 callersMethoddefault_dimensions

(&self)

libs/appflowy-ai-client/src/dto.rs:265

↓ 2 callersFunctiondelete_all_invite_code_for_workspace

( executor: E, workspace_id: &Uuid, )

libs/database/src/workspace.rs:1815

↓ 2 callersFunctiondelete_chat

(pg_pool: &PgPool, chat_id: &str)

src/biz/chat/ops.rs:35

↓ 2 callersFunctiondelete_from_workspace

(pg_pool: &PgPool, workspace_id: &Uuid)

libs/database/src/workspace.rs:21

↓ 2 callersFunctiondelete_published_collabs

( txn: &mut sqlx::Transaction<'_, Postgres>, workspace_id: &Uuid, publish_names: &[String], )

libs/database/src/publish.rs:218

↓ 2 callersMethoddelete_reaction_on_comment

( &self, reaction_type: &str, view_id: &Uuid, comment_id: &Uuid, )

libs/client-api/src/http_publish.rs:172

↓ 2 callersFunctiondelete_task

( redis_client: &mut ConnectionManager, stream_name: &str, _group_name: &str, entry_id: &str, )

services/appflowy-worker/src/import_worker/worker.rs:522

↓ 2 callersMethoddelete_template_category

(&self, category_id: Uuid)

libs/client-api/src/http_template.rs:93

↓ 2 callersMethoddelete_template_creator

(&self, creator_id: Uuid)

libs/client-api/src/http_template.rs:169

↓ 2 callersMethoddelete_user

(&self)

libs/client-api/src/http.rs:967

↓ 2 callersFunctiondelete_workspace_for_user

( pg_pool: PgPool, mut connection_manager: RedisConnectionManager, workspace_id: Uuid, bucket_storage:

src/biz/workspace/ops.rs:43

↓ 2 callersFunctiondeserialize_publish_database_data

( published_blob: &[u8], )

src/biz/workspace/publish_dup.rs:117

↓ 2 callersMethoddisable_search_indexing

(mut self, disable_search_indexing: bool)

libs/database-entity/src/dto.rs:735

↓ 2 callersMethoddo_send

(&self, message: RealtimeMessage)

services/appflowy-collaborate/src/actix_ws/client/rt_client.rs:320

↓ 2 callersMethodembed_immediately

(&self, pending_collab: UnindexedCollabTask)

libs/indexer/src/scheduler.rs:162

↓ 2 callersMethodemit_awareness_state

(&self, object_id: &Uuid)

libs/client-api-test/src/test_client_v2.rs:347

↓ 2 callersMethodenable_receive_message

(&self)

libs/client-api/src/ws/client.rs:450

↓ 2 callersFunctionencode_collab_from_bytes_with_thread_pool

( thread_pool: &Arc<ThreadPoolNoAbort>, bytes: Vec<u8>, )

services/appflowy-collaborate/src/collab/cache/mod.rs:27

↓ 2 callersFunctionensure_consumer_group

Ensure the consumer group exists, if not, create it.

services/appflowy-worker/src/import_worker/worker.rs:1396

↓ 2 callersFunctionensure_indexer_consumer_group

Ensure the consumer group exists, if not, create it.

libs/indexer/src/queue.rs:149

↓ 2 callersMethoderror_response

(&self)

libs/app-error/src/lib.rs:515

↓ 2 callersFunctionexpect_redis_json_bytes

(v: &[u8])

admin_frontend/src/session.rs:270

↓ 2 callersFunctionexpect_redis_value_data

(v: &redis::Value)

admin_frontend/src/session.rs:285

↓ 2 callersFunctionextract_request_id

(resp: &reqwest::Response)

libs/client-api/src/http.rs:1313

↓ 2 callersMethodfill_buffer

(&mut self)

src/api/util.rs:188

↓ 2 callersFunctionforward_message_to_group

( user: RealtimeUser, object_id: Uuid, collab_messages: Vec<ClientCollabMessage>, client_msg_router: &

services/appflowy-collaborate/src/group/cmd.rs:344

↓ 2 callersFunctiongather

( join_set: &mut JoinSet<GetResult>, results: &mut HashMap<Uuid, QueryCollabResult>, not_found: &m

services/appflowy-collaborate/src/collab/cache/disk_cache.rs:653

↓ 2 callersFunctiongen_rate_limiter

( mut times_per_sec: u32, )

services/appflowy-collaborate/src/actix_ws/client/rt_client.rs:325

↓ 2 callersFunctiongen_sync_state

( awareness: &Awareness, protocol: &P, )

libs/client-api/src/collab_sync/sync_control.rs:153

↓ 2 callersMethodgenerate_search_summary

High score means more relevant

libs/client-api/src/http_search.rs:44

↓ 2 callersMethodgenerate_sign_in_action_link

( &self, email: &str, )

libs/client-api/src/http.rs:489

↓ 2 callersFunctiongenerate_unique_registered_user_with_email

(email: &str)

libs/client-api-test/src/user.rs:44

↓ 2 callersMethodget_access_request

( &self, access_request_id: Uuid, )

libs/client-api/src/http_access_request.rs:12

↓ 2 callersFunctionget_aws_s3_client

(s3_setting: &S3Setting)

src/application.rs:425

↓ 2 callersFunctionget_blob_by_object_key

( state: Data<AppState>, key: &impl BlobKey, req: HttpRequest, )

src/api/file_storage.rs:355

↓ 2 callersMethodget_blob_stream

(&self, object_key: &str)

services/appflowy-worker/src/s3_client.rs:79

↓ 2 callersMethodget_blob_url_v1

(&self, workspace_id: &Uuid, parent_dir: &str, file_id: &str)

libs/client-api/src/http_blob.rs:97

↓ 2 callersFunctionget_bool_from_env_var

(env_var_name: &str)

libs/client-api-test/src/log.rs:8

↓ 2 callersMethodget_chat_settings

( &self, workspace_id: &Uuid, chat_id: &str, )

libs/client-api/src/http_chat.rs:60

↓ 2 callersMethodget_code

(&self)

libs/collab-rt-entity/src/server_message.rs:192

↓ 2 callersMethodget_collab_publish_info

(&self, view_id: &Uuid)

src/biz/workspace/publish.rs:382

↓ 2 callersMethodget_data_with_timestamp

Retrieves data and its associated timestamp from Redis for a given object identifier. # Arguments `object_id` - A unique identifier for the data. #

services/appflowy-collaborate/src/collab/cache/mem_cache.rs:509

↓ 2 callersMethodget_database

(&self, workspace_id: Uuid, database_id: &str)

libs/client-api-test/src/test_client.rs:227

↓ 2 callersFunctionget_encode_collab_from_bytes

( workspace_id: &Uuid, object_id: &Uuid, collab_type: &CollabType, pg_pool: &PgPool, s3: &Arc<dyn S3

services/appflowy-worker/src/import_worker/worker.rs:1357

↓ 2 callersMethodget_group

(&self, object_id: &Uuid)

services/appflowy-collaborate/src/group/state.rs:60

↓ 2 callersMethodget_head_object

(&self, object_key: &str)

services/appflowy-worker/src/s3_client.rs:51

↓ 2 callersFunctionget_header_value_or_default

( header_map: &'a HeaderMap, header_name: &str, default: &'a str, )

admin_frontend/src/web_api.rs:654

↓ 2 callersFunctionget_host_from_request

(req: &HttpRequest)

src/api/data_import.rs:386

↓ 2 callersMethodget_import_list

(&self)

libs/client-api/src/http_file.rs:233

↓ 2 callersMethodget_json

(&self)

libs/client-api-test/src/test_client.rs:1048

↓ 2 callersMethodget_last_disconnect_reason

(&self)

libs/client-api/src/v2/conn_retry.rs:204

↓ 2 callersFunctionget_latest_snapshot_state

Retrieves the most recent snapshot from the `af_snapshot_state` table that has a `created_at` timestamp greater than or equal to the specified timesta

libs/database/src/history/ops.rs:164

↓ 2 callersMethodget_model_list

(&self, workspace_id: &Uuid)

libs/client-api/src/http_ai.rs:112

↓ 2 callersFunctionget_page_collab_data_for_document

( collab_storage: &Arc<dyn CollabStore>, uid: i64, workspace_id: &Uuid, view_id: &Uuid, )

src/biz/workspace/page_view.rs:2126

↓ 2 callersMethodget_published_outline

( &self, publish_namespace: &str, )

libs/client-api/src/http_publish.rs:283

↓ 2 callersMethodget_related_question

( &self, chat_id: &str, message_id: &i64, model: &str, )

libs/appflowy-ai-client/src/client.rs:258

↓ 2 callersFunctionget_request_id

(req: &ServiceRequest)

src/middleware/request_id.rs:88

↓ 2 callersMethodget_snapshot_collab

( &self, workspace_id: &Uuid, query: QueryCollab, )

services/appflowy-collaborate/src/collab/cache/collab_cache.rs:220

↓ 2 callersMethodget_template

( &self, view_id: Uuid, )

libs/client-api/src/http_template.rs:216

← previous next →501–600 of 3,042, ranked by callers