risingwave_pb::batch_plan::plan_node

Enum NodeBody

source
pub enum NodeBody {
Show 35 variants Insert(InsertNode), Delete(DeleteNode), Update(UpdateNode), Project(ProjectNode), HashAgg(HashAggNode), Filter(FilterNode), Exchange(ExchangeNode), Sort(SortNode), NestedLoopJoin(NestedLoopJoinNode), TopN(TopNNode), SortAgg(SortAggNode), RowSeqScan(RowSeqScanNode), Limit(LimitNode), Values(ValuesNode), HashJoin(HashJoinNode), MergeSortExchange(MergeSortExchangeNode), HopWindow(HopWindowNode), TableFunction(TableFunctionNode), SysRowSeqScan(SysRowSeqScanNode), Expand(ExpandNode), LocalLookupJoin(LocalLookupJoinNode), ProjectSet(ProjectSetNode), Union(UnionNode), GroupTopN(GroupTopNNode), DistributedLookupJoin(DistributedLookupJoinNode), Source(SourceNode), SortOverWindow(SortOverWindowNode), MaxOneRow(MaxOneRowNode), LogRowSeqScan(LogRowSeqScanNode), FileScan(FileScanNode), IcebergScan(IcebergScanNode), PostgresQuery(PostgresQueryNode), MysqlQuery(MySqlQueryNode), BlockExecutor(bool), BusyLoopExecutor(bool),
}

Variants§

§

Insert(InsertNode)

§

Delete(DeleteNode)

§

Update(UpdateNode)

§

Project(ProjectNode)

§

HashAgg(HashAggNode)

§

Filter(FilterNode)

§

Exchange(ExchangeNode)

§

Sort(SortNode)

§

NestedLoopJoin(NestedLoopJoinNode)

§

TopN(TopNNode)

§

SortAgg(SortAggNode)

§

RowSeqScan(RowSeqScanNode)

§

Limit(LimitNode)

§

Values(ValuesNode)

§

HashJoin(HashJoinNode)

§

MergeSortExchange(MergeSortExchangeNode)

§

HopWindow(HopWindowNode)

§

TableFunction(TableFunctionNode)

§

SysRowSeqScan(SysRowSeqScanNode)

§

Expand(ExpandNode)

§

LocalLookupJoin(LocalLookupJoinNode)

§

ProjectSet(ProjectSetNode)

§

Union(UnionNode)

§

GroupTopN(GroupTopNNode)

§

DistributedLookupJoin(DistributedLookupJoinNode)

§

Source(SourceNode)

§

SortOverWindow(SortOverWindowNode)

§

MaxOneRow(MaxOneRowNode)

§

LogRowSeqScan(LogRowSeqScanNode)

§

FileScan(FileScanNode)

§

IcebergScan(IcebergScanNode)

§

PostgresQuery(PostgresQueryNode)

§

MysqlQuery(MySqlQueryNode)

§

BlockExecutor(bool)

The following nodes are used for testing.

§

BusyLoopExecutor(bool)

Implementations§

source§

impl NodeBody

source

pub fn encode(&self, buf: &mut impl BufMut)

Encodes the message to a buffer.

source

pub fn merge( field: &mut Option<NodeBody>, tag: u32, wire_type: WireType, buf: &mut impl Buf, ctx: DecodeContext, ) -> Result<(), DecodeError>

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

source

pub fn encoded_len(&self) -> usize

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

source§

impl NodeBody

source

pub fn is_insert(&self) -> bool

Returns true if this is a NodeBody::Insert, otherwise false

source

pub fn as_insert_mut(&mut self) -> Option<&mut InsertNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Insert, otherwise None

source

pub fn as_insert(&self) -> Option<&InsertNode>

Optionally returns references to the inner fields if this is a NodeBody::Insert, otherwise None

source

pub fn into_insert(self) -> Result<InsertNode, Self>

Returns the inner fields if this is a NodeBody::Insert, otherwise returns back the enum in the Err case of the result

source

pub fn is_delete(&self) -> bool

Returns true if this is a NodeBody::Delete, otherwise false

source

pub fn as_delete_mut(&mut self) -> Option<&mut DeleteNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Delete, otherwise None

source

pub fn as_delete(&self) -> Option<&DeleteNode>

Optionally returns references to the inner fields if this is a NodeBody::Delete, otherwise None

source

pub fn into_delete(self) -> Result<DeleteNode, Self>

Returns the inner fields if this is a NodeBody::Delete, otherwise returns back the enum in the Err case of the result

source

pub fn is_update(&self) -> bool

Returns true if this is a NodeBody::Update, otherwise false

source

pub fn as_update_mut(&mut self) -> Option<&mut UpdateNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Update, otherwise None

source

pub fn as_update(&self) -> Option<&UpdateNode>

Optionally returns references to the inner fields if this is a NodeBody::Update, otherwise None

source

pub fn into_update(self) -> Result<UpdateNode, Self>

Returns the inner fields if this is a NodeBody::Update, otherwise returns back the enum in the Err case of the result

source

pub fn is_project(&self) -> bool

Returns true if this is a NodeBody::Project, otherwise false

source

pub fn as_project_mut(&mut self) -> Option<&mut ProjectNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Project, otherwise None

source

pub fn as_project(&self) -> Option<&ProjectNode>

Optionally returns references to the inner fields if this is a NodeBody::Project, otherwise None

source

pub fn into_project(self) -> Result<ProjectNode, Self>

Returns the inner fields if this is a NodeBody::Project, otherwise returns back the enum in the Err case of the result

source

pub fn is_hash_agg(&self) -> bool

Returns true if this is a NodeBody::HashAgg, otherwise false

source

pub fn as_hash_agg_mut(&mut self) -> Option<&mut HashAggNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HashAgg, otherwise None

source

pub fn as_hash_agg(&self) -> Option<&HashAggNode>

Optionally returns references to the inner fields if this is a NodeBody::HashAgg, otherwise None

source

pub fn into_hash_agg(self) -> Result<HashAggNode, Self>

Returns the inner fields if this is a NodeBody::HashAgg, otherwise returns back the enum in the Err case of the result

source

pub fn is_filter(&self) -> bool

Returns true if this is a NodeBody::Filter, otherwise false

source

pub fn as_filter_mut(&mut self) -> Option<&mut FilterNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Filter, otherwise None

source

pub fn as_filter(&self) -> Option<&FilterNode>

Optionally returns references to the inner fields if this is a NodeBody::Filter, otherwise None

source

pub fn into_filter(self) -> Result<FilterNode, Self>

Returns the inner fields if this is a NodeBody::Filter, otherwise returns back the enum in the Err case of the result

source

pub fn is_exchange(&self) -> bool

Returns true if this is a NodeBody::Exchange, otherwise false

source

pub fn as_exchange_mut(&mut self) -> Option<&mut ExchangeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Exchange, otherwise None

source

pub fn as_exchange(&self) -> Option<&ExchangeNode>

Optionally returns references to the inner fields if this is a NodeBody::Exchange, otherwise None

source

pub fn into_exchange(self) -> Result<ExchangeNode, Self>

Returns the inner fields if this is a NodeBody::Exchange, otherwise returns back the enum in the Err case of the result

source

pub fn is_sort(&self) -> bool

Returns true if this is a NodeBody::Sort, otherwise false

source

pub fn as_sort_mut(&mut self) -> Option<&mut SortNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Sort, otherwise None

source

pub fn as_sort(&self) -> Option<&SortNode>

Optionally returns references to the inner fields if this is a NodeBody::Sort, otherwise None

source

pub fn into_sort(self) -> Result<SortNode, Self>

Returns the inner fields if this is a NodeBody::Sort, otherwise returns back the enum in the Err case of the result

source

pub fn is_nested_loop_join(&self) -> bool

Returns true if this is a NodeBody::NestedLoopJoin, otherwise false

source

pub fn as_nested_loop_join_mut(&mut self) -> Option<&mut NestedLoopJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::NestedLoopJoin, otherwise None

source

pub fn as_nested_loop_join(&self) -> Option<&NestedLoopJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::NestedLoopJoin, otherwise None

source

pub fn into_nested_loop_join(self) -> Result<NestedLoopJoinNode, Self>

Returns the inner fields if this is a NodeBody::NestedLoopJoin, otherwise returns back the enum in the Err case of the result

source

pub fn is_top_n(&self) -> bool

Returns true if this is a NodeBody::TopN, otherwise false

source

pub fn as_top_n_mut(&mut self) -> Option<&mut TopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::TopN, otherwise None

source

pub fn as_top_n(&self) -> Option<&TopNNode>

Optionally returns references to the inner fields if this is a NodeBody::TopN, otherwise None

source

pub fn into_top_n(self) -> Result<TopNNode, Self>

Returns the inner fields if this is a NodeBody::TopN, otherwise returns back the enum in the Err case of the result

source

pub fn is_sort_agg(&self) -> bool

Returns true if this is a NodeBody::SortAgg, otherwise false

source

pub fn as_sort_agg_mut(&mut self) -> Option<&mut SortAggNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::SortAgg, otherwise None

source

pub fn as_sort_agg(&self) -> Option<&SortAggNode>

Optionally returns references to the inner fields if this is a NodeBody::SortAgg, otherwise None

source

pub fn into_sort_agg(self) -> Result<SortAggNode, Self>

Returns the inner fields if this is a NodeBody::SortAgg, otherwise returns back the enum in the Err case of the result

source

pub fn is_row_seq_scan(&self) -> bool

Returns true if this is a NodeBody::RowSeqScan, otherwise false

source

pub fn as_row_seq_scan_mut(&mut self) -> Option<&mut RowSeqScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::RowSeqScan, otherwise None

source

pub fn as_row_seq_scan(&self) -> Option<&RowSeqScanNode>

Optionally returns references to the inner fields if this is a NodeBody::RowSeqScan, otherwise None

source

pub fn into_row_seq_scan(self) -> Result<RowSeqScanNode, Self>

Returns the inner fields if this is a NodeBody::RowSeqScan, otherwise returns back the enum in the Err case of the result

source

pub fn is_limit(&self) -> bool

Returns true if this is a NodeBody::Limit, otherwise false

source

pub fn as_limit_mut(&mut self) -> Option<&mut LimitNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Limit, otherwise None

source

pub fn as_limit(&self) -> Option<&LimitNode>

Optionally returns references to the inner fields if this is a NodeBody::Limit, otherwise None

source

pub fn into_limit(self) -> Result<LimitNode, Self>

Returns the inner fields if this is a NodeBody::Limit, otherwise returns back the enum in the Err case of the result

source

pub fn is_values(&self) -> bool

Returns true if this is a NodeBody::Values, otherwise false

source

pub fn as_values_mut(&mut self) -> Option<&mut ValuesNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Values, otherwise None

source

pub fn as_values(&self) -> Option<&ValuesNode>

Optionally returns references to the inner fields if this is a NodeBody::Values, otherwise None

source

pub fn into_values(self) -> Result<ValuesNode, Self>

Returns the inner fields if this is a NodeBody::Values, otherwise returns back the enum in the Err case of the result

source

pub fn is_hash_join(&self) -> bool

Returns true if this is a NodeBody::HashJoin, otherwise false

source

pub fn as_hash_join_mut(&mut self) -> Option<&mut HashJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HashJoin, otherwise None

source

pub fn as_hash_join(&self) -> Option<&HashJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::HashJoin, otherwise None

source

pub fn into_hash_join(self) -> Result<HashJoinNode, Self>

Returns the inner fields if this is a NodeBody::HashJoin, otherwise returns back the enum in the Err case of the result

source

pub fn is_merge_sort_exchange(&self) -> bool

Returns true if this is a NodeBody::MergeSortExchange, otherwise false

source

pub fn as_merge_sort_exchange_mut( &mut self, ) -> Option<&mut MergeSortExchangeNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::MergeSortExchange, otherwise None

source

pub fn as_merge_sort_exchange(&self) -> Option<&MergeSortExchangeNode>

Optionally returns references to the inner fields if this is a NodeBody::MergeSortExchange, otherwise None

source

pub fn into_merge_sort_exchange(self) -> Result<MergeSortExchangeNode, Self>

Returns the inner fields if this is a NodeBody::MergeSortExchange, otherwise returns back the enum in the Err case of the result

source

pub fn is_hop_window(&self) -> bool

Returns true if this is a NodeBody::HopWindow, otherwise false

source

pub fn as_hop_window_mut(&mut self) -> Option<&mut HopWindowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::HopWindow, otherwise None

source

pub fn as_hop_window(&self) -> Option<&HopWindowNode>

Optionally returns references to the inner fields if this is a NodeBody::HopWindow, otherwise None

source

pub fn into_hop_window(self) -> Result<HopWindowNode, Self>

Returns the inner fields if this is a NodeBody::HopWindow, otherwise returns back the enum in the Err case of the result

source

pub fn is_table_function(&self) -> bool

Returns true if this is a NodeBody::TableFunction, otherwise false

source

pub fn as_table_function_mut(&mut self) -> Option<&mut TableFunctionNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::TableFunction, otherwise None

source

pub fn as_table_function(&self) -> Option<&TableFunctionNode>

Optionally returns references to the inner fields if this is a NodeBody::TableFunction, otherwise None

source

pub fn into_table_function(self) -> Result<TableFunctionNode, Self>

Returns the inner fields if this is a NodeBody::TableFunction, otherwise returns back the enum in the Err case of the result

source

pub fn is_sys_row_seq_scan(&self) -> bool

Returns true if this is a NodeBody::SysRowSeqScan, otherwise false

source

pub fn as_sys_row_seq_scan_mut(&mut self) -> Option<&mut SysRowSeqScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::SysRowSeqScan, otherwise None

source

pub fn as_sys_row_seq_scan(&self) -> Option<&SysRowSeqScanNode>

Optionally returns references to the inner fields if this is a NodeBody::SysRowSeqScan, otherwise None

source

pub fn into_sys_row_seq_scan(self) -> Result<SysRowSeqScanNode, Self>

Returns the inner fields if this is a NodeBody::SysRowSeqScan, otherwise returns back the enum in the Err case of the result

source

pub fn is_expand(&self) -> bool

Returns true if this is a NodeBody::Expand, otherwise false

source

pub fn as_expand_mut(&mut self) -> Option<&mut ExpandNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Expand, otherwise None

source

pub fn as_expand(&self) -> Option<&ExpandNode>

Optionally returns references to the inner fields if this is a NodeBody::Expand, otherwise None

source

pub fn into_expand(self) -> Result<ExpandNode, Self>

Returns the inner fields if this is a NodeBody::Expand, otherwise returns back the enum in the Err case of the result

source

pub fn is_local_lookup_join(&self) -> bool

Returns true if this is a NodeBody::LocalLookupJoin, otherwise false

source

pub fn as_local_lookup_join_mut(&mut self) -> Option<&mut LocalLookupJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::LocalLookupJoin, otherwise None

source

pub fn as_local_lookup_join(&self) -> Option<&LocalLookupJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::LocalLookupJoin, otherwise None

source

pub fn into_local_lookup_join(self) -> Result<LocalLookupJoinNode, Self>

Returns the inner fields if this is a NodeBody::LocalLookupJoin, otherwise returns back the enum in the Err case of the result

source

pub fn is_project_set(&self) -> bool

Returns true if this is a NodeBody::ProjectSet, otherwise false

source

pub fn as_project_set_mut(&mut self) -> Option<&mut ProjectSetNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::ProjectSet, otherwise None

source

pub fn as_project_set(&self) -> Option<&ProjectSetNode>

Optionally returns references to the inner fields if this is a NodeBody::ProjectSet, otherwise None

source

pub fn into_project_set(self) -> Result<ProjectSetNode, Self>

Returns the inner fields if this is a NodeBody::ProjectSet, otherwise returns back the enum in the Err case of the result

source

pub fn is_union(&self) -> bool

Returns true if this is a NodeBody::Union, otherwise false

source

pub fn as_union_mut(&mut self) -> Option<&mut UnionNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Union, otherwise None

source

pub fn as_union(&self) -> Option<&UnionNode>

Optionally returns references to the inner fields if this is a NodeBody::Union, otherwise None

source

pub fn into_union(self) -> Result<UnionNode, Self>

Returns the inner fields if this is a NodeBody::Union, otherwise returns back the enum in the Err case of the result

source

pub fn is_group_top_n(&self) -> bool

Returns true if this is a NodeBody::GroupTopN, otherwise false

source

pub fn as_group_top_n_mut(&mut self) -> Option<&mut GroupTopNNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::GroupTopN, otherwise None

source

pub fn as_group_top_n(&self) -> Option<&GroupTopNNode>

Optionally returns references to the inner fields if this is a NodeBody::GroupTopN, otherwise None

source

pub fn into_group_top_n(self) -> Result<GroupTopNNode, Self>

Returns the inner fields if this is a NodeBody::GroupTopN, otherwise returns back the enum in the Err case of the result

source

pub fn is_distributed_lookup_join(&self) -> bool

Returns true if this is a NodeBody::DistributedLookupJoin, otherwise false

source

pub fn as_distributed_lookup_join_mut( &mut self, ) -> Option<&mut DistributedLookupJoinNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::DistributedLookupJoin, otherwise None

source

pub fn as_distributed_lookup_join(&self) -> Option<&DistributedLookupJoinNode>

Optionally returns references to the inner fields if this is a NodeBody::DistributedLookupJoin, otherwise None

source

pub fn into_distributed_lookup_join( self, ) -> Result<DistributedLookupJoinNode, Self>

Returns the inner fields if this is a NodeBody::DistributedLookupJoin, otherwise returns back the enum in the Err case of the result

source

pub fn is_source(&self) -> bool

Returns true if this is a NodeBody::Source, otherwise false

source

pub fn as_source_mut(&mut self) -> Option<&mut SourceNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::Source, otherwise None

source

pub fn as_source(&self) -> Option<&SourceNode>

Optionally returns references to the inner fields if this is a NodeBody::Source, otherwise None

source

pub fn into_source(self) -> Result<SourceNode, Self>

Returns the inner fields if this is a NodeBody::Source, otherwise returns back the enum in the Err case of the result

source

pub fn is_sort_over_window(&self) -> bool

Returns true if this is a NodeBody::SortOverWindow, otherwise false

source

pub fn as_sort_over_window_mut(&mut self) -> Option<&mut SortOverWindowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::SortOverWindow, otherwise None

source

pub fn as_sort_over_window(&self) -> Option<&SortOverWindowNode>

Optionally returns references to the inner fields if this is a NodeBody::SortOverWindow, otherwise None

source

pub fn into_sort_over_window(self) -> Result<SortOverWindowNode, Self>

Returns the inner fields if this is a NodeBody::SortOverWindow, otherwise returns back the enum in the Err case of the result

source

pub fn is_max_one_row(&self) -> bool

Returns true if this is a NodeBody::MaxOneRow, otherwise false

source

pub fn as_max_one_row_mut(&mut self) -> Option<&mut MaxOneRowNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::MaxOneRow, otherwise None

source

pub fn as_max_one_row(&self) -> Option<&MaxOneRowNode>

Optionally returns references to the inner fields if this is a NodeBody::MaxOneRow, otherwise None

source

pub fn into_max_one_row(self) -> Result<MaxOneRowNode, Self>

Returns the inner fields if this is a NodeBody::MaxOneRow, otherwise returns back the enum in the Err case of the result

source

pub fn is_log_row_seq_scan(&self) -> bool

Returns true if this is a NodeBody::LogRowSeqScan, otherwise false

source

pub fn as_log_row_seq_scan_mut(&mut self) -> Option<&mut LogRowSeqScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::LogRowSeqScan, otherwise None

source

pub fn as_log_row_seq_scan(&self) -> Option<&LogRowSeqScanNode>

Optionally returns references to the inner fields if this is a NodeBody::LogRowSeqScan, otherwise None

source

pub fn into_log_row_seq_scan(self) -> Result<LogRowSeqScanNode, Self>

Returns the inner fields if this is a NodeBody::LogRowSeqScan, otherwise returns back the enum in the Err case of the result

source

pub fn is_file_scan(&self) -> bool

Returns true if this is a NodeBody::FileScan, otherwise false

source

pub fn as_file_scan_mut(&mut self) -> Option<&mut FileScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::FileScan, otherwise None

source

pub fn as_file_scan(&self) -> Option<&FileScanNode>

Optionally returns references to the inner fields if this is a NodeBody::FileScan, otherwise None

source

pub fn into_file_scan(self) -> Result<FileScanNode, Self>

Returns the inner fields if this is a NodeBody::FileScan, otherwise returns back the enum in the Err case of the result

source

pub fn is_iceberg_scan(&self) -> bool

Returns true if this is a NodeBody::IcebergScan, otherwise false

source

pub fn as_iceberg_scan_mut(&mut self) -> Option<&mut IcebergScanNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::IcebergScan, otherwise None

source

pub fn as_iceberg_scan(&self) -> Option<&IcebergScanNode>

Optionally returns references to the inner fields if this is a NodeBody::IcebergScan, otherwise None

source

pub fn into_iceberg_scan(self) -> Result<IcebergScanNode, Self>

Returns the inner fields if this is a NodeBody::IcebergScan, otherwise returns back the enum in the Err case of the result

source

pub fn is_postgres_query(&self) -> bool

Returns true if this is a NodeBody::PostgresQuery, otherwise false

source

pub fn as_postgres_query_mut(&mut self) -> Option<&mut PostgresQueryNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::PostgresQuery, otherwise None

source

pub fn as_postgres_query(&self) -> Option<&PostgresQueryNode>

Optionally returns references to the inner fields if this is a NodeBody::PostgresQuery, otherwise None

source

pub fn into_postgres_query(self) -> Result<PostgresQueryNode, Self>

Returns the inner fields if this is a NodeBody::PostgresQuery, otherwise returns back the enum in the Err case of the result

source

pub fn is_mysql_query(&self) -> bool

Returns true if this is a NodeBody::MysqlQuery, otherwise false

source

pub fn as_mysql_query_mut(&mut self) -> Option<&mut MySqlQueryNode>

Optionally returns mutable references to the inner fields if this is a NodeBody::MysqlQuery, otherwise None

source

pub fn as_mysql_query(&self) -> Option<&MySqlQueryNode>

Optionally returns references to the inner fields if this is a NodeBody::MysqlQuery, otherwise None

source

pub fn into_mysql_query(self) -> Result<MySqlQueryNode, Self>

Returns the inner fields if this is a NodeBody::MysqlQuery, otherwise returns back the enum in the Err case of the result

source

pub fn is_block_executor(&self) -> bool

Returns true if this is a NodeBody::BlockExecutor, otherwise false

source

pub fn as_block_executor_mut(&mut self) -> Option<&mut bool>

Optionally returns mutable references to the inner fields if this is a NodeBody::BlockExecutor, otherwise None

source

pub fn as_block_executor(&self) -> Option<&bool>

Optionally returns references to the inner fields if this is a NodeBody::BlockExecutor, otherwise None

source

pub fn into_block_executor(self) -> Result<bool, Self>

Returns the inner fields if this is a NodeBody::BlockExecutor, otherwise returns back the enum in the Err case of the result

source

pub fn is_busy_loop_executor(&self) -> bool

Returns true if this is a NodeBody::BusyLoopExecutor, otherwise false

source

pub fn as_busy_loop_executor_mut(&mut self) -> Option<&mut bool>

Optionally returns mutable references to the inner fields if this is a NodeBody::BusyLoopExecutor, otherwise None

source

pub fn as_busy_loop_executor(&self) -> Option<&bool>

Optionally returns references to the inner fields if this is a NodeBody::BusyLoopExecutor, otherwise None

source

pub fn into_busy_loop_executor(self) -> Result<bool, Self>

Returns the inner fields if this is a NodeBody::BusyLoopExecutor, otherwise returns back the enum in the Err case of the result

Trait Implementations§

source§

impl Clone for NodeBody

source§

fn clone(&self) -> NodeBody

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for NodeBody

source§

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

Formats the value using the given formatter. Read more
source§

impl Display for NodeBody

source§

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

Formats the value using the given formatter. Read more
source§

impl PartialEq for NodeBody

source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

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

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

impl StructuralPartialEq for NodeBody

Auto Trait Implementations§

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> CloneToUninit for T
where T: Clone,

source§

unsafe fn clone_to_uninit(&self, dst: *mut T)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> FromRef<T> for T
where T: Clone,

§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
§

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
source§

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

source§

fn into(self) -> U

Calls U::from(self).

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

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T> ToOwned for T
where T: Clone,

source§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T> ToString for T
where T: Display + ?Sized,

source§

default fn to_string(&self) -> String

Converts the given value to a String. Read more
source§

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

source§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

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

source§

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

The type returned in the event of a conversion error.
source§

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