risingwave_frontend::optimizer::plan_node

Struct PlanRef

pub struct PlanRef(Rc<dyn PlanNode>);

Tuple Fields§

§0: Rc<dyn PlanNode>

Implementations§

impl PlanRef

pub fn common_subplan_sharing<V: Hash + Eq>(self) -> PlanRef
where PlanRef: Semantics<V>,

impl PlanRef

pub fn prune_share(&self) -> PlanRef

impl PlanRef

pub fn expect_stream_key(&self) -> &[usize]

fn prune_col_inner( &self, required_cols: &[usize], ctx: &mut ColumnPruningContext, ) -> PlanRef

fn predicate_pushdown_inner( &self, predicate: Condition, ctx: &mut PredicatePushdownContext, ) -> PlanRef

impl PlanRef

fn optimize_by_rules_inner( self, heuristic_optimizer: &mut HeuristicOptimizer<'_>, stage_name: &str, ) -> Result<PlanRef, RwError>

pub(crate) fn optimize_by_rules( self, _: &OptimizationStage, ) -> Result<PlanRef, RwError>

pub(crate) fn optimize_by_rules_until_fix_point( self, _: &OptimizationStage, ) -> Result<PlanRef, RwError>

Methods from Deref<Target = dyn PlanNode>§

pub fn is<__T: PlanNode>(&self) -> bool

Returns true if the trait object wraps an object of type __T.

pub fn downcast_rc<T: PlanNode>(self: Rc<Self>) -> Result<Rc<T>, Rc<Self>>

Returns an Rc-ed object from an Rc-ed trait object if the underlying object is of type __T. Returns the original Rc-ed trait if it isn’t.

pub fn downcast_ref<T: PlanNode>(&self) -> Option<&T>

Returns a reference to the object within the trait object if it is of type __T, or None if it isn’t.

pub fn id(&self) -> PlanNodeId

pub fn ctx(&self) -> OptimizerContextRef

pub fn schema(&self) -> &Schema

pub fn stream_key(&self) -> Option<&[usize]>

pub fn functional_dependency(&self) -> &FunctionalDependencySet

pub fn to_stream_prost( &self, state: &mut BuildFragmentGraphState, ) -> Result<PbStreamPlan, SchedulerError>

Serialize the plan node and its children to a stream plan proto.

Note that some operators has their own implementation of to_stream_prost. We have a hook inside to do some ad-hoc things.

pub fn to_batch_prost(&self) -> Result<PbBatchPlan, SchedulerError>

Serialize the plan node and its children to a batch plan proto.

pub fn to_batch_prost_identity( &self, identity: bool, ) -> Result<PbBatchPlan, SchedulerError>

Serialize the plan node and its children to a batch plan proto without the identity field (for testing).

pub fn explain_myself_to_string(&self) -> String

pub fn as_logical_agg(&self) -> Option<&LogicalAgg>

pub fn as_logical_apply(&self) -> Option<&LogicalApply>

pub fn as_logical_filter(&self) -> Option<&LogicalFilter>

pub fn as_logical_project(&self) -> Option<&LogicalProject>

pub fn as_logical_scan(&self) -> Option<&LogicalScan>

pub fn as_logical_cdc_scan(&self) -> Option<&LogicalCdcScan>

pub fn as_logical_sys_scan(&self) -> Option<&LogicalSysScan>

pub fn as_logical_source(&self) -> Option<&LogicalSource>

pub fn as_logical_insert(&self) -> Option<&LogicalInsert>

pub fn as_logical_delete(&self) -> Option<&LogicalDelete>

pub fn as_logical_update(&self) -> Option<&LogicalUpdate>

pub fn as_logical_join(&self) -> Option<&LogicalJoin>

pub fn as_logical_values(&self) -> Option<&LogicalValues>

pub fn as_logical_limit(&self) -> Option<&LogicalLimit>

pub fn as_logical_top_n(&self) -> Option<&LogicalTopN>

pub fn as_logical_hop_window(&self) -> Option<&LogicalHopWindow>

pub fn as_logical_table_function(&self) -> Option<&LogicalTableFunction>

pub fn as_logical_multi_join(&self) -> Option<&LogicalMultiJoin>

pub fn as_logical_expand(&self) -> Option<&LogicalExpand>

pub fn as_logical_project_set(&self) -> Option<&LogicalProjectSet>

pub fn as_logical_union(&self) -> Option<&LogicalUnion>

pub fn as_logical_over_window(&self) -> Option<&LogicalOverWindow>

pub fn as_logical_share(&self) -> Option<&LogicalShare>

pub fn as_logical_now(&self) -> Option<&LogicalNow>

pub fn as_logical_dedup(&self) -> Option<&LogicalDedup>

pub fn as_logical_intersect(&self) -> Option<&LogicalIntersect>

pub fn as_logical_except(&self) -> Option<&LogicalExcept>

pub fn as_logical_max_one_row(&self) -> Option<&LogicalMaxOneRow>

pub fn as_logical_kafka_scan(&self) -> Option<&LogicalKafkaScan>

pub fn as_logical_iceberg_scan(&self) -> Option<&LogicalIcebergScan>

pub fn as_logical_recursive_union(&self) -> Option<&LogicalRecursiveUnion>

pub fn as_logical_cte_ref(&self) -> Option<&LogicalCteRef>

pub fn as_logical_change_log(&self) -> Option<&LogicalChangeLog>

pub fn as_logical_file_scan(&self) -> Option<&LogicalFileScan>

pub fn as_logical_postgres_query(&self) -> Option<&LogicalPostgresQuery>

pub fn as_logical_my_sql_query(&self) -> Option<&LogicalMySqlQuery>

pub fn as_batch_simple_agg(&self) -> Option<&BatchSimpleAgg>

pub fn as_batch_hash_agg(&self) -> Option<&BatchHashAgg>

pub fn as_batch_sort_agg(&self) -> Option<&BatchSortAgg>

pub fn as_batch_project(&self) -> Option<&BatchProject>

pub fn as_batch_filter(&self) -> Option<&BatchFilter>

pub fn as_batch_insert(&self) -> Option<&BatchInsert>

pub fn as_batch_delete(&self) -> Option<&BatchDelete>

pub fn as_batch_update(&self) -> Option<&BatchUpdate>

pub fn as_batch_seq_scan(&self) -> Option<&BatchSeqScan>

pub fn as_batch_sys_seq_scan(&self) -> Option<&BatchSysSeqScan>

pub fn as_batch_log_seq_scan(&self) -> Option<&BatchLogSeqScan>

pub fn as_batch_hash_join(&self) -> Option<&BatchHashJoin>

pub fn as_batch_nested_loop_join(&self) -> Option<&BatchNestedLoopJoin>

pub fn as_batch_values(&self) -> Option<&BatchValues>

pub fn as_batch_sort(&self) -> Option<&BatchSort>

pub fn as_batch_exchange(&self) -> Option<&BatchExchange>

pub fn as_batch_limit(&self) -> Option<&BatchLimit>

pub fn as_batch_top_n(&self) -> Option<&BatchTopN>

pub fn as_batch_hop_window(&self) -> Option<&BatchHopWindow>

pub fn as_batch_table_function(&self) -> Option<&BatchTableFunction>

pub fn as_batch_expand(&self) -> Option<&BatchExpand>

pub fn as_batch_lookup_join(&self) -> Option<&BatchLookupJoin>

pub fn as_batch_project_set(&self) -> Option<&BatchProjectSet>

pub fn as_batch_union(&self) -> Option<&BatchUnion>

pub fn as_batch_group_top_n(&self) -> Option<&BatchGroupTopN>

pub fn as_batch_source(&self) -> Option<&BatchSource>

pub fn as_batch_over_window(&self) -> Option<&BatchOverWindow>

pub fn as_batch_max_one_row(&self) -> Option<&BatchMaxOneRow>

pub fn as_batch_kafka_scan(&self) -> Option<&BatchKafkaScan>

pub fn as_batch_iceberg_scan(&self) -> Option<&BatchIcebergScan>

pub fn as_batch_file_scan(&self) -> Option<&BatchFileScan>

pub fn as_batch_postgres_query(&self) -> Option<&BatchPostgresQuery>

pub fn as_batch_my_sql_query(&self) -> Option<&BatchMySqlQuery>

pub fn as_stream_project(&self) -> Option<&StreamProject>

pub fn as_stream_filter(&self) -> Option<&StreamFilter>

pub fn as_stream_table_scan(&self) -> Option<&StreamTableScan>

pub fn as_stream_cdc_table_scan(&self) -> Option<&StreamCdcTableScan>

pub fn as_stream_sink(&self) -> Option<&StreamSink>

pub fn as_stream_source(&self) -> Option<&StreamSource>

pub fn as_stream_source_scan(&self) -> Option<&StreamSourceScan>

pub fn as_stream_hash_join(&self) -> Option<&StreamHashJoin>

pub fn as_stream_exchange(&self) -> Option<&StreamExchange>

pub fn as_stream_hash_agg(&self) -> Option<&StreamHashAgg>

pub fn as_stream_simple_agg(&self) -> Option<&StreamSimpleAgg>

pub fn as_stream_stateless_simple_agg( &self, ) -> Option<&StreamStatelessSimpleAgg>

pub fn as_stream_materialize(&self) -> Option<&StreamMaterialize>

pub fn as_stream_top_n(&self) -> Option<&StreamTopN>

pub fn as_stream_hop_window(&self) -> Option<&StreamHopWindow>

pub fn as_stream_delta_join(&self) -> Option<&StreamDeltaJoin>

pub fn as_stream_expand(&self) -> Option<&StreamExpand>

pub fn as_stream_dynamic_filter(&self) -> Option<&StreamDynamicFilter>

pub fn as_stream_project_set(&self) -> Option<&StreamProjectSet>

pub fn as_stream_group_top_n(&self) -> Option<&StreamGroupTopN>

pub fn as_stream_union(&self) -> Option<&StreamUnion>

pub fn as_stream_row_id_gen(&self) -> Option<&StreamRowIdGen>

pub fn as_stream_dml(&self) -> Option<&StreamDml>

pub fn as_stream_now(&self) -> Option<&StreamNow>

pub fn as_stream_share(&self) -> Option<&StreamShare>

pub fn as_stream_watermark_filter(&self) -> Option<&StreamWatermarkFilter>

pub fn as_stream_temporal_join(&self) -> Option<&StreamTemporalJoin>

pub fn as_stream_values(&self) -> Option<&StreamValues>

pub fn as_stream_dedup(&self) -> Option<&StreamDedup>

pub fn as_stream_eowc_over_window(&self) -> Option<&StreamEowcOverWindow>

pub fn as_stream_eowc_sort(&self) -> Option<&StreamEowcSort>

pub fn as_stream_over_window(&self) -> Option<&StreamOverWindow>

pub fn as_stream_fs_fetch(&self) -> Option<&StreamFsFetch>

pub fn as_stream_change_log(&self) -> Option<&StreamChangeLog>

pub fn as_stream_global_approx_percentile( &self, ) -> Option<&StreamGlobalApproxPercentile>

pub fn as_stream_local_approx_percentile( &self, ) -> Option<&StreamLocalApproxPercentile>

pub fn as_stream_row_merge(&self) -> Option<&StreamRowMerge>

pub fn as_stream_as_of_join(&self) -> Option<&StreamAsOfJoin>

Trait Implementations§

impl AnyPlanNodeMeta for PlanRef

Implement again for the dyn newtype wrapper.

fn node_type(&self) -> PlanNodeType

fn plan_base(&self) -> PlanBaseRef<'_>

fn convention(&self) -> Convention

impl BatchPlanRef for PlanRef

Allow access to all fields defined in BatchPlanRef for the type-erased plan node.

fn order(&self) -> &Order

impl Clone for PlanRef

fn clone(&self) -> PlanRef

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

impl ColPrunable for PlanRef

fn prune_col( &self, required_cols: &[usize], ctx: &mut ColumnPruningContext, ) -> PlanRef

Transform the plan node to only output the required columns ordered by index number. Read more

impl Debug for PlanRef

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

Formats the value using the given formatter. Read more

impl Deref for PlanRef

type Target = dyn PlanNode

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<V: Hash + Eq> Endo<PlanRef> for Merger<V>
where PlanRef: Semantics<V>,

fn apply(&mut self, t: PlanRef) -> PlanRef

The real application function is left undefined. If we want the derived transformation we can simply call tree_apply in the implementation. But for more complicated requirements, e.g. skipping over certain subtrees, custom logic can be added.

fn pre(&mut self, t: T) -> T

fn post(&mut self, t: T) -> T

fn tree_apply(&mut self, t: T) -> T

The derived transformation based on pre and post.

impl Endo<PlanRef> for Pruner<'_>

fn pre(&mut self, t: PlanRef) -> PlanRef

fn apply(&mut self, t: PlanRef) -> PlanRef

The real application function is left undefined. If we want the derived transformation we can simply call tree_apply in the implementation. But for more complicated requirements, e.g. skipping over certain subtrees, custom logic can be added.

fn post(&mut self, t: T) -> T

fn tree_apply(&mut self, t: T) -> T

The derived transformation based on pre and post.

impl Explain for PlanRef

fn explain<'a>(&self) -> Pretty<'a>

Write explain the whole plan tree.

fn explain_with_id<'a>(&self) -> Pretty<'a>

Write explain the whole plan tree with node id.

fn explain_to_string(&self) -> String

Explain the plan node and return a string.

fn explain_to_json(&self) -> String

Explain the plan node and return a json string.

fn explain_to_xml(&self) -> String

Explain the plan node and return a xml string.

fn explain_to_yaml(&self) -> String

Explain the plan node and return a yaml string.

fn explain_to_dot(&self) -> String

Explain the plan node and return a dot format string.

impl ExprRewritable for PlanRef

fn has_rewritable_expr(&self) -> bool

fn rewrite_exprs(&self, r: &mut dyn ExprRewriter) -> PlanRef

impl ExprVisitable for PlanRef

fn visit_exprs(&self, v: &mut dyn ExprVisitor)

impl From<Agg<PlanRef>> for PlanRef

Because From/Into are not transitive

fn from(core: Agg<PlanRef>) -> Self

Converts to this type from the input type.

impl From<CdcScan> for PlanRef

fn from(core: CdcScan) -> Self

Converts to this type from the input type.

impl From<SysScan> for PlanRef

fn from(core: SysScan) -> Self

Converts to this type from the input type.

impl<T: PlanNode> From<T> for PlanRef

fn from(value: T) -> Self

Converts to this type from the input type.

impl From<TableScan> for PlanRef

fn from(core: TableScan) -> Self

Converts to this type from the input type.

impl GenericPlanRef for PlanRef

Allow access to all fields defined in GenericPlanRef for the type-erased plan node.

fn id(&self) -> PlanNodeId

fn schema(&self) -> &Schema

fn stream_key(&self) -> Option<&[usize]>

fn ctx(&self) -> OptimizerContextRef

fn functional_dependency(&self) -> &FunctionalDependencySet

impl Hash for PlanRef

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher. Read more

1.3.0 · source§

fn hash_slice<H>(data: &[Self], state: &mut H)
where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher. Read more

impl Layer for PlanRef

type Sub = PlanRef

fn map<F>(self, f: F) -> Self
where F: FnMut(Self::Sub) -> Self::Sub,

Given a transformation f : Sub -> Sub, we can derive a transformation on the entire Layer by acting f on all subcomponents.

fn descent<F>(&self, f: F)
where F: FnMut(&Self::Sub),

Given a traversal f : Sub -> (), we can derive a traversal on the entire Layer by sequentially visiting the subcomponents with f.

impl LogicalCardinalityExt for PlanRef

fn max_one_row(&self) -> bool

Returns true if the plan node is guaranteed to yield at most one row.

fn row_count(&self) -> Option<usize>

Returns the number of rows the plan node is guaranteed to yield, if known exactly.

impl PartialEq for PlanRef

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

impl PhysicalPlanRef for PlanRef

Allow access to all fields defined in PhysicalPlanRef for the type-erased plan node.

fn distribution(&self) -> &Distribution

impl PlanCheckApplyEliminationExt for PlanRef

fn check_apply_elimination(&self) -> Result<(), RwError>

Checks if all LogicalApply nodes in the plan have been eliminated, that is, subqueries are successfully unnested.

impl PlanTreeNode for PlanRef

fn inputs(&self) -> SmallVec<[PlanRef; 2]>

Get input nodes of the plan.

fn clone_with_inputs(&self, inputs: &[PlanRef]) -> PlanRef

Clone the node with a list of new inputs.

impl PredicatePushdown for PlanRef

fn predicate_pushdown( &self, predicate: Condition, ctx: &mut PredicatePushdownContext, ) -> PlanRef

Push predicate down for every logical plan node. Read more

impl RewriteExprsRecursive for PlanRef

fn rewrite_exprs_recursive(&self, r: &mut impl ExprRewriter) -> PlanRef

impl Semantics<PlanRef> for PlanRef

fn semantics(&self) -> PlanRef

impl StreamPlanRef for PlanRef

Allow access to all fields defined in StreamPlanRef for the type-erased plan node.

fn append_only(&self) -> bool

fn emit_on_window_close(&self) -> bool

fn watermark_columns(&self) -> &FixedBitSet

fn columns_monotonicity(&self) -> &MonotonicityMap

impl TryFrom<PlanRef> for ExecutionPlanNode

type Error = SchedulerError

The type returned in the event of a conversion error.

fn try_from(plan_node: PlanRef) -> Result<Self, Self::Error>

Performs the conversion.

impl Visit<PlanRef> for Counter

fn visit(&mut self, t: &PlanRef)

fn pre(&mut self, t: &T)

fn post(&mut self, t: &T)

fn tree_visit(&mut self, t: &T)

impl VisitExprsRecursive for PlanRef

fn visit_exprs_recursive(&self, r: &mut impl ExprVisitor)

impl Eq for PlanRef

Auto Trait Implementations§

impl Freeze for PlanRef

impl !RefUnwindSafe for PlanRef

impl !Send for PlanRef

impl !Sync for PlanRef

impl Unpin for PlanRef

impl !UnwindSafe for PlanRef

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> CloneToUninit for T
where T: Clone,

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

impl<T> Conv for T

fn conv<T>(self) -> T
where Self: Into<T>,

Converts self into T using Into<T>. Read more

impl<Choices> CoproductSubsetter<CNil, HNil> for Choices

type Remainder = Choices

fn subset( self, ) -> Result<CNil, <Choices as CoproductSubsetter<CNil, HNil>>::Remainder>

Extract a subset of the possible types in a coproduct (or get the remaining possibilities) Read more

impl<T> Downcast for T
where T: Any,

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.

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

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> DynEq for T
where T: Any + Eq,

fn as_any(&self) -> &(dyn Any + 'static)

fn dyn_eq(&self, other: &(dyn DynEq + 'static)) -> bool

impl<T> DynHash for T
where T: DynEq + Hash,

fn as_dyn_eq(&self) -> &(dyn DynEq + 'static)

fn dyn_hash(&self, state: &mut dyn Hasher)

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

Causes self to use its Binary implementation when Debug-formatted.

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

Causes self to use its Display implementation when Debug-formatted.

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted.

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted.

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

Causes self to use its Octal implementation when Debug-formatted.

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

Causes self to use its Pointer implementation when Debug-formatted.

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted.

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted.

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

Formats each item in a sequence. Read more

impl<T> From<T> for T

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> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more

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> 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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request

impl<T> IntoResult<T> for T

type Err = Infallible

fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

Creates a shared type from an unshared type.

impl<T, U, I> LiftInto<U, I> for T
where U: LiftFrom<T, I>,

fn lift_into(self) -> U

Performs the indexed conversion.

impl<M> MetricVecRelabelExt for M

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level.

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level_relabel_n.

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

Equivalent to RelabeledMetricVec::with_metric_level_relabel_n with metric_level set to MetricLevel::Debug and relabel_num set to 1.

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

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

Pipes by value. This is generally the method you want to use. Read more

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

Borrows self and passes that borrow into the pipe function. Read more

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

Mutably borrows self and passes that borrow into the pipe function. Read more

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

Borrows self, then passes self.as_ref() into the pipe function.

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function.

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

Borrows self, then passes self.deref() into the pipe function.

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function.

impl<T> Pointable for T

const ALIGN: usize = _

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<T> Same for T

type Output = T

Should always be Self

impl<Source> Sculptor<HNil, HNil> for Source

type Remainder = Source

fn sculpt(self) -> (HNil, <Source as Sculptor<HNil, HNil>>::Remainder)

Consumes the current HList and returns an HList with the requested shape. Read more

impl<T> SerTo<T> for T

fn ser_to(self) -> Result<T, SinkError>

impl<T> Tap for T

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Immutable access to the Borrow<B> of a value. Read more

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Mutable access to the BorrowMut<B> of a value. Read more

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Immutable access to the Deref::Target of a value. Read more

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Mutable access to the Deref::Target of a value. Read more

fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self

Calls .tap() only in debug builds, and is erased in release builds.

fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self

Calls .tap_mut() only in debug builds, and is erased in release builds.

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
where Self: Borrow<B>, B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds.

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
where Self: BorrowMut<B>, B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds.

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
where Self: AsRef<R>, R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds.

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
where Self: AsMut<R>, R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds.

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
where Self: Deref<Target = T>, T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds.

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self
where Self: DerefMut<Target = T> + Deref, T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds.

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

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

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

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

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

impl<T> TryConv for T

fn try_conv<T>(self) -> Result<T, Self::Error>
where Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more

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

type Error = Infallible

The type returned in the event of a conversion error.

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

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

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