Struct WorkerNode

pub struct WorkerNode {
    pub id: u32,
    pub type: i32,
    pub host: Option<HostAddress>,
    pub state: i32,
    pub property: Option<Property>,
    pub transactional_id: Option<u32>,
    pub resource: Option<Resource>,
    pub started_at: Option<u64>,
    pub parallelism: u32,
    pub node_label: String,
}

Fields

id: u32

type: i32

host: Option<HostAddress>

state: i32

property: Option<Property>

transactional_id: Option<u32>

Ranges from 0 to 1023, used to generate the machine ID field in the global unique ID.

resource: Option<Resource>

Resource spec. It’s populated by meta node with the value reported by worker node, when the worker node is added by meta node. It’s not persistent in meta store.

started_at: Option<u64>

Timestamp the worker node is added by meta node, in seconds. It’s populated by meta node, when the worker node is added by meta node. It’s not persistent in meta store.

parallelism: u32

node_label: String

Meta may assign labels to worker nodes to partition workload by label. This is used for serverless backfilling of materialized views.

Implementations

impl WorkerNode

pub fn type(&self) -> WorkerType

Returns the enum value of type, or the default if the field is set to an invalid enum value.

pub fn set_type(&mut self, value: WorkerType)

Sets type to the provided enum value.

pub fn state(&self) -> State

Returns the enum value of state, or the default if the field is set to an invalid enum value.

pub fn set_state(&mut self, value: State)

Sets state to the provided enum value.

pub fn transactional_id(&self) -> u32

Returns the value of transactional_id, or the default value if transactional_id is unset.

pub fn started_at(&self) -> u64

Returns the value of started_at, or the default value if started_at is unset.

impl WorkerNode

pub fn get_id(&self) -> u32

pub fn get_type(&self) -> Result<WorkerType, PbFieldNotFound>

pub fn get_host(&self) -> Result<&HostAddress, PbFieldNotFound>

pub fn get_state(&self) -> Result<State, PbFieldNotFound>

pub fn get_property(&self) -> Result<&Property, PbFieldNotFound>

pub fn get_transactional_id(&self) -> Result<&u32, PbFieldNotFound>

pub fn get_resource(&self) -> Result<&Resource, PbFieldNotFound>

pub fn get_started_at(&self) -> Result<&u64, PbFieldNotFound>

pub fn get_parallelism(&self) -> u32

pub fn get_node_label(&self) -> &String

impl WorkerNode

pub fn parallelism(&self) -> usize

impl WorkerNode

pub fn is_streaming_schedulable(&self) -> bool

Trait Implementations

impl Clone for WorkerNode

fn clone(&self) -> WorkerNode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerNode

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

Formats the value using the given formatter.

impl Default for WorkerNode

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WorkerNode

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

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Message for WorkerNode

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 WorkerNode

fn eq(&self, other: &WorkerNode) -> 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 WorkerNode

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 WorkerNode