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:
Name | Description |
---|---|
name | The name of the parameter being bound. |
event_hub_name | The name of the event hub. When the event hub name is also present in the connection string, that value overrides this property at runtime. |
connection | The 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_group | An 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§
Auto Trait Implementations§
impl Freeze for EventHubTrigger
impl RefUnwindSafe for EventHubTrigger
impl Send for EventHubTrigger
impl Sync for EventHubTrigger
impl Unpin for EventHubTrigger
impl UnwindSafe for EventHubTrigger
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request