Crate drasi_reaction_platform 

Platform reaction plugin for Drasi

This plugin implements Platform reactions for Drasi.

Example

use drasi_reaction_platform::PlatformReaction;

let reaction = PlatformReaction::builder("my-platform-reaction")
    .with_queries(vec!["query1".to_string()])
    .with_redis_url("redis://localhost:6379")
    .with_batch_enabled(true)
    .build()?;

Re-exports

pub use config::PlatformReactionConfig;

pub use platform::PlatformReaction;

Modules

config

Configuration types for Platform reactions (Redis Streams publishing).

descriptor

Descriptor for the platform reaction plugin.

platform

Platform Reaction for publishing query results to Redis Streams

publisher

Redis Stream publisher for CloudEvents

transformer

Transformation logic for converting drasi-core QueryResult to Platform ChangeEvent

types

Type definitions for Platform Reaction based on Drasi Platform TypeSpec schema

Structs

PlatformReactionBuilder

Builder for Platform reaction