Skip to main content

Crate rivetkit_core

Crate rivetkit_core 

Source

Re-exports§

pub use actor::kv;
pub use actor::sqlite;
pub use actor::action::ActionDispatchError;
pub use actor::config::ActionDefinition;
pub use actor::config::ActorConfig;
pub use actor::config::ActorConfigInput;
pub use actor::config::ActorConfigOverrides;
pub use actor::config::CanHibernateWebSocket;
pub use actor::connection::ConnHandle;
pub use actor::context::ActorContext;
pub use actor::context::ActorKv;
pub use actor::context::ActorWorkRegion;
pub use actor::context::KeepAwakeRegion;
pub use actor::context::WebSocketCallbackRegion;
pub use actor::factory::ActorEntryFn;
pub use actor::factory::ActorFactory;
pub use actor::lifecycle_hooks::ActorEvents;
pub use actor::lifecycle_hooks::ActorStart;
pub use actor::lifecycle_hooks::Reply;
pub use actor::messages::ActorEvent;
pub use actor::messages::ActorHttpResponse;
pub use actor::messages::QueueSendResult;
pub use actor::messages::QueueSendStatus;
pub use actor::messages::Request;
pub use actor::messages::Response;
pub use actor::messages::SerializeStateReason;
pub use actor::messages::StateDelta;
pub use actor::messages::StreamingResponse;
pub use actor::messages::WorkflowKvWrite;
pub use actor::queue::CompletableQueueMessage;
pub use actor::queue::EnqueueAndWaitOpts;
pub use actor::queue::QueueMessage;
pub use actor::queue::QueueNextBatchOpts;
pub use actor::queue::QueueNextOpts;
pub use actor::queue::QueueTryNextBatchOpts;
pub use actor::queue::QueueTryNextOpts;
pub use actor::queue::QueueWaitOpts;
pub use actor::sqlite::SqliteBackend;
pub use actor::sqlite::SqliteBatchStatement;
pub use actor::sqlite::SqliteDb;
pub use actor::sqlite::SqliteTransaction;
pub use actor::state::RequestSaveOpts;
pub use actor::task::ActionDispatchResult;
pub use actor::task::ActorTask;
pub use actor::task::DispatchCommand;
pub use actor::task::HttpDispatchResult;
pub use actor::task::LifecycleCommand;
pub use actor::task::LifecycleEvent;
pub use actor::task::LifecycleState;
pub use actor::task_types::ShutdownKind;
pub use error::ActorLifecycle;
pub use inspector::Inspector;
pub use inspector::InspectorSnapshot;
pub use registry::CoreRegistry;
pub use registry::EngineSpawnMode;
pub use registry::ServeConfig;
pub use runtime::RuntimeBoxFuture;
pub use runtime::RuntimeSpawner;
pub use runtime::boxed_runtime_future;
pub use serverless::CoreServerlessRuntime;
pub use serverless::ServerlessRequest;
pub use serverless::ServerlessResponse;
pub use types::ActorKey;
pub use types::ActorKeySegment;
pub use types::ConnId;
pub use types::ListOpts;
pub use types::SaveStateOpts;
pub use types::WsMessage;
pub use types::format_actor_key;
pub use websocket::WebSocket;

Modules§

actor
engine_process
The rivet-engine subprocess manager lives in the standalone rivetkit-engine-process crate so the CLI and other hosts can reuse the same resolution, spawn, reuse, and orphan-lifetime logic. This module re-exports it for existing in-crate callers.
error
inspector
inspector_bundle
Inspector UI bundle serving for the shared inspector paths:
metrics_endpoint
registry
runtime
serverless
serverless_http
types
websocket

Structs§

ActorWorkPolicy
Defines how a work kind participates in idle sleep and shutdown grace.
ExecResult
ExecuteResult
HttpRequestBodyStream
QueryResult

Enums§

ActorWorkKind
Classifies actor work so sleep can apply one policy model across different APIs.
BindParam
ColumnValue
ResponseChunk
A chunk in a streaming HTTP response.

Constants§

HTTP_BODY_STREAM_CHANNEL_CAPACITY