Struct ConsommeEndpoint

pub struct ConsommeEndpoint { /* private fields */ }

Implementations

impl ConsommeEndpoint

pub fn new() -> Result<Self, Error>

pub fn new_with_state(state: ConsommeState) -> Self

pub fn new_dynamic(state: ConsommeState) -> (Self, ConsommeControl)

Trait Implementations

impl Endpoint for ConsommeEndpoint

fn endpoint_type(&self) -> &'static str

Returns an informational endpoint type.

fn get_queues<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, config: Vec<QueueConfig<'life1>>, _rss: Option<&'life2 RssConfig<'life3>>, queues: &'life4 mut Vec<Box<dyn Queue>>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Initializes the queues associated with the endpoint.

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stops the endpoint.

fn is_ordered(&self) -> bool

Specifies whether packets are always completed in order.

fn tx_offload_support(&self) -> TxOffloadSupport

Specifies the supported set of transmit offloads.

fn multiqueue_support(&self) -> MultiQueueSupport

Specifies parameters related to supporting multiple queues.

fn tx_fast_completions(&self) -> bool

If true, transmits are guaranteed to complete quickly. This is used to allow eliding tx notifications from the guest when there are already some tx packets in flight.

fn set_data_path_to_guest_vf<'life0, 'async_trait>( &'life0 self, _use_vf: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Sets the current data path for packet flow (e.g. via vmbus synthnic or through virtual function). This is only supported for endpoints that pair with an accelerated device.

fn get_data_path_to_guest_vf<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn wait_for_endpoint_action<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = EndpointAction> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

On completion, the return value indicates the specific endpoint action to take.

fn link_speed(&self) -> u64

Link speed in bps.

impl InspectMut for ConsommeEndpoint

fn inspect_mut(&mut self, req: Request<'_>)

Inspects the object.