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

↓ 1 callersMethodopen_workspace

(&self, workspace_id: &Uuid)

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

↓ 1 callersMethodopen_workspace

(&self, workspace_id: &Uuid)

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

↓ 1 callersFunctionpage_router

()

admin_frontend/src/web_app.rs:28

↓ 1 callersFunctionparser_realtime_msg

( payload: Bytes, req: HttpRequest, )

src/api/workspace.rs:2596

↓ 1 callersMethodpatch_collabs

( &self, workspace_id: &Uuid, user_uuid: &Uuid, patches: &[PatchPublishedCollab], )

src/biz/workspace/publish.rs:411

↓ 1 callersFunctionpatch_old_workspace_folder

( user: RealtimeUser, workspace_id: &str, folder: &mut Folder, child_view_id_without_space: &[String],

src/biz/collab/ops.rs:161

↓ 1 callersFunctionpatch_workspace

( pg_pool: &PgPool, workspace_id: &Uuid, workspace_name: Option<&str>, workspace_icon: Option<&str>, )

src/biz/workspace/ops.rs:152

↓ 1 callersMethodpath_buf

(&self)

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

↓ 1 callersMethodpause

(&self)

libs/client-api/src/collab_sync/collab_sink.rs:179

↓ 1 callersMethodpayload_size

(&self)

libs/collab-rt-entity/src/client_message.rs:159

↓ 1 callersFunctionpayload_to_async_read

(payload: Payload)

src/api/file_storage.rs:541

↓ 1 callersMethodpersist_update

Saves the provided update to the persistent database and checks if there are any missing updates in the collaboration sequence. If gaps are detected i

libs/client-api/src/v2/actor.rs:977

↓ 1 callersMethodpg_connect_options

(&self)

src/config/config.rs:127

↓ 1 callersFunctionpoll_until

Polls a condition until it returns true or timeout is reached

libs/client-api-test/src/async_utils.rs:149

↓ 1 callersFunctionpoll_until_some

Polls a function until it returns Some(T) or timeout is reached

libs/client-api-test/src/async_utils.rs:168

↓ 1 callersFunctionpopulate_searchable_view_ids

( folder: &Folder, private_space_and_trash_views: &PrivateSpaceAndTrashViews, searchable_view_ids: &mut

src/biz/search/ops.rs:31

↓ 1 callersFunctionprepare_default_board_encoded_database

( view_id: &Uuid, database_id: &Uuid, name: &str, )

src/biz/workspace/page_view.rs:443

↓ 1 callersFunctionprepare_default_calendar_encoded_database

( view_id: &Uuid, database_id: &Uuid, name: &str, )

src/biz/workspace/page_view.rs:392

↓ 1 callersFunctionprepare_default_grid_encoded_database

( view_id: &Uuid, database_id: &Uuid, name: &str, )

src/biz/workspace/page_view.rs:417

↓ 1 callersFunctionprepare_document_collab_param_with_initial_data

( client_id: ClientID, page_data: serde_json::Value, collab_id: Uuid, )

src/biz/workspace/page_view.rs:265

↓ 1 callersFunctionprocess_resources

(resources: Vec<CollabResource>)

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

↓ 1 callersMethodprocess_snapshot_tasks

Processes snapshot tasks in parallel to generate full states

services/appflowy-collaborate/src/collab/collab_manager.rs:450

↓ 1 callersFunctionprocess_task

( mut context: TaskContext, import_task: ImportTask, )

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

↓ 1 callersFunctionprocess_un_acked_tasks

( storage_dir: &Path, redis_client: &mut ConnectionManager, s3_client: &Arc<dyn S3Client>, pg_pool: &P

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

↓ 1 callersFunctionprocess_unzip_file

( import_task: &NotionImportTask, unzip_dir_path: &PathBuf, pg_pool: &PgPool, redis_client: &mut Conne

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

↓ 1 callersFunctionprocess_upcoming_tasks

( storage_dir: &Path, redis_client: &mut ConnectionManager, s3_client: &Arc<dyn S3Client>, pg_pool: Pg

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

↓ 1 callersFunctionprocess_upcoming_tasks

( pg_pool: PgPool, redis_client: &mut ConnectionManager, metrics: Arc<EmbeddingMetrics>, indexer_provi

services/appflowy-worker/src/indexer_worker/worker.rs:83

↓ 1 callersMethodprune_updates

(&self, workspace_id: WorkspaceId, up_to: Rid)

services/appflowy-collaborate/src/collab/collab_manager.rs:83

↓ 1 callersMethodpublish_awareness_update

( &self, workspace_id: WorkspaceId, object_id: ObjectId, sender: CollabOrigin, update: Awa

services/appflowy-collaborate/src/collab/collab_manager.rs:287

↓ 1 callersFunctionpublish_inactive_collab

( last_message_id: Rid, sender: &UnboundedSender<WorkspaceAction>, chunk: &[(ObjectId, CollabType)], v

libs/client-api/src/v2/actor.rs:1332

↓ 1 callersFunctionpublish_page

( state: &AppState, uid: i64, user_uuid: Uuid, workspace_id: Uuid, view_id: Uuid, visible_database

src/biz/workspace/page_view.rs:1657

↓ 1 callersMethodpublish_page

( &self, workspace_id: Uuid, view_id: &Uuid, params: &PublishPageParams, )

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

↓ 1 callersMethodpublish_pending_collabs

(&self)

libs/client-api/src/v2/actor.rs:733

↓ 1 callersMethodpublish_update

( store: Arc<CollabManager>, workspace_id: WorkspaceId, msg: PublishUpdate, )

services/appflowy-collaborate/src/ws2/actors/workspace.rs:71

↓ 1 callersMethodpublish_update

( &self, object_id: ObjectId, collab_type: CollabType, source: ActionSource, update_v1: Ve

libs/client-api/src/v2/actor.rs:1074

↓ 1 callersFunctionpush_task

( redis_client: &mut ConnectionManager, stream_name: &str, _group_name: &str, task: ImportTask, entr

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

↓ 1 callersMethodput_blob

( &self, object_key: &str, content: ByteStream, content_type: Option<&str>, )

libs/database/src/file/s3_client_impl.rs:153

↓ 1 callersMethodput_code_session

( &self, code: &str, code_session: &CodeSession, )

admin_frontend/src/session.rs:75

↓ 1 callersFunctionread_background_embed_tasks

Reads tasks from the Redis stream for processing by a consumer group.

libs/indexer/src/queue.rs:74

↓ 1 callersMethodrecord_enforce_count

(&self, total: i64, from_cache: i64)

libs/access-control/src/metrics.rs:79

↓ 1 callersMethodrecord_import_size_bytes

(&self, size: usize)

services/appflowy-worker/src/metric.rs:42

↓ 1 callersMethodrecord_load_all_policies_in_ms

(&self, millis: u64)

libs/access-control/src/metrics.rs:75

↓ 1 callersMethodrecord_policy_send_metrics

(&self, attempts: i64, failures: i64, channel_full: i64)

libs/access-control/src/metrics.rs:84

↓ 1 callersMethodrecord_request

app services/middleware should call this method to increase the request count for the path

src/api/metrics.rs:115

↓ 1 callersMethodrecord_search_tokens_used

(&self, workspace_id: &Uuid, tokens: u32)

src/api/metrics.rs:105

↓ 1 callersMethodrecord_stream_image_count

(&self, count: u64)

src/biz/chat/metrics.rs:70

↓ 1 callersMethodrecord_total_summary_row_count

(&self, count: u64)

src/biz/chat/metrics.rs:78

↓ 1 callersMethodrecord_total_translate_row_count

(&self, count: u64)

src/biz/chat/metrics.rs:82

↓ 1 callersFunctionredis_client

()

tests/collab/util.rs:162

↓ 1 callersFunctionredis_connection_manager

()

services/appflowy-worker/tests/import_test.rs:122

↓ 1 callersMethodregenerate_image

(&self, source_metadata: Value)

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

↓ 1 callersFunctionregister_mailer

(mailer: &mut Mailer)

src/mailer.rs:89

↓ 1 callersMethodremove_collab

Remove colla from the cache

libs/client-api/src/v2/actor.rs:121

↓ 1 callersFunctionremove_comment_on_published_view

( pg_pool: &PgPool, view_id: &Uuid, comment_id: &Uuid, user_uuid: &Uuid, )

src/biz/workspace/ops.rs:201

↓ 1 callersMethodremove_dir

(&self, dir: &str)

libs/database/src/file/file_storage.rs:87

↓ 1 callersMethodremove_doc

(&self, object_id: &Uuid)

libs/client-api/src/v2/db.rs:228

↓ 1 callersMethodremove_encode_collab

(&self, object_id: &Uuid)

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

↓ 1 callersMethodremove_group

(&self, object_id: &Uuid)

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

↓ 1 callersMethodremove_inactive_groups

Returns group ids of inactive groups.

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

↓ 1 callersMethodremove_page_icon

( &self, workspace_id: Uuid, view_id: &Uuid, )

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

↓ 1 callersFunctionremove_reaction_on_comment

( pg_pool: &PgPool, comment_id: &Uuid, reaction_type: &str, user_uuid: &Uuid, )

src/biz/workspace/ops.rs:241

↓ 1 callersMethodremove_user_from_workspace

( &self, _uid: &i64, _workspace_id: &Uuid, )

libs/access-control/src/noops/workspace.rs:62

↓ 1 callersFunctionrename_workspace

( tx: &mut Transaction<'_, sqlx::Postgres>, workspace_id: &Uuid, new_workspace_name: &str, )

libs/database/src/workspace.rs:85

↓ 1 callersFunctionreorder_favorite_page

( state: &AppState, user: RealtimeUser, workspace_id: Uuid, view_id: &str, prev_view_id: Option<&str

src/biz/workspace/page_view.rs:1384

↓ 1 callersFunctionreorder_favorite_section

( view_id: &str, prev_view_id: Option<&str>, folder: &mut Folder, uid: i64, )

src/biz/workspace/page_view.rs:789

↓ 1 callersFunctionreplace_invalid_url_chars

(input: &str)

src/biz/workspace/page_view.rs:1636

↓ 1 callersMethodreport

(&self, task_id: &str)

services/appflowy-worker/src/error.rs:77

↓ 1 callersFunctionresolve_board_dependencies

( original_fields: &[Field], )

src/biz/collab/database.rs:55

↓ 1 callersFunctionresolve_calendar_dependencies

(fields: &[Field])

src/biz/collab/database.rs:125

↓ 1 callersFunctionresolve_grid_dependencies

(fields: &[Field])

src/biz/collab/database.rs:46

↓ 1 callersFunctionrestore_all_pages_from_trash

( state: &AppState, user: RealtimeUser, workspace_id: Uuid, )

src/biz/workspace/page_view.rs:1466

↓ 1 callersMethodrestore_all_workspace_page_views_from_trash

( &self, workspace_id: Uuid, )

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

↓ 1 callersFunctionrestore_page_from_trash

( state: &AppState, user: RealtimeUser, workspace_id: Uuid, view_id: &str, )

src/biz/workspace/page_view.rs:1428

↓ 1 callersMethodresume

(&self)

libs/client-api/src/collab_sync/collab_sink.rs:187

↓ 1 callersMethodretriable_when_editing

(&self)

libs/client-api/src/v2/controller.rs:255

↓ 1 callersFunctionretry_connect

( connect_provider: Arc<dyn WSClientConnectURLProvider>, state_notify: Weak<StateNotify>, )

libs/client-api/src/retry.rs:79

↓ 1 callersFunctionrevoke_apple_token_http_call

Based on: https://developer.apple.com/documentation/sign_in_with_apple/revoke_tokens

src/biz/user/user_delete.rs:134

↓ 1 callersFunctionrevoke_apple_user

( client_id: &str, client_secret: &Secret<String>, apple_access_token: Option<String>, apple_refresh_t

src/biz/user/user_delete.rs:81

↓ 1 callersMethodrun

(&mut self)

libs/client-api/src/ping.rs:46

↓ 1 callersMethodrun

The runner will stop if the [CollabSink] was dropped or the notifier was closed.

libs/client-api/src/collab_sync/collab_sink.rs:466

↓ 1 callersFunctionrun_actix_server

( listener: TcpListener, state: AppState, config: Config, )

src/application.rs:105

↓ 1 callersFunctionrun_background_indexer

( pg_pool: PgPool, mut redis_client: ConnectionManager, embed_metrics: Arc<EmbeddingMetrics>, config:

services/appflowy-worker/src/indexer_worker/worker.rs:31

↓ 1 callersFunctionrun_importer_worker

( pg_pool: PgPool, redis_client: ConnectionManager, notifier: Arc<dyn ImportNotifier>, stream_name: St

services/appflowy-worker/tests/import_test.rs:131

↓ 1 callersFunctionrun_server

( listener: TcpListener, config: Config, )

services/appflowy-worker/src/application.rs:36

↓ 1 callersMethodrun_until_stopped

(self)

src/application.rs:96

↓ 1 callersMethods3_client

(&self)

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

↓ 1 callersMethodsave

(&self)

services/appflowy-collaborate/src/group/group_init.rs:1136

↓ 1 callersMethodsave_answer

save an answer message to a chat

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

↓ 1 callersMethodsave_attempt

Tries to save provided `snapshot`. This snapshot is expected to have **GC turned off**, as first it will try to save it as a historical snapshot (will

services/appflowy-collaborate/src/group/group_init.rs:1154

↓ 1 callersMethodsave_awareness_update

( &self, object_id: ObjectId, update: AwarenessUpdate, )

libs/client-api/src/v2/actor.rs:1008

↓ 1 callersMethodsave_remote_update

Applies or persists remote updates for collaborative objects. # Arguments `object_id` - The identifier of the collaborative object `collab_type` - Th

libs/client-api/src/v2/actor.rs:904

↓ 1 callersMethodschedule_snapshot

(&self, workspace_id: Uuid, last_message_id: Rid)

services/appflowy-collaborate/src/collab/snapshot_scheduler.rs:24

↓ 1 callersFunctionsearch_document

( pg_pool: &PgPool, collab_instance_cache: &impl WorkspaceCollabInstanceCache, indexer_scheduler: &Arc<I

src/biz/search/ops.rs:77

↓ 1 callersFunctionsearch_documents

Logs each search request to track usage by workspace. It either inserts a new record or updates an existing one with the current date, workspace ID, r

libs/database/src/index/search_ops.rs:14

↓ 1 callersMethodsearch_documents

( &self, request: &SearchDocumentsRequest, )

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

↓ 1 callersFunctionsearch_scope

()

src/api/search.rs:17

↓ 1 callersFunctionsection_items_to_favorite_folder_view

( section_items: &[SectionItem], folder: &Folder, published_view_ids: &HashSet<String>, uid: i64, )

src/biz/collab/folder_view.rs:211

↓ 1 callersFunctionsection_items_to_recent_folder_view

( section_items: &[SectionItem], folder: &Folder, published_view_ids: &HashSet<String>, uid: i64, )

src/biz/collab/folder_view.rs:260

↓ 1 callersFunctionsection_items_to_trash_folder_view

( section_items: &[SectionItem], folder: &Folder, uid: i64, )

src/biz/collab/folder_view.rs:300

↓ 1 callersFunctionselect_all_uid_uuid

( executor: E, )

libs/database/src/user.rs:165

← previous next →1,301–1,400 of 3,042, ranked by callers