[][src]Struct azure_functions::bindings::EventHubTrigger

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,
}

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

impl Debug for EventHubTrigger[src]

Auto Trait Implementations

Blanket Implementations

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> From<T> for T[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

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

The type returned in the event of a conversion error.

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> IntoRequest<T> for T[src]

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