rivetkit 2.3.17

Rust SDK for RivetKit actors, actions, events, queues, and test harnesses
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

#![recursion_limit = "256"]

pub mod action;
pub mod actor;
pub mod context;
pub mod event;
pub mod persist;
pub mod prelude;
pub mod queue;
pub mod registry;
mod serverless_listener;
pub mod sqlite;
pub mod start;
pub mod test;
pub mod typed_client;

pub use crate::{
	action::{Action, ActionEntry, ActionSet, Handles, Raw},
	actor::{Actor, HttpCallbackAdmission, HttpCallbackClass},
	context::{
		ConnCtx, ConnIter, Cron, CronEveryOptions, CronJobInfo, CronSetOptions, Ctx, Schedule,
		StateMut, StateRef,
	},
	event::{
		ActionCall, ConnClosed, ConnOpen, Destroy, Event, EventEntry, EventSet, HttpCall,
		HttpReply, RuntimeEvent, SerializeState, Sleep, Subscribe, WsOpen,
	},
	queue::{HandlesQueue, Queue, QueueEntry, QueueMessage, QueueSet, TypedQueueMessage},
	registry::Registry,
	sqlite::{SqliteDbExt, SqliteTransactionOptions},
	start::{Events, Hibernated, Input, Snapshot, Start, run_actor},
	typed_client::{IntoActorKey, TypedActorConnection, TypedActorHandle, TypedClientExt},
};
pub use rivetkit_client as client;
pub use rivetkit_core::actor::schedule::{
	CronFire, ScheduleErrorInfo, ScheduleKind, ScheduledEventInfo, ScheduledFireInfo,
};
pub use rivetkit_core::actor::state::OnStateChangeGuard;
pub use rivetkit_core::inspector::InspectorTabEntry;
pub use rivetkit_core::metrics_endpoint::RenderedMetrics;
pub use rivetkit_core::serverless::{
	CoreServerlessRuntime, ServerlessRequest, ServerlessResponse, ServerlessStreamError,
};
pub use rivetkit_core::serverless_http;
pub use rivetkit_core::{
	ActorConfig, ActorHttpResponse, ActorKey, ActorKeySegment, ActorKv, CanHibernateWebSocket,
	CompletableQueueMessage, ConnHandle, ConnId, EngineSpawnMode, EnqueueAndWaitOpts,
	HTTP_BODY_STREAM_CHANNEL_CAPACITY, KeepAwakeRegion, ListOpts, QueueMessage as CoreQueueMessage,
	QueueNextBatchOpts, QueueNextOpts, QueueTryNextBatchOpts, QueueTryNextOpts, QueueWaitOpts,
	Request, RequestSaveOpts, Response, ResponseChunk, RuntimeMode, SaveStateOpts,
	SerializeStateReason, ServeConfig, SqliteBatchStatement, SqliteDb, SqliteTransaction,
	StateDelta, StreamingResponse, WebSocket, WsMessage,
	sqlite::{BindParam, ColumnValue, ExecResult, QueryResult},
};