Skip to content

Commit faa6eaf

Browse files
authored
add conn opts (#222)
1 parent bc3db12 commit faa6eaf

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

pubsub/src/client.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,8 @@ pub struct ClientConfig {
2424
pub environment: Environment,
2525
/// Overriding service endpoint
2626
pub endpoint: String,
27+
/// gRPC connection option
28+
pub connection_option: ConnectionOptions,
2729
}
2830

2931
/// ClientConfigs created by default will prefer to use `PUBSUB_EMULATOR_HOST`
@@ -39,6 +41,7 @@ impl Default for ClientConfig {
3941
},
4042
project_id: default_project_id,
4143
endpoint: PUBSUB.to_string(),
44+
connection_option: ConnectionOptions::default(),
4245
}
4346
}
4447
}
@@ -111,7 +114,7 @@ impl Client {
111114
pool_size,
112115
config.endpoint.as_str(),
113116
&config.environment,
114-
&ConnectionOptions::default(),
117+
&config.connection_option,
115118
)
116119
.await?,
117120
);
@@ -120,7 +123,7 @@ impl Client {
120123
pool_size,
121124
config.endpoint.as_str(),
122125
&config.environment,
123-
&ConnectionOptions::default(),
126+
&config.connection_option,
124127
)
125128
.await?,
126129
);

0 commit comments

Comments
 (0)