Skip to main content

ToActor

rivet_envoy_client::actor

Enum ToActor

pub enum ToActor {
Show 17 variants    Intent {
        intent: ActorIntent,
        error: Option<String>,
    },
    Stop {
        command_idx: i64,
        reason: StopActorReason,
    },
    Lost,
    SetAlarm {
        alarm_ts: Option<i64>,
        ack_tx: Option<Sender<()>>,
    },
    ReqStart {
        message_id: MessageId,
        req: ToEnvoyRequestStart,
        connection_session: u64,
    },
    ConnectionClosed {
        session: u64,
    },
    ReqChunk {
        message_id: MessageId,
        chunk: ToEnvoyRequestChunk,
    },
    ReqAbort {
        message_id: MessageId,
        reason: HttpStreamAbortReason,
    },
    ReqProtocolViolation {
        message_id: MessageId,
        detail: String,
    },
    ReqBodyCancelled {
        message_id: MessageId,
    },
    ReqBodyCancel {
        message_id: MessageId,
    },
    ResponseBodyWindowUpdate {
        message_id: MessageId,
        consumed_bytes: u64,
    },
    ReqComplete {
        message_id: MessageId,
    },
    WsOpen {
        message_id: MessageId,
        path: String,
        headers: BTreeMap<String, String>,
    },
    WsMsg {
        message_id: MessageId,
        msg: ToEnvoyWebSocketMessage,
    },
    WsClose {
        message_id: MessageId,
        close: ToEnvoyWebSocketClose,
    },
    HwsAck {
        gateway_id: GatewayId,
        request_id: RequestId,
        envoy_message_index: u16,
    },
}

Variants§

Intent

Fields

§intent: ActorIntent

§error: Option<String>

Stop

Fields

§command_idx: i64

§reason: StopActorReason

Lost

SetAlarm

Fields

§alarm_ts: Option<i64>

§ack_tx: Option<Sender<()>>

ReqStart

Fields

§message_id: MessageId

§req: ToEnvoyRequestStart

§connection_session: u64

ConnectionClosed

Fields

§session: u64

ReqChunk

Fields

§message_id: MessageId

§chunk: ToEnvoyRequestChunk

ReqAbort

Fields

§message_id: MessageId

§reason: HttpStreamAbortReason

ReqProtocolViolation

Fields

§message_id: MessageId

§detail: String

ReqBodyCancelled

Fields

§message_id: MessageId

ReqBodyCancel

Fields

§message_id: MessageId

ResponseBodyWindowUpdate

Fields

§message_id: MessageId

§consumed_bytes: u64

ReqComplete

Fields

§message_id: MessageId

WsOpen

Fields

§message_id: MessageId

§path: String

§headers: BTreeMap<String, String>

WsMsg

Fields

§message_id: MessageId

§msg: ToEnvoyWebSocketMessage

WsClose

Fields

§message_id: MessageId

§close: ToEnvoyWebSocketClose

HwsAck

Fields

§gateway_id: GatewayId

§request_id: RequestId

§envoy_message_index: u16

Auto Trait Implementations§

impl !RefUnwindSafe for ToActor

impl !UnwindSafe for ToActor

impl Freeze for ToActor

impl Send for ToActor

impl Sync for ToActor

impl Unpin for ToActor

impl UnsafeUnpin for ToActor

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Same for T

type Output = T

Should always be Self

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more