Skip to content

Commit f6a1a93

Browse files
committed
docs:完善Cargo.toml内容
1 parent d31e9be commit f6a1a93

File tree

3 files changed

+0
-478
lines changed

3 files changed

+0
-478
lines changed

src/plugins/connector/grpc/connector.rs

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ use crate::core::model::pb::lib::{
2727
};
2828
use crate::core::plugin::connector::{Connector, InitConnectorOption, ResourceHandler};
2929
use crate::core::plugin::plugins::Plugin;
30-
use crate::plugins::connector::grpc::manager::ConnectionManager;
3130
use std::cmp::PartialEq;
3231
use std::collections::HashMap;
3332
use std::str::FromStr;
@@ -46,8 +45,6 @@ use tonic::transport::{Channel, Endpoint};
4645
use tonic::Streaming;
4746
use tracing::Instrument;
4847

49-
use super::manager::EmptyConnectionSwitchListener;
50-
5148
struct ResourceHandlerWrapper {
5249
handler: Box<dyn ResourceHandler>,
5350
revision: String,
@@ -58,7 +55,6 @@ pub struct GrpcConnector {
5855
opt: InitConnectorOption,
5956
discover_channel: Channel,
6057
config_channel: Channel,
61-
connection_manager: Arc<ConnectionManager>,
6258
discover_grpc_client: PolarisGrpcClient<Channel>,
6359
config_grpc_client: PolarisConfigGrpcClient<Channel>,
6460

@@ -90,12 +86,6 @@ fn new_connector(opt: InitConnectorOption) -> Box<dyn Connector> {
9086
opt: opt,
9187
discover_channel: discover_channel.clone(),
9288
config_channel: config_channel.clone(),
93-
connection_manager: Arc::new(ConnectionManager::new(
94-
connect_timeout,
95-
server_switch_interval,
96-
client_id,
97-
Arc::new(EmptyConnectionSwitchListener::new()),
98-
)),
9989
discover_grpc_client: discover_grpc_client,
10090
config_grpc_client: config_grpc_client,
10191

0 commit comments

Comments
 (0)