Skip to main content

Crate rivetkit

Crate rivetkit 

Source

Re-exports§

pub use crate::action::Action;
pub use crate::action::ActionEntry;
pub use crate::action::ActionSet;
pub use crate::action::Handles;
pub use crate::action::Raw;
pub use crate::actor::Actor;
pub use crate::actor::HttpCallbackAdmission;
pub use crate::actor::HttpCallbackClass;
pub use crate::context::ConnCtx;
pub use crate::context::ConnIter;
pub use crate::context::Cron;
pub use crate::context::CronEveryOptions;
pub use crate::context::CronJobInfo;
pub use crate::context::CronSetOptions;
pub use crate::context::Ctx;
pub use crate::context::Schedule;
pub use crate::context::StateMut;
pub use crate::context::StateRef;
pub use crate::event::ActionCall;
pub use crate::event::ConnClosed;
pub use crate::event::ConnOpen;
pub use crate::event::Destroy;
pub use crate::event::Event;
pub use crate::event::EventEntry;
pub use crate::event::EventSet;
pub use crate::event::HttpCall;
pub use crate::event::HttpReply;
pub use crate::event::RuntimeEvent;
pub use crate::event::SerializeState;
pub use crate::event::Sleep;
pub use crate::event::Subscribe;
pub use crate::event::WsOpen;
pub use crate::queue::HandlesQueue;
pub use crate::queue::Queue;
pub use crate::queue::QueueEntry;
pub use crate::queue::QueueMessage;
pub use crate::queue::QueueSet;
pub use crate::queue::TypedQueueMessage;
pub use crate::registry::Registry;
pub use crate::sqlite::SqliteDbExt;
pub use crate::sqlite::SqliteTransactionOptions;
pub use crate::start::Events;
pub use crate::start::Hibernated;
pub use crate::start::Input;
pub use crate::start::Snapshot;
pub use crate::start::Start;
pub use crate::start::run_actor;
pub use crate::typed_client::IntoActorKey;
pub use crate::typed_client::TypedActorConnection;
pub use crate::typed_client::TypedActorHandle;
pub use crate::typed_client::TypedClientExt;
pub use rivetkit_client as client;

Modules§

action
actor
context
event
persist
prelude
queue
registry
serverless_http
sqlite
start
test
In-process end-to-end test helpers for Rust actors.
typed_client

Structs§

ActorConfig
ActorKv
CompletableQueueMessage
ConnHandle
CoreQueueMessage
CoreServerlessRuntime
CronFire
EnqueueAndWaitOpts
ExecResult
KeepAwakeRegion
ListOpts
OnStateChangeGuard
QueryResult
QueueNextBatchOpts
QueueNextOpts
QueueTryNextBatchOpts
QueueTryNextOpts
QueueWaitOpts
RenderedMetrics
Request
RequestSaveOpts
Response
SaveStateOpts
ScheduleErrorInfo
ScheduledEventInfo
ScheduledFireInfo
ServeConfig
ServerlessRequest
ServerlessResponse
ServerlessStreamError
SqliteBatchStatement
SqliteDb
SqliteTransaction
StreamingResponse
WebSocket

Enums§

ActorHttpResponse
ActorKeySegment
BindParam
CanHibernateWebSocket
ColumnValue
EngineSpawnMode
InspectorTabEntry
Inspector tab declaration carried on ActorConfig. Either a custom tab (id + label + source root) or a hide modifier for a built-in tab. Validation of id collisions and source presence happens upstream in the TypeScript Zod schema or the Rust builder; validate_inspector_tabs below is the runtime authority that closes the gap when direct Rust callers bypass the upstream layers.
ResponseChunk
A chunk in a streaming HTTP response.
RuntimeMode
Selects how Registry::start runs, mirroring the TypeScript RIVETKIT_RUNTIME_MODE env var. Envoy holds one long-lived outbound envoy for the process lifetime; Serverless runs an HTTP listener that lazily starts and caches an envoy on the first request.
ScheduleKind
SerializeStateReason
StateDelta
WsMessage

Constants§

HTTP_BODY_STREAM_CHANNEL_CAPACITY

Type Aliases§

ActorKey
ConnId