Struct EventHubTrigger

Source
pub struct EventHubTrigger {
    pub message: EventHubMessage,
    pub partition_context: PartitionContext,
    pub enqueued_time: DateTime<Utc>,
    pub offset: String,
    pub properties: Value,
    pub sequence_number: i64,
    pub system_properties: SystemProperties,
}
Expand description

Represents an Event Hub trigger binding.

The following binding attributes are supported:

NameDescription
nameThe name of the parameter being bound.
event_hub_nameThe name of the event hub. When the event hub name is also present in the connection string, that value overrides this property at runtime.
connectionThe name of an app setting that contains the connection string to the event hub’s namespace. This connection string must have at least read permissions to activate the trigger.
consumer_groupAn optional property that sets the consumer group used to subscribe to events in the hub. If omitted, the $Default consumer group is used.

§Examples

use azure_functions::{
    bindings::EventHubTrigger,
    func,
};
use log::info;

#[func]
#[binding(name = "trigger", connection = "my_connection")]
pub fn log_event(trigger: EventHubTrigger) {
    log::info!("{:?}", trigger);
}

Fields§

§message: EventHubMessage

The Event Hub message that triggered the function.

§partition_context: PartitionContext

The partition context information.

§enqueued_time: DateTime<Utc>

The enqueued time in UTC.

§offset: String

The offset of the data relative to the Event Hub partition stream.

§properties: Value

The user properties of the event data.

§sequence_number: i64

The logical sequence number of the event.

§system_properties: SystemProperties

The system properties of the event data.

Trait Implementations§

Source§

impl Debug for EventHubTrigger

Source§

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

Formats the value using the given formatter. 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> 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> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
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<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