Struct SequencerActor 

pub struct SequencerActor;

One repo’s sequencer, hosted on the Rivet runtime.

Trait Implementations

impl Actor for SequencerActor

type State = LogState

type Input = ()

type Actions = (SubmitOp, DumpLog)

type Events = ()

type Queue = ()

type ConnParams = ()

type ConnState = ()

type Action = Raw

fn create_state<'life0, 'async_trait>( _ctx: &'life0 Ctx<Self>, _input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::State>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn create<'life0, 'async_trait>( _ctx: &'life0 Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<Self>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

const HAS_DATABASE: bool = false

fn run<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_create<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_start<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_state_change<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn create_conn_state<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _params: Self::ConnParams, ) -> Pin<Box<dyn Future<Output = Result<Self::ConnState, Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_before_connect<'life0, 'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _params: &'life0 Self::ConnParams, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_connect<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _conn: ConnCtx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_disconnect<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _conn: ConnCtx<Self>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_subscribe<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _conn: ConnCtx<Self>, _event_name: String, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_fetch<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _req: Request, ) -> Pin<Box<dyn Future<Output = Result<Response, Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_websocket<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, _ws: WebSocket, _req: Request, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_sleep<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

fn on_destroy<'async_trait>( self: Arc<Self>, _ctx: Ctx<Self>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait,

impl Handles<DumpLog> for SequencerActor

type Future = Pin<Box<dyn Future<Output = Result<Vec<OpEntry>, Error>> + Send>>

fn handle(self: Arc<Self>, ctx: Ctx<Self>, _op: DumpLog) -> Self::Future

impl Handles<SubmitOp> for SequencerActor

type Future = Pin<Box<dyn Future<Output = Result<SubmitReply, Error>> + Send>>

fn handle(self: Arc<Self>, ctx: Ctx<Self>, op: SubmitOp) -> Self::Future