Struct OracleReactiveHandler 

pub struct OracleReactiveHandler { /* private fields */ }

Reactive-runtime bridge for Chainlink-compatible oracle feeds.

Implementations

impl OracleReactiveHandler

pub fn new(registrations: Vec<FeedRegistration>) -> Self

Create a handler from current feed registrations.

pub fn with_storage_sync( registrations: Vec<FeedRegistration>, storage_sync: OracleStorageSync, ) -> Self

Create a handler from current feed registrations and storage adapters.

pub fn id(&self) -> HandlerId

Stable handler id.

pub fn interests(&self) -> Vec<ReactiveInterest<Ethereum>>

Interests for current aggregators.

pub fn handle_for_test( &self, ctx: &ReactiveContext, input: &ReactiveInput<Ethereum>, ) -> Result<HandlerOutcome, HandlerError>

Test helper that avoids requiring callers to construct a cache view.

Trait Implementations

impl Clone for OracleReactiveHandler

fn clone(&self) -> OracleReactiveHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OracleReactiveHandler

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

Formats the value using the given formatter.

impl ReactiveHandler for OracleReactiveHandler

fn id(&self) -> HandlerId

Stable handler id.

fn interests(&self) -> Vec<ReactiveInterest<Ethereum>>

Interests used by subscribers and the local router.

fn handle( &self, ctx: &ReactiveContext, input: &ReactiveInput<Ethereum>, state: &dyn StateView, ) -> Result<HandlerOutcome, HandlerError>

Handle one input against a read-only cache view.

fn log_route_index(&self) -> Option<LogRouteIndex>

Exhaustive exact keys for log inputs this handler can accept.