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 callersFunctioninsert_meta_from_path

( object_id: &str, path: &PathBuf, )

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

↓ 1 callersFunctioninsert_new_access_request

( executor: E, workspace_id: Uuid, view_id: Uuid, uid: i64, )

libs/database/src/access_request.rs:10

↓ 1 callersFunctioninsert_new_quick_note

( executor: E, workspace_id: Uuid, uid: i64, data: &serde_json::Value, )

libs/database/src/quick_note.rs:8

↓ 1 callersFunctioninsert_new_template_category

( executor: E, name: &str, description: &str, icon: &str, bg_color: &str, category_type: TemplateC

libs/database/src/template.rs:14

↓ 1 callersFunctioninsert_non_orginal_workspace_publish_namespace

( pg_pool: &PgPool, workspace_id: &Uuid, new_namespace: &str, )

libs/database/src/publish.rs:59

↓ 1 callersFunctioninsert_reaction_on_comment

( executor: E, comment_id: &Uuid, view_id: &Uuid, user_uuid: &Uuid, reaction_type: &str, )

libs/database/src/workspace.rs:1435

↓ 1 callersFunctioninsert_snapshot_meta

( workspace_id: &Uuid, oid: &Uuid, meta: SnapshotMetaPb, partition_key: i32, executor: E, )

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

↓ 1 callersFunctioninsert_snapshot_state

( workspace_id: &Uuid, oid: &Uuid, doc_state: Vec<u8>, doc_state_version: i32, deps_snapshot_id: Opt

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

↓ 1 callersFunctioninsert_template_creator

( executor: E, name: &str, avatar_url: &str, account_links: &[AccountLink], )

libs/database/src/template.rs:176

↓ 1 callersFunctioninsert_template_view

( executor: E, view_id: Uuid, name: &str, description: &str, about: &str, view_url: &str, creato

libs/database/src/template.rs:479

↓ 1 callersMethodinsert_user

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

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

↓ 1 callersFunctioninsert_workspace_ids_to_deleted_table

( executor: E, workspace_ids: Vec<Uuid>, )

libs/database/src/workspace.rs:969

↓ 1 callersFunctioninsert_workspace_invitation

( txn: &mut Transaction<'_, sqlx::Postgres>, invite_id: &uuid::Uuid, workspace_id: &uuid::Uuid, invite

libs/database/src/workspace.rs:244

↓ 1 callersFunctioninsert_workspace_invite_code

( executor: E, workspace_id: &Uuid, code: &str, expires_at: Option<&chrono::DateTime<Utc>>, )

libs/database/src/workspace.rs:1832

↓ 1 callersMethodinto_error

(self)

libs/shared-entity/src/response.rs:75

↓ 1 callersMethodinto_ids

(&self)

libs/shared-entity/src/dto/workspace_dto.rs:470

↓ 1 callersMethodinto_message

(self)

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

↓ 1 callersMethodinto_text

Attempt to consume the WebSocket message and convert it to a String.

libs/client-websocket/src/message.rs:86

↓ 1 callersMethodinvite

(&self, email: &str)

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

↓ 1 callersFunctioninvite_code_scope

()

src/api/invite_code.rs:14

↓ 1 callersFunctioninvite_user_to_workspace

( access_token: &str, workspace_id: &str, user_email: &str, appflowy_cloud_base_url: &str, )

admin_frontend/src/ext/api.rs:198

↓ 1 callersFunctioninvite_user_to_workspace

( workspace_id: &Uuid, owner: &Client, member: &Client, member_email: &str, )

tests/workspace/workspace_settings.rs:58

↓ 1 callersFunctioninvite_workspace_members

( mailer: &AFCloudMailer, pg_pool: &PgPool, inviter: &Uuid, workspace_id: &Uuid, invitations: Vec<Wo

src/biz/workspace/ops.rs:355

↓ 1 callersFunctionis_admin

(user: &User)

admin_frontend/src/web_app.rs:523

↓ 1 callersFunctionis_apple_user

(auth: &Authorization)

src/biz/user/user_delete.rs:113

↓ 1 callersMethodis_at_least

Check if this permission is at least as high as another permission

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

↓ 1 callersMethodis_binary

Indicates whether a message is a binary message.

libs/client-websocket/src/message.rs:37

↓ 1 callersMethodis_blob_exist

(&self, object_key: &str)

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

↓ 1 callersFunctionis_collab_exists

( oid: &Uuid, executor: E, )

libs/database/src/collab/collab_db_ops.rs:535

↓ 1 callersMethodis_connecting

(&self)

libs/client-api/src/ws/state.rs:42

↓ 1 callersMethodis_empty

Returns true if the WebSocket message has no content. For example, if the other side of the connection sent an empty string.

libs/client-websocket/src/message.rs:69

↓ 1 callersMethodis_file_not_found

(&self)

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

↓ 1 callersMethodis_higher_than

Check if this permission is higher than another permission

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

↓ 1 callersMethodis_image

(&self)

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

↓ 1 callersMethodis_inactive

Check if the group is active. A group is considered active if it has at least one subscriber

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

↓ 1 callersMethodis_network_error

(&self)

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

↓ 1 callersMethodis_ping_sync

(&self)

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

↓ 1 callersFunctionis_task_expired

(created_timestamp: i64, last_process_at: Option<i64>)

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

↓ 1 callersMethodis_time_for_next_sync

Indicate the duration is passed since the last sync. The last sync timestamp will be updated after sending a new message

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

↓ 1 callersMethodis_too_many_message

(&self)

services/appflowy-collaborate/src/error.rs:113

↓ 1 callersMethodis_unauthorized

(&self)

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

↓ 1 callersFunctionis_user_exist

( executor: E, user_uuid: &Uuid, )

libs/database/src/user.rs:189

↓ 1 callersMethodis_v1_encoded

(&self)

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

↓ 1 callersFunctionis_view_searchable

(view: &View, workspace_id: &str)

src/biz/search/ops.rs:26

↓ 1 callersMethodjoin_workspace_by_invitation_code

( &self, invitation_code: &str, )

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

↓ 1 callersFunctionjoin_workspace_invite_by_code

( pg_pool: &PgPool, invitation_code: &str, uid: i64, )

src/biz/workspace/invite.rs:36

↓ 1 callersMethodjson_value

(&self)

libs/gotrue/src/grant.rs:29

↓ 1 callersMethodlast_message_id

(&self)

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

↓ 1 callersMethodlast_message_id

(&self)

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

↓ 1 callersFunctionleave_workspace

( pg_pool: &PgPool, workspace_id: &Uuid, user_uuid: &Uuid, workspace_access_control: Arc<dyn Workspace

src/biz/workspace/ops.rs:521

↓ 1 callersFunctionleave_workspace

( access_token: &str, workspace_id: &str, appflowy_cloud_base_url: &str, )

admin_frontend/src/ext/api.rs:226

↓ 1 callersFunctionlist_collab_publish_info

( publish_collab_store: &dyn PublishedCollabStore, collab_instance_cache: &impl WorkspaceCollabInstanceCac

src/biz/workspace/publish.rs:203

↓ 1 callersMethodlist_collab_publish_info

( &self, workspace_id: &Uuid, )

src/biz/workspace/publish.rs:375

↓ 1 callersFunctionlist_database

( pg_pool: &PgPool, collab_instance_cache: &impl WorkspaceCollabInstanceCache, collab_storage: &Arc<dyn

src/biz/collab/ops.rs:348

↓ 1 callersFunctionlist_database_row_details

( collab_storage: &Arc<dyn CollabStore>, uid: i64, workspace_uuid: Uuid, database_uuid: Uuid, row_id

src/biz/collab/ops.rs:859

↓ 1 callersFunctionlist_database_row_ids_updated

( collab_storage: &Arc<dyn CollabStore>, pg_pool: &PgPool, workspace_uuid: Uuid, database_uuid: Uuid,

src/biz/collab/ops.rs:841

↓ 1 callersMethodlist_database_row_ids_updated

( &self, workspace_id: &Uuid, database_id: &str, after: Option<DateTime<Utc>>, )

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

↓ 1 callersFunctionlist_quick_notes

( pg_pool: &PgPool, uid: i64, workspace_id: Uuid, search_term: Option<String>, offset: Option<i32>,

src/biz/workspace/quick_note.rs:43

↓ 1 callersFunctionlist_workspace_invitations_for_user

( pg_pool: &PgPool, user_uuid: &Uuid, status: Option<AFWorkspaceInvitationStatus>, )

src/biz/workspace/ops.rs:470

↓ 1 callersFunctionlisten_on_user_change

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

src/api/ws.rs:231

↓ 1 callersMethodlive_collab_updates

Reads all collab updates for a given `workspace_id`:`object_id` entry, starting from a given message id. This stream will be kept alive and pass over

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

↓ 1 callersMethodload_if_changed

Returns a collab state (with GC turned off), but only if there were any pending updates waiting to be merged into main document state.

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

↓ 1 callersMethodload_policy

(&mut self, model: &mut dyn Model)

libs/access-control/src/casbin/adapter.rs:99

↓ 1 callersFunctionload_workspace_policies

Loads workspace policies from a given stream of workspace member permissions. This function iterates over the stream of member permissions, construct

libs/access-control/src/casbin/adapter.rs:75

↓ 1 callersFunctionlocalhost_gotrue_client

()

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

↓ 1 callersFunctionlog_message_map

(messages_map: &HashMap<String, Vec<ClientCollabMessage>>)

libs/client-api/src/ws/msg_queue.rs:174

↓ 1 callersMethodlogout

(&self, access_token: &str)

libs/gotrue/src/api.rs:130

↓ 1 callersFunctionmake_client_id_key

(workspace_id: &Uuid)

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

↓ 1 callersMethodmark_as_dirty

(&self, object_id: Uuid, millis_secs: MillisSeconds)

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

↓ 1 callersMethodmark_as_editing

(&self, oid: Uuid)

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

↓ 1 callersMethodmerge

(&self)

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

↓ 1 callersMethodmerge

(&mut self, other: &Self, maximum_payload_size: &usize)

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

↓ 1 callersMethodmerge_payload

(&mut self, other: &Self)

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

↓ 1 callersFunctionmetrics_scope

()

src/api/metrics.rs:17

↓ 1 callersFunctionmigrate

(pool: &PgPool)

src/application.rs:531

↓ 1 callersMethodmodified_at

(&self)

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

↓ 1 callersFunctionmove_all_views_out_from_trash

(folder: &mut Folder, uid: i64)

src/biz/workspace/page_view.rs:1000

↓ 1 callersFunctionmove_page

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

src/biz/workspace/page_view.rs:1355

↓ 1 callersFunctionmove_page_to_trash

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

src/biz/workspace/page_view.rs:1405

↓ 1 callersFunctionmove_view

( view_id: &str, new_parent_view_id: &str, prev_view_id: Option<String>, folder: &mut Folder, uid: i

src/biz/workspace/page_view.rs:898

↓ 1 callersFunctionmove_view_out_from_trash

( view_id: &str, folder: &mut Folder, uid: i64, )

src/biz/workspace/page_view.rs:948

↓ 1 callersFunctionmove_view_to_trash

( view_id: &str, folder: &mut Folder, uid: i64, )

src/biz/workspace/page_view.rs:915

↓ 1 callersMethodmove_workspace_page_view

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

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

↓ 1 callersFunctionname_from_user_metadata

Best effort to get user's name after oauth

src/biz/user/user_verify.rs:77

↓ 1 callersFunctionnext_batch_message

( maximum_init_sync: usize, maximum_payload_size: usize, queue: &Arc<Mutex<BinaryHeap<ClientCollabMessag

libs/client-api/src/ws/msg_queue.rs:139

↓ 1 callersFunctionnum_of_unsynced_collab

(cache: Arc<DashMap<ObjectId, CachedCollab>>)

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

↓ 1 callersFunctionnum_pending_task

(uid: i64, pg_pool: &PgPool)

src/biz/workspace/ops.rs:719

↓ 1 callersMethodoauth_providers

(&self)

libs/gotrue-entity/src/dto.rs:124

↓ 1 callersMethodobject_id

(&self)

libs/access-control/src/entity.rs:33

↓ 1 callersMethodobject_id

(&self)

libs/collab-rt-entity/src/message.rs:94

↓ 1 callersFunctionobserve_awareness

( actor: &Arc<WorkspaceControllerActor>, collab_type: CollabType, object_id: ObjectId, client_id: Clie

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

↓ 1 callersMethodobserve_snapshot_duration

(&self, duration: std::time::Duration)

services/appflowy-collaborate/src/metrics.rs:241

↓ 1 callersMethodobserve_snapshot_updates_count

(&self, count: usize)

services/appflowy-collaborate/src/metrics.rs:245

↓ 1 callersFunctionobserve_update

( collab_type: CollabType, object_id: ObjectId, sync_state: Arc<State>, last_message_id: Arc<ArcSwap<R

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

↓ 1 callersMethodopen

Load the testing data at the specified file. If the filename ends in .gz, it will be transparently uncompressed. This method panics if the file does

tests/collab/util.rs:227

↓ 1 callersFunctionopen_ai_config

()

libs/indexer/src/vector/embedder.rs:51

↓ 1 callersMethodopen_collab

( &mut self, workspace_id: Uuid, object_id: Uuid, collab_type: CollabType, )

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

↓ 1 callersMethodopen_collab_with_doc_state

( &mut self, workspace_id: Uuid, object_id: Uuid, collab_type: CollabType, doc_state: Vec<

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

↓ 1 callersFunctionopen_workspace

Returns the workspace with the given workspace_id and update the updated_at field of the workspace.

src/biz/workspace/ops.rs:304

↓ 1 callersMethodopen_workspace

(&self, workspace_id: &Uuid)

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

← previous next →1,201–1,300 of 3,042, ranked by callers