Struct ate::time::TimestampEnforcer

pub struct TimestampEnforcer {
    pub cursor: Duration,
    pub tolerance: Duration,
    pub ntp_pool: String,
    pub ntp_port: u16,
    // some fields omitted
}

Fields

cursor: Duration

tolerance: Duration

ntp_pool: String

ntp_port: u16

Implementations

impl TimestampEnforcer

pub async fn new(
    cfg: &ConfAte,
    tolerance_ms: u32
) -> Result<TimestampEnforcer, TimeError>

Trait Implementations

impl Clone for TimestampEnforcer

fn clone(&self) -> TimestampEnforcer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TimestampEnforcer

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

Formats the value using the given formatter.

impl EventDataTransformer for TimestampEnforcer

fn clone_transformer(&self) -> Box<dyn EventDataTransformer>

fn data_as_underlay(
    &self,
    _meta: &mut Metadata,
    with: Bytes,
    _session: &Session
) -> Result<Bytes, TransformError>

Callback when data is stored in the event

fn data_as_overlay(
    &self,
    _meta: &Metadata,
    with: Bytes,
    _session: &Session
) -> Result<Bytes, TransformError>

Callback before data in an event is actually used by an actual user

impl EventIndexer for TimestampEnforcer

fn clone_indexer(&self) -> Box<dyn EventIndexer>

fn rebuild(&mut self, _data: &Vec<EventHeader>) -> Result<(), SinkError>

impl EventMetadataLinter for TimestampEnforcer

fn clone_linter(&self) -> Box<dyn EventMetadataLinter>

fn metadata_lint_event(
    &self,
    _meta: &Metadata,
    _session: &Session,
    _trans_meta: &TransactionMetadata
) -> Result<Vec<CoreMetadata>, LintError>

fn metadata_lint_many<'a>(
    &self,
    _lints: &Vec<LintData<'a>>,
    _session: &Session
) -> Result<Vec<CoreMetadata>, LintError>

Called just before the metadata is pushed into the redo log

impl EventPlugin for TimestampEnforcer

fn clone_plugin(&self) -> Box<dyn EventPlugin>

fn rebuild(&mut self, headers: &Vec<EventHeader>) -> Result<(), SinkError>

fn root_keys(&self) -> Vec<PublicSignKey>

fn set_root_keys(&mut self, _root_keys: &Vec<PublicSignKey>)

impl EventSink for TimestampEnforcer

fn feed(&mut self, header: &EventHeader) -> Result<(), SinkError>

fn reset(&mut self)

impl EventValidator for TimestampEnforcer

fn clone_validator(&self) -> Box<dyn EventValidator>

fn validate(
    &self,
    header: &EventHeader
) -> Result<ValidationResult, ValidationError>