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
Methodhandle
(&mut self, new_conn: Connect, _ctx: &mut Context<Self>)
services/appflowy-collaborate/src/actix_ws/server/rt_actor.rs:62
Methodhandle
(&mut self, _msg: ClientWebSocketMessage, _ctx: &mut Self::Context)
tests/websocket/actor_test.rs:156
Methodhandle_action
(actor: &Arc<Self>, action: WorkspaceAction)
libs/client-api/src/v2/actor.rs:313
Methodhandle_awareness_update
( state: &CollabGroupState, origin: &CollabOrigin, update: Vec<u8>, )
services/appflowy-collaborate/src/group/group_init.rs:849
Methodhandle_client_message
( &self, user: RealtimeUser, message_by_oid: MessageByObjectId, )
services/appflowy-collaborate/src/rt_server.rs:134
Methodhandle_connect
( actor: &Arc<Self>, access_token: String, )
libs/client-api/src/v2/actor.rs:457
Methodhandle_inbound_awareness
(state: &CollabGroupState, update: &AwarenessStreamUpdate)
services/appflowy-collaborate/src/group/group_init.rs:295
Methodhandle_inbound_update
(state: &CollabGroupState, update: CollabStreamUpdate)
services/appflowy-collaborate/src/group/group_init.rs:211
Methodhandle_message
( state: &CollabGroupState, payload: &[u8], message_origin: &CollabOrigin, msg_id: MsgId, )
services/appflowy-collaborate/src/group/group_init.rs:590
Methodhandle_messages
( state: &CollabGroupState, sink: &mut Sink, msg: MessageByObjectId, )
services/appflowy-collaborate/src/group/group_init.rs:512
Functionhandle_process_exit
(status: std::process::ExitStatus, process_name: &str)
xtask/src/main.rs:222
Methodhandle_protocol_message
( state: &CollabGroupState, origin: &CollabOrigin, msg: Message, )
services/appflowy-collaborate/src/group/group_init.rs:655
Methodhandle_sync_step1
( state: &CollabGroupState, client_sv: &StateVector, )
services/appflowy-collaborate/src/group/group_init.rs:673
Methodhandle_sync_step2
( state: &CollabGroupState, origin: &CollabOrigin, update: Vec<u8>, )
services/appflowy-collaborate/src/group/group_init.rs:741
Functionhandle_tick
( sender: &AggregateMessagesSender, queue: &Arc<Mutex<BinaryHeap<ClientCollabMessage>>>, maximum_payload
libs/client-api/src/ws/msg_queue.rs:83
Methodhandle_update
( state: &CollabGroupState, origin: &CollabOrigin, update: Vec<u8>, )
services/appflowy-collaborate/src/group/group_init.rs:841
Methodhas
(&self, k: &K)
libs/access-control/src/casbin/redis_cache.rs:53
Methodhash
(&self, state: &mut H)
libs/client-api/src/v2/actor.rs:1244
Methodhash
(&self, state: &mut H)
libs/collab-rt-entity/src/client_message.rs:205
Functionhealth_check
()
src/application.rs:549
Functionimport_blog_post_test
()
tests/workspace/import_test.rs:13
Functionimport_data_handler
( user_uuid: UserUuid, state: Data<AppState>, mut payload: Multipart, req: HttpRequest, )
src/api/data_import.rs:146
Functionimport_project_and_task_zip_test
()
tests/workspace/import_test.rs:91
Functionimported_workspace_do_not_become_latest_visit_workspace_test
()
tests/workspace/import_test.rs:165
Methodinbound_awareness_task
Task used to receive awareness updates from Redis.
services/appflowy-collaborate/src/group/group_init.rs:268
Methodinbound_task
Task used to receive collab updates from Redis.
services/appflowy-collaborate/src/group/group_init.rs:177
Methodincr_decoding_failure_count
(&self, count: i64)
src/api/metrics.rs:281
Functionindex_search
()
libs/appflowy-ai-client/tests/index_test/index_search_test.rs:5
Functionindex_workspace
(scheduler: Arc<IndexerScheduler>, workspace_id: Uuid)
libs/indexer/src/unindexed_workspace.rs:34
Methodinit
()
services/appflowy-worker/src/metric.rs:12
Methodinit
()
libs/indexer/src/metrics.rs:13
Methodinit_client_communication
Initializes a communication channel for a client and a specific collaboration object. sets up a two-way communication channel between the client and
services/appflowy-collaborate/src/client/client_msg_router.rs:56
Functioninit_sync_workspace_with_member_permission
()
tests/workspace/edit_workspace.rs:11
Methodinit_workspace
( server: Recipient<Terminate>, workspace_id: WorkspaceId, manager: Arc<CollabManager>, snapsh
services/appflowy-collaborate/src/ws2/actors/server.rs:39
Methodinsert_blob_with_retries
( s3: AwsS3BucketClientImpl, key: String, blob: Bytes, mut retries: usize, )
services/appflowy-collaborate/src/collab/cache/disk_cache.rs:570
Functioninsert_bulk_collab_sql_test
(pool: PgPool)
tests/sql_test/workspace_test.rs:70
Functioninsert_collab_embedding_fragment_test
(pool: PgPool)
tests/sql_test/collab_embed_test.rs:19
Functioninsert_collab_sql_test
(pool: PgPool)
tests/sql_test/workspace_test.rs:13
Functioninsert_empty_data_test
()
tests/collab/storage_test.rs:418
Functioninsert_folder_data_success_test
()
tests/collab/storage_test.rs:488
Methodinsert_into
(&self, object_id: &Uuid, key: &str, value: S)
libs/client-api-test/src/test_client_v2.rs:175
Functioninsert_invalid_data_test
()
tests/collab/storage_test.rs:448
Methodinsert_role
( &self, uid: &i64, workspace_id: &Uuid, role: AFRole, )
libs/access-control/src/casbin/workspace.rs:79
Functioninsert_snapshot_test
(pool: PgPool)
tests/sql_test/history_test.rs:11
Functioninsert_text_through_http_post_request
()
tests/collab/single_device_edit.rs:698
Methodinsert_view_to_general_space
( &self, workspace_id: &Uuid, view_id: &str, view_name: &str, view_layout: ViewLayout,
libs/client-api-test/src/test_client_v2.rs:208
Methodinto_bytes
Converts this ClientMessage into a serialized byte array. This is typically used before sending the message over the network.
libs/appflowy-proto/src/client_message.rs:126
Methodinto_bytes
(self)
libs/appflowy-proto/src/server_message.rs:68
Methodinto_data
(self)
libs/shared-entity/src/response.rs:62
Methodinto_inner
(self)
libs/shared-entity/src/dto/auth_dto.rs:19
Methodinto_inner
(self)
libs/collab-rt-entity/src/message.rs:37
Methodinto_response
(self)
admin_frontend/src/response.rs:32
Methodinto_response
(self)
admin_frontend/src/ext/error.rs:20
Methodinto_tuple_array
(self)
libs/collab-stream/src/model.rs:205
Functioninvalid_test
()
tests/file_test/multiple_part_test.rs:306
Functioninvite_accept_handler
( State(state): State<AppState>, session: UserSession, Path(invite_id): Path<String>, )
admin_frontend/src/web_api.rs:196
Methodinvite_and_accepted_workspace_member
( &self, workspace_id: &Uuid, other_client: &TestClient, role: AFRole, )
libs/client-api-test/src/test_client_v2.rs:468
Functioninvite_handler
Invite another user, this will trigger email sending to the target user
admin_frontend/src/web_api.rs:142
Functioninvite_wait_email_sending_success
()
tests/workspace/invitation_crud.rs:157
Functioninvite_workspace_crud
()
tests/workspace/invitation_crud.rs:8
Methodis_allowed
Check if this CloseCode is allowed.
libs/client-websocket/src/message.rs:262
Methodis_awareness_sync
(&self)
libs/collab-rt-entity/src/client_message.rs:195
Methodis_blob_exist
(&self, _object_key: &str)
services/appflowy-worker/tests/import_test.rs:224
Methodis_cannot_apply_update
(&self)
libs/client-api/src/collab_sync/error.rs:100
Methodis_close
Indicates whether a message ia s close message.
libs/client-websocket/src/message.rs:52
Methodis_connected
(&self)
libs/client-api/src/v2/controller.rs:62
Methodis_connected
(&self)
libs/client-api/src/ws/state.rs:46
Methodis_connected
(&self)
libs/client-api/src/ws/client.rs:377
Methodis_create_group_failed
(&self)
services/appflowy-collaborate/src/error.rs:120
Methodis_disconnected
(&self)
libs/client-api/src/v2/controller.rs:69
Methodis_empty
(&self)
libs/collab-rt-entity/src/message.rs:191
Methodis_exist
(&self, workspace_id: &Uuid, object_id: &Uuid)
services/appflowy-collaborate/src/collab/cache/disk_cache.rs:57
Methodis_exist
(&self, workspace_id: &Uuid, oid: &Uuid)
services/appflowy-collaborate/src/collab/cache/collab_cache.rs:687
Methodis_filtered
(&self)
libs/access-control/src/casbin/adapter.rs:132
Methodis_indexing_enabled
(&self, collab_type: CollabType)
libs/indexer/src/collab_indexer/provider.rs:66
Methodis_lock_timeout
(&self)
services/appflowy-collaborate/src/error.rs:117
Methodis_lost
(&self)
libs/client-api/src/ws/state.rs:56
Methodis_network_error
(&self)
libs/app-error/src/gotrue.rs:34
Methodis_not_enough_permissions
(&self)
libs/app-error/src/lib.rs:217
Methodis_ping
Indicates whether a message is a ping message.
libs/client-websocket/src/message.rs:42
Methodis_pong
Indicates whether a message is a pong message.
libs/client-websocket/src/message.rs:47
Methodis_record_not_found
(&self)
libs/shared-entity/src/response.rs:162
Methodis_server_init_sync
(&self)
libs/collab-rt-entity/src/client_message.rs:187
Methodis_stream_not_exist
(&self)
libs/collab-stream/src/error.rs:49
Methodis_syncing
(&self)
libs/client-api/src/collab_sync/collab_sink.rs:566
Methodis_text
Indicates whether a message is a text message.
libs/client-websocket/src/message.rs:32
Methodis_update_sync
(&self)
libs/collab-rt-entity/src/client_message.rs:191
Methodis_user_unauthorized
(&self)
libs/shared-entity/src/response.rs:166
Functionis_workspace_exist
( executor: E, workspace_id: &Uuid, )
libs/database/src/workspace.rs:1190
Functionjoin_workspace_by_invite_code
()
tests/workspace/join_workspace.rs:5
Methodjson_response_stream
( resp: reqwest::Response, )
libs/shared-entity/src/response_stream.rs:21
Methodjson_str_to_document
(json_str: &str)
libs/workspace-template/src/document/parser.rs:37
Methodjson_to_document
(json_value: serde_json::Value)
libs/workspace-template/src/document/parser.rs:42
Methodlast_message_id
(&self, workspace_id: &WorkspaceId)
libs/client-api/src/v2/db.rs:318
Functionlatest_snapshot_time
( oid: &Uuid, executor: E, )
libs/database/src/collab/collab_db_ops.rs:372
Methodlayout
(&self)
libs/workspace-template/src/document/getting_started.rs:178
Functionlease_acquisition
()
libs/collab-stream/src/lease.rs:115
Functionleave_workspace_handler
( user_uuid: UserUuid, state: Data<AppState>, workspace_id: web::Path<Uuid>, )
src/api/workspace.rs:790
Functionleave_workspace_handler
( State(state): State<AppState>, session: UserSession, Path(workspace_id): Path<String>, )
admin_frontend/src/web_api.rs:181
Functionlist_database_handler
( user_uuid: UserUuid, workspace_id: web::Path<Uuid>, state: Data<AppState>, )
src/api/workspace.rs:2402
← previousnext →2,201–2,300 of 3,042, ranked by callers