rivetkit_core/actor/
mod.rs

1pub mod action;
2#[cfg(all(feature = "sqlite-local", unix))]
3pub mod actor_runtime_socket;
4#[cfg(all(feature = "sqlite-local", not(unix)))]
5#[path = "actor_runtime_socket_unsupported.rs"]
6pub mod actor_runtime_socket;
7pub mod config;
8pub mod connection;
9pub mod context;
10pub(crate) mod diagnostics;
11pub mod factory;
12pub(crate) mod internal_storage;
13pub(crate) mod keys;
14pub mod kv;
15pub mod lifecycle_hooks;
16pub mod messages;
17pub mod metrics;
18pub(crate) mod migrate_kv_to_sqlite;
19pub mod persist;
20pub mod queue;
21pub mod schedule;
22pub mod sleep;
23#[cfg(test)]
24#[path = "../../tests/sql_efficiency.rs"]
25mod sql_efficiency;
26pub mod sqlite;
27pub mod state;
28pub mod task;
29pub mod task_types;
30pub(crate) mod work_registry;
31
32pub use action::ActionDispatchError;
33#[cfg(feature = "sqlite-local")]
34pub use actor_runtime_socket::ActorRuntimeSocketEndpointInfo;
35pub use config::{ActionDefinition, ActorConfig, ActorConfigOverrides, CanHibernateWebSocket};
36pub use connection::ConnHandle;
37pub use context::{ActorContext, ActorWorkRegion, KeepAwakeRegion, WebSocketCallbackRegion};
38pub use factory::{ActorEntryFn, ActorFactory};
39pub use lifecycle_hooks::{ActorEvents, ActorStart, Reply};
40pub use messages::{
41	ActorEvent, QueueSendResult, QueueSendStatus, Request, Response, StateDelta, WorkflowKvWrite,
42};
43pub use queue::{
44	CompletableQueueMessage, EnqueueAndWaitOpts, QueueMessage, QueueNextBatchOpts, QueueNextOpts,
45	QueueTryNextBatchOpts, QueueTryNextOpts, QueueWaitOpts,
46};
47pub use sqlite::{
48	BindParam, ColumnValue, ExecResult, ExecuteResult, QueryResult, SqliteBackend,
49	SqliteBatchStatement, SqliteDb, SqliteTransaction,
50};
51pub use state::RequestSaveOpts;
52pub use task::{
53	ActionDispatchResult, ActorTask, DispatchCommand, HttpDispatchResult, LifecycleCommand,
54	LifecycleEvent, LifecycleState,
55};
56pub use task_types::{ActorChildOutcome, ShutdownKind, StateMutationReason, UserTaskKind};
57pub use work_registry::{ActorWorkKind, ActorWorkPolicy};
rivetkit_core/actor/mod.rs

rivetkit_core/actor/
mod.rs
