Crate faucet_source_grpc 

faucet-source-grpc

A config-driven gRPC source that uses protobuf reflection to call any gRPC service dynamically and return records as JSON.

Supports both RpcKind::Unary (one request → one response) and RpcKind::ServerStreaming (one request → server-driven stream of responses) — see the crate README for the differences in batching and reconnect behaviour.

Requires a compiled FileDescriptorSet (produced by protoc --descriptor_set_out=descriptor.bin).

Re-exports

pub use config::GrpcAuth;

pub use config::GrpcStreamConfig;

pub use config::MetadataEntry;

pub use config::RpcKind;

pub use stream::GrpcStream;

Modules

config

gRPC source configuration.

stream

gRPC stream executor using dynamic protobuf messages.

Enums

AuthSpec

A connector’s auth: field: either an inline auth definition A (the { type, config } shape), or a { ref: <name> } reference to a shared provider defined in the top-level auth: catalog.

FaucetError

All possible errors returned by faucet-stream.

Traits

Source

A source fetches records from an external system.

Type Aliases

SharedAuthProvider

A shared AuthProvider handle. Cloning it shares the one live provider (and its single token cache) across connectors.