DoraNode

Struct DoraNode 

Source
pub struct DoraNode { /* private fields */ }
Expand description

Allows sending outputs and retrieving node information.

The main purpose of this struct is to send outputs via Dora. There are also functions available for retrieving the node configuration.

Implementations§

Source§

impl DoraNode

Source

pub fn init_from_env() -> Result<(Self, EventStream)>

Initiate a node from environment variables set by the Dora daemon.

This is the recommended initialization function for Dora nodes, which are spawned by Dora daemon instances.

use dora_node_api::DoraNode;

let (mut node, mut events) = DoraNode::init_from_env().expect("Could not init node.");
Source

pub fn init_from_node_id(node_id: NodeId) -> Result<(Self, EventStream)>

Initiate a node from a dataflow id and a node id.

This initialization function should be used for dynamic nodes.

use dora_node_api::DoraNode;
use dora_node_api::dora_core::config::NodeId;

let (mut node, mut events) = DoraNode::init_from_node_id(NodeId::from("plot".to_string())).expect("Could not init node plot");
Source

pub fn init_flexible(node_id: NodeId) -> Result<(Self, EventStream)>

Dynamic initialization function for nodes that are sometimes used as dynamic nodes.

This function first tries initializing the traditional way through init_from_env. If this fails, it falls back to init_from_node_id.

Source

pub fn send_output_raw<F>( &mut self, output_id: DataId, parameters: MetadataParameters, data_len: usize, data: F, ) -> Result<()>
where F: FnOnce(&mut [u8]),

Send raw data from the node to the other nodes.

We take a closure as an input to enable zero copy on send.

use dora_node_api::{DoraNode, MetadataParameters};
use dora_core::config::DataId;

let (mut node, mut events) = DoraNode::init_from_env().expect("Could not init node.");

let output = DataId::from("output_id".to_owned());

let data: &[u8] = &[0, 1, 2, 3];
let parameters = MetadataParameters::default();

node.send_output_raw(
   output,
   parameters,
   data.len(),
   |out| {
        out.copy_from_slice(data);
    }).expect("Could not send output");

Ignores the output if the given output_id is not specified as node output in the dataflow configuration file.

Source

pub fn send_output( &mut self, output_id: DataId, parameters: MetadataParameters, data: impl Array, ) -> Result<()>

Sends the give Arrow array as an output message.

Uses shared memory for efficient data transfer if suitable.

This method might copy the message once to move it to shared memory.

Ignores the output if the given output_id is not specified as node output in the dataflow configuration file.

Source

pub fn send_output_bytes( &mut self, output_id: DataId, parameters: MetadataParameters, data_len: usize, data: &[u8], ) -> Result<()>

Send the given raw byte data as output.

Might copy the data once to move it into shared memory.

Ignores the output if the given output_id is not specified as node output in the dataflow configuration file.

Source

pub fn send_typed_output<F>( &mut self, output_id: DataId, type_info: ArrowTypeInfo, parameters: MetadataParameters, data_len: usize, data: F, ) -> Result<()>
where F: FnOnce(&mut [u8]),

Send the give raw byte data with the provided type information.

It is recommended to use a function like send_output instead.

Ignores the output if the given output_id is not specified as node output in the dataflow configuration file.

Source

pub fn send_output_sample( &mut self, output_id: DataId, type_info: ArrowTypeInfo, parameters: MetadataParameters, sample: Option<DataSample>, ) -> Result<()>

Sends the given DataSample as output, combined with the given type information.

It is recommended to use a function like send_output instead.

Ignores the output if the given output_id is not specified as node output in the dataflow configuration file.

Source

pub fn close_outputs(&mut self, outputs_ids: Vec<DataId>) -> Result<()>

Report the given outputs IDs as closed.

The node is not allowed to send more outputs with the closed IDs.

Closing outputs early can be helpful to receivers.

Source

pub fn id(&self) -> &NodeId

Returns the ID of the node as specified in the dataflow configuration file.

Source

pub fn dataflow_id(&self) -> &DataflowId

Returns the unique identifier for the running dataflow instance.

Dora assigns each dataflow instance a random identifier when started.

Source

pub fn node_config(&self) -> &NodeRunConfig

Returns the input and output configuration of this node.

Source

pub fn allocate_data_sample(&mut self, data_len: usize) -> Result<DataSample>

Allocates a DataSample of the specified size.

The data sample will use shared memory when suitable to enable efficient data transfer when sending an output message.

Source

pub fn dataflow_descriptor(&self) -> Result<&Descriptor>

Returns the full dataflow descriptor that this node is part of.

This method returns the parsed dataflow YAML file.

Trait Implementations§

Source§

impl Drop for DoraNode

Source§

fn drop(&mut self)

Executes the destructor for this type. Read more

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

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

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

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

fn with_current_context(self) -> WithContext<Self>

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

impl<T> FutureExt for T

Source§

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

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

fn with_current_context(self) -> WithContext<Self>

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

impl<T> Instrument for T

Source§

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

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

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

Source§

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

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
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> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. 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.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

fn with_current_subscriber(self) -> WithDispatch<Self>

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

impl<T> ErasedDestructor for T
where T: 'static,