Struct HeaderFields 

pub struct HeaderFields;

The delivery’s headers, built from the row’s header fields: set by InboxSpec::header_fields.

Examples

use ruststream::HeaderMap;
use ruststream::runtime::{Input, SoloCarried};
use ruststream_sqlx::dialect::Column;
use ruststream_sqlx::spec;
use ruststream_sqlx::{HeaderFields, InboxSpec, InboxTable, put_header};

#[derive(Debug, Clone, sqlx::FromRow)]
pub struct Signal {
    id: i64,
    trace: Option<String>,
    sensor: String,
    value: f64,
}

impl InboxTable for Signal {
    type Id = i64;
    // `trace` reads as a header; a row without one has no `trace` header.
    type Table = InboxSpec<(spec::HeaderFields,)>;
    const TABLE: Self::Table = InboxSpec::new("signals", Column::new("id").generated())
        .data(&[Column::new("trace"), Column::new("sensor"), Column::new("value")])
        .header_fields();

    fn id(&self) -> &i64 {
        &self.id
    }
}

impl HeaderFields for Signal {
    const NAMES: &'static [&'static str] = &["trace"];

    fn header_map(&self) -> HeaderMap {
        let mut headers = HeaderMap::with_capacity(Self::NAMES.len());
        put_header(&mut headers, "trace", &self.trace);
        headers
    }
}

Trait Implementations

impl Debug for HeaderFields

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

Formats the value using the given formatter.

impl Declaration for HeaderFields

type Form = Unset

The form: Lease or Advisory; unset for the row lock form.

type Message = Unset

The message mode: Payload; unset for row mode.

type Key = Unset

The partition key: Key.

type Attempt = Unset

The attempt count: Attempt.

type Headers = Set<HeaderFields>

The delivery’s headers: Headers or HeaderFields.

type RetryAfter = Unset

The time a retried row is due: RetryAfter.

type ProcessedAt = Unset

The time a row was processed: ProcessedAt.

type Clock = Unset

The clock: Clock; unset for SystemClock.

type Opening = Unset

What the table’s transactions open at: Opens; unset for the database’s default.

type Fifo = Unset

Groups kept in order: Fifo.

type OwnClaim = Unset

The service’s own claim: own::Claim.

type OwnFetch = Unset

The service’s own fetch: own::Fetch.

type OwnAck = Unset

The service’s own ack: own::Ack.

type OwnRetry = Unset

The service’s own retry: own::Retry.

type OwnRetryAfter = Unset

The service’s own delayed retry: own::RetryAfter.

type OwnDiscard = Unset

The service’s own discard: own::Discard.

type OwnDeadLetter = Unset

The service’s own dead letter: own::DeadLetter.

type OwnExtend = Unset

The service’s own lease extension: own::Extend.

type OwnLock = Unset

The service’s own lock: own::Lock.

type OwnUnlock = Unset

The service’s own unlock: own::Unlock.