Skip to main content

datafusion_distributed/protocol/grpc/
mod.rs

1mod channel_resolver;
2mod errors;
3mod generated;
4mod metrics_proto;
5mod observability;
6mod on_drop_stream;
7mod spawn_select_all;
8mod worker_client;
9mod worker_service;
10
11// TODO: this should not be exposed.
12pub(crate) use channel_resolver::DEFAULT_CHANNEL_RESOLVER_PER_RUNTIME;
13
14pub use channel_resolver::{BoxCloneSyncChannel, DefaultChannelResolver};
15pub use observability::{
16    GetClusterWorkersRequest, GetClusterWorkersResponse, GetTaskProgressRequest,
17    GetTaskProgressResponse, ObservabilityService, ObservabilityServiceClient,
18    ObservabilityServiceImpl, ObservabilityServiceServer, PingRequest, PingResponse, TaskProgress,
19    TaskStatus, WorkerMetrics,
20};
21pub use worker_client::create_worker_client;