Struct azure_functions::bindings::EventHubMessage

pub struct EventHubMessage(_);

Represents an Event Hubs message output 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 send permissions to send the message to the event stream.

Examples

Creating a message from a string:

use azure_functions::bindings::{HttpRequest, EventHubMessage};
use azure_functions::func;

#[func]
#[binding(name = "output1", connection = "connection", event_hub_name = "example")]
pub fn create_message(_req: HttpRequest) -> ((), EventHubMessage) {
    ((), "Hello world!".into())
}

Creating a message from a JSON value (see the json! macro from the serde_json crate):

use azure_functions::bindings::{HttpRequest, EventHubMessage};
use azure_functions::func;
use serde_json::json;

#[func]
#[binding(name = "output1", connection = "connection", event_hub_name = "example")]
pub fn create_message(_req: HttpRequest) -> ((), EventHubMessage) {
    (() ,json!({ "hello": "world!" }).into())
}

Creating a message from a sequence of bytes:

use azure_functions::bindings::{HttpRequest, EventHubMessage};
use azure_functions::func;

#[func]
#[binding(name = "output1", connection = "connection", event_hub_name = "example")]
pub fn create_message(_req: HttpRequest) -> ((), EventHubMessage) {
    ((), [1, 2, 3][..].into())
}

Methods

impl EventHubMessage

pub fn as_str(&self) -> Option<&str>

Gets the content of the message as a string.

Returns None if there is no valid string representation of the message.

pub fn as_bytes(&self) -> &[u8]

Gets the content of the message as a slice of bytes.

pub fn as_json<'b, T>(&'b self) -> Result<T> where
    T: Deserialize<'b>, 

Deserializes the message as JSON to the requested type.

Trait Implementations

impl Into<String> for EventHubMessage

fn into(self) -> String

Performs the conversion.

impl Into<Value> for EventHubMessage

fn into(self) -> Value

Performs the conversion.

impl Into<Vec<u8>> for EventHubMessage

fn into(self) -> Vec<u8>

Performs the conversion.

impl<'a> Into<Body<'a>> for EventHubMessage

fn into(self) -> Body<'a>

Performs the conversion.

impl Clone for EventHubMessage

fn clone(&self) -> EventHubMessage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> From<&'a str> for EventHubMessage

fn from(content: &'a str) -> Self

Performs the conversion.

impl From<String> for EventHubMessage

fn from(content: String) -> Self

Performs the conversion.

impl<'_> From<&'_ Value> for EventHubMessage

fn from(content: &Value) -> Self

Performs the conversion.

impl From<Value> for EventHubMessage

fn from(content: Value) -> Self

Performs the conversion.

impl<'a> From<&'a [u8]> for EventHubMessage

fn from(content: &'a [u8]) -> Self

Performs the conversion.

impl From<Vec<u8>> for EventHubMessage

fn from(content: Vec<u8>) -> Self

Performs the conversion.

impl Debug for EventHubMessage

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

Formats the value using the given formatter.

impl Display for EventHubMessage

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

Formats the value using the given formatter.