Struct UpdateMutation

pub struct UpdateMutation {
    pub dispatcher_update: Vec<DispatcherUpdate>,
    pub merge_update: Vec<MergeUpdate>,
    pub actor_vnode_bitmap_update: HashMap<u32, Buffer>,
    pub dropped_actors: Vec<u32>,
    pub actor_splits: HashMap<u32, ConnectorSplits>,
    pub actor_new_dispatchers: HashMap<u32, Dispatchers>,
}

Fields

dispatcher_update: Vec<DispatcherUpdate>

Dispatcher updates.

merge_update: Vec<MergeUpdate>

Merge updates.

actor_vnode_bitmap_update: HashMap<u32, Buffer>

Vnode bitmap updates for each actor.

dropped_actors: Vec<u32>

All actors to be dropped in this update.

actor_splits: HashMap<u32, ConnectorSplits>

Source updates. Source and SourceBackfill are handled together here.

actor_new_dispatchers: HashMap<u32, Dispatchers>

When modifying the Materialized View, we need to recreate the Dispatcher from the old upstream to the new TableFragment. Consistent with the semantics in AddMutation.

Implementations

impl UpdateMutation

pub fn get_dispatcher_update(&self) -> &Vec<DispatcherUpdate>

pub fn get_merge_update(&self) -> &Vec<MergeUpdate>

pub fn get_actor_vnode_bitmap_update(&self) -> &HashMap<u32, Buffer>

pub fn get_dropped_actors(&self) -> &Vec<u32>

pub fn get_actor_splits(&self) -> &HashMap<u32, ConnectorSplits>

pub fn get_actor_new_dispatchers(&self) -> &HashMap<u32, Dispatchers>

Trait Implementations

impl Clone for UpdateMutation

fn clone(&self) -> UpdateMutation

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UpdateMutation

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for UpdateMutation

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for UpdateMutation

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Message for UpdateMutation

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for UpdateMutation

fn eq(&self, other: &UpdateMutation) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for UpdateMutation

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for UpdateMutation