Crate drasi_reaction_grpc 

gRPC reaction plugin for Drasi

This plugin implements gRPC reactions for Drasi.

Example

use drasi_reaction_grpc::GrpcReaction;

let reaction = GrpcReaction::builder("my-grpc-reaction")
    .with_queries(vec!["query1".to_string()])
    .with_endpoint("grpc://localhost:50052")
    .with_batch_size(200)
    .with_timeout_ms(10000)
    .build()?;

Re-exports

pub use config::GrpcReactionConfig;

pub use grpc::GrpcReaction;

pub use helpers::convert_json_to_proto_struct;

pub use proto::ProcessResultsRequest;

pub use proto::ProtoQueryResult;

pub use proto::ProtoQueryResultItem;

pub use proto::ReactionServiceClient;

Modules

config

Configuration types for gRPC reactions.

connection

Connection management for gRPC reactions.

descriptor

Descriptor for the gRPC reaction plugin.

grpc

helpers

Helper utilities for converting data to Protocol Buffer format.

proto

Protocol buffer definitions for gRPC reactions.

Structs

GrpcReactionBuilder

Builder for gRPC reaction