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
Methodnew
()
libs/infra/src/thread_pool.rs:70
Methodnew
(stream: S)
libs/infra/src/reqwest.rs:68
Methodnew
()
libs/access-control/src/metrics.rs:101
Methodnew
(uid: i64, object_type: ObjectType, action: T)
libs/access-control/src/request.rs:11
Methodnew
()
libs/access-control/src/noops/collab.rs:15
Methodnew
()
libs/access-control/src/noops/workspace.rs:13
Methodnew
(pg_pool: PgPool, access_control_metrics: Arc<AccessControlMetrics>)
libs/access-control/src/casbin/adapter.rs:28
Methodnew
(mut enforcer: CachedEnforcer)
libs/access-control/src/casbin/enforcer.rs:52
Methodnew
(access_control: AccessControl)
libs/access-control/src/casbin/collab.rs:20
Methodnew
(enforcer: CachedEnforcer)
libs/access-control/src/casbin/enforcer_v2.rs:63
Methodnew
( pg_pool: PgPool, redis_uri: Option<&str>, access_control_metrics: Arc<AccessControlMetrics>, )
libs/access-control/src/casbin/access.rs:39
Methodnew
(redis_url: T)
libs/access-control/src/casbin/redis_cache.rs:18
Methodnew
(access_control: AccessControl)
libs/access-control/src/casbin/workspace.rs:18
Methodnew
(pg_pool: &PgPool, channel: &str)
libs/database/src/listener.rs:16
Methodnew
( client: Client, bucket: String, endpoint: String, presigned_url_endpoint: Option<String>,
libs/database/src/file/s3_client_impl.rs:42
Methodnew
(client: C, pg_pool: PgPool)
libs/database/src/file/file_storage.rs:83
Methodnew
(registered_user: User, start_ws_conn: bool)
libs/client-api-test/src/test_client.rs:84
Methodnew
(device_id: String, temp_dir: Arc<TempDir>)
libs/client-api-test/src/workspace_ops.rs:19
Methodnew
# Arguments `registered_user` - The user to sign in with `start_ws_conn` - Whether to start websocket connections immediately
libs/client-api-test/src/test_client_v2.rs:86
Methodnew
(api_client: client_api::Client, workspace_id: Uuid, client_id: ClientID)
libs/client-api-test/src/database_util.rs:24
Methodnew
(decoder: &'a mut D)
libs/collab-rt-protocol/src/message.rs:284
Methodnew
(stream: S)
libs/shared-entity/src/response_stream.rs:98
Methodnew
(code: ErrorCode, message: M)
libs/shared-entity/src/response.rs:44
Methodnew
(email: String)
libs/shared-entity/src/dto/workspace_dto.rs:78
Methodnew
()
libs/shared-entity/src/dto/auth_dto.rs:16
Methodnew
(author_id: i64, author_type: ChatAuthorType)
libs/shared-entity/src/dto/chat_dto.rs:335
Methodnew
( indexer_provider: Arc<IndexerProvider>, pg_pool: PgPool, storage: Arc<dyn CollabStore>, metr
libs/indexer/src/scheduler.rs:58
Methodnew
(config: OpenAIConfig)
libs/indexer/src/vector/open_ai.rs:20
Methodnew
()
libs/indexer/src/collab_indexer/provider.rs:44
Methodnew
( duration: Duration, state: Arc<parking_lot::Mutex<ConnectStateNotify>>, ping_sender: Sender<Mess
libs/client-api/src/ping.rs:22
Methodnew
()
libs/client-api/src/notify.rs:21
Methodnew
Constructs a new `Client` instance. # Parameters - `base_url`: The base URL for API requests. - `ws_addr`: The WebSocket address for real-time commun
libs/client-api/src/http.rs:132
Methodnew
(stream: S)
libs/client-api/src/http_chat.rs:357
Methodnew
(token: Arc<RwLock<ClientToken>>, gotrue_client: gotrue::api::Client)
libs/client-api/src/retry.rs:25
Methodnew
(publish_collab_items: Vec<PublishCollabItem<Metadata, Data>>)
libs/client-api/src/http_collab.rs:551
Methodnew
( object: SyncObject, origin: CollabOrigin, sink: Sink, sink_config: SinkConfig, stream: S
libs/client-api/src/collab_sync/sync_control.rs:55
Methodnew
( origin: CollabOrigin, object: SyncObject, collab: CollabRef, sink: Sink, sink_config: Si
libs/client-api/src/collab_sync/plugin.rs:59
Methodnew
( uid: i64, object: SyncObject, sink: Sink, notifier: watch::Sender<SinkSignal>, sync_stat
libs/client-api/src/collab_sync/collab_sink.rs:57
Methodnew
( origin: CollabOrigin, object: SyncObject, stream: Stream, weak_collab: CollabRef, sink:
libs/client-api/src/collab_sync/collab_stream.rs:59
Methodnew
(options: Options, workspace_db_path: &str)
libs/client-api/src/v2/controller.rs:34
Methodnew
Convenience ctor for production: pass the concrete actor.
libs/client-api/src/v2/conn_retry.rs:69
Methodnew
(db: Db, options: Options, last_message_id: Rid)
libs/client-api/src/v2/actor.rs:65
Methodnew
(receiver: UnboundedReceiver<WorkspaceAction>)
libs/client-api/src/v2/compactor.rs:17
Methodnew
()
libs/client-api/src/ws/state.rs:10
Methodnew
(maximum_payload_size: usize)
libs/client-api/src/ws/msg_queue.rs:25
Methodnew
(object_id: &str, rt_msg_sender: Sender<Vec<ClientCollabMessage>>)
libs/client-api/src/ws/handler.rs:30
Methodnew
(config: WSClientConfig, http_sender: H, connect_provider: C)
libs/client-api/src/ws/client.rs:89
Methodnew
()
libs/gotrue-entity/src/dto.rs:242
Methodnew
(workspace_id: Uuid, uid: i64, params: CollabParams)
libs/database-entity/src/dto.rs:100
Methodnew
(url: &str, headers: HeaderMap)
libs/client-websocket/src/web.rs:21
Methodnew
(uid: i64, workspace_id: &Uuid)
libs/workspace-template/src/lib.rs:67
Methodnew
(workspace_id: String, uid: i64)
libs/workspace-template/src/hierarchy_builder.rs:16
Methodnew
()
libs/appflowy-ai-client/src/dto.rs:49
Methodnew
(url: &str)
libs/appflowy-ai-client/src/client.rs:29
Methodnew
(timestamp: u64, seq_no: u16)
libs/appflowy-proto/src/shared.rs:17
Methodnew
(device_id: &str, uid: i64)
libs/collab-rt-entity/src/user.rs:34
Methodnew
( origin: CollabOrigin, object_id: String, collab_type: CollabType, workspace_id: String,
libs/collab-rt-entity/src/client_message.rs:265
Methodnew
(origin: CollabOrigin, object_id: String, payload: Vec<u8>, msg_id: MsgId)
libs/collab-rt-entity/src/server_message.rs:127
Methodnew
(client: reqwest::Client, base_url: &str)
libs/gotrue/src/api.rs:26
Methodnew
( conn: ConnectionManager, stream_key: String, object_id: ObjectId, collab_type: CollabType,
libs/collab-stream/src/collab_update_sink.rs:16
Methodnew
(client: &Client)
libs/collab-stream/src/awareness_gossip.rs:24
Methodnew
(receiver: StreamReceiver)
libs/collab-stream/src/stream_router.rs:42
Methodnew
(timestamp_ms: u64, sequence_number: u16)
libs/collab-stream/src/model.rs:35
Methodnew
( redis_client: redis::Client, metrics: Arc<CollabStreamMetrics>, )
libs/collab-stream/src/client.rs:29
Methodnew
(node_id: u64)
libs/snowflake/src/lib.rs:17
Methodnew
(config: OpenAIConfig)
libs/llm-client/src/chat.rs:64
Methodnew_ai
(message_id: i64, content: String, reply_message_id: Option<i64>)
libs/shared-entity/src/dto/chat_dto.rs:252
Methodnew_awareness_sync
(data: UpdateSync)
libs/collab-rt-entity/src/client_message.rs:50
Methodnew_for_target
Construct using the default retry config.
libs/client-api/src/v2/conn_retry.rs:64
Methodnew_human
(message_id: i64, content: String, reply_message_id: Option<i64>)
libs/shared-entity/src/dto/chat_dto.rs:241
Methodnew_init_sync
(data: InitSync)
libs/collab-rt-entity/src/client_message.rs:38
Methodnew_internal
(mut enforcer: CachedEnforcer)
libs/access-control/src/casbin/enforcer_v2.rs:88
Methodnew_line_response_stream
( resp: reqwest::Response, )
libs/shared-entity/src/response_stream.rs:45
Methodnew_server_init_sync
(data: ServerInit)
libs/collab-rt-entity/src/client_message.rs:46
Methodnew_system
(content: T)
libs/shared-entity/src/dto/chat_dto.rs:168
Methodnew_text
(content: String)
libs/shared-entity/src/dto/chat_dto.rs:134
Methodnew_transform
(&self, service: S)
src/middleware/request_id.rs:25
Methodnew_transform
(&self, service: S)
src/middleware/metrics_mw.rs:26
Methodnew_update_sync
(data: UpdateSync)
libs/collab-rt-entity/src/client_message.rs:42
Methodnew_user
()
libs/client-api-test/src/test_client.rs:140
Methodnew_user
Creates a new user and test client
libs/client-api-test/src/test_client_v2.rs:153
Methodnew_user
(content: T)
libs/shared-entity/src/dto/chat_dto.rs:176
Methodnew_user_without_ws_conn
()
libs/client-api-test/src/test_client.rs:148
Methodnew_user_without_ws_conn
Creates a new user without websocket connection
libs/client-api-test/src/test_client_v2.rs:163
Methodnew_with_cache_ttl
( uid: i64, workspace_id: WorkspaceId, collab_origin: CollabOrigin, conn: Addr<WsSession>,
services/appflowy-collaborate/src/ws2/actors/workspace.rs:802
Methodnew_with_completion_type
( text: String, completion_type: CompletionType, metadata: Option<CompletionMetadata>, )
libs/appflowy-ai-client/src/dto.rs:451
Methodnew_with_connection_manager
( connection_manager: ConnectionManager, stream_router: Arc<StreamRouter>, awareness_gossip: Arc<A
libs/collab-stream/src/client.rs:53
Methodnew_with_data
(data: Vec<u8>, content_type: Option<String>)
libs/database/src/file/s3_client_impl.rs:544
Methodnew_with_db
(options: Options, db: Db)
libs/client-api/src/v2/controller.rs:44
Methodnew_with_device_id
( device_id: &str, registered_user: User, start_ws_conn: bool, )
libs/client-api-test/src/test_client.rs:105
Methodnew_with_device_id
Creates a new test client with a specific device ID
libs/client-api-test/src/test_client_v2.rs:94
Methodnew_with_message
(object_id: String, messages: Vec<ClientCollabMessage>)
libs/collab-rt-entity/src/message.rs:31
Methodnew_with_redis
( mut enforcer: CachedEnforcer, redis_uri: &str, )
libs/access-control/src/casbin/enforcer_v2.rs:67
Methodnew_with_rocksdb
(options: Options, db: T)
libs/client-api/src/v2/controller.rs:39
Methodnext_back
(limit: u64)
libs/shared-entity/src/dto/chat_dto.rs:211
Methodnext_user_id
(&self)
src/state.rs:71
Functionno_compaction_for_different_object_ids
()
libs/client-api/src/v2/compactor.rs:225
Methodnotify_awareness_change
Send a Redis pub-sub message to notify other clients about the awareness change.
libs/collab-stream/src/awareness_gossip.rs:179
Methodnotify_progress
(&self, progress: ImportProgress)
services/appflowy-worker/tests/import_test.rs:197
Methodnow
()
services/appflowy-collaborate/src/collab/cache/mem_cache.rs:53
← previousnext →2,401–2,500 of 3,042, ranked by callers