Crate drasi_reaction_grpc_adaptive 

gRPC Adaptive reaction plugin for Drasi

This plugin implements gRPC Adaptive reactions for Drasi.

Example

use drasi_reaction_grpc_adaptive::AdaptiveGrpcReaction;

let reaction = AdaptiveGrpcReaction::builder("my-grpc-adaptive")
    .with_queries(vec!["query1".to_string()])
    .with_endpoint("grpc://localhost:50052")
    .with_max_batch_size(500)
    .build()?;

Re-exports

pub use config::GrpcAdaptiveReactionConfig;

pub use grpc_adaptive::AdaptiveGrpcReaction;

Modules

config

Configuration types for gRPC adaptive reaction.

descriptor

Descriptor for the gRPC adaptive reaction plugin.

grpc_adaptive

Structs

GrpcAdaptiveReactionBuilder

Builder for gRPC Adaptive reaction