@@ -50,12 +50,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
50
50
. help ( "the identity to use with the dummy adapter" )
51
51
. takes_value ( true ) ,
52
52
)
53
- . arg (
54
- Arg :: with_name ( "clustered" )
55
- . long ( "clustered" )
56
- . short ( "c" )
57
- . help ( "Run app in cluster mode with multiple workers" ) ,
58
- )
59
53
. get_matches ( ) ;
60
54
61
55
let environment = std:: env:: var ( "ENV" ) . unwrap_or_else ( |_| "development" . into ( ) ) ;
@@ -64,7 +58,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
64
58
. unwrap_or_else ( |_| DEFAULT_PORT ) ;
65
59
let config_file = cli. value_of ( "config" ) ;
66
60
let config = configuration ( & environment, config_file) . unwrap ( ) ;
67
- let clustered = cli. is_present ( "clustered" ) ;
68
61
69
62
let adapter = match cli. value_of ( "adapter" ) . unwrap ( ) {
70
63
"ethereum" => {
@@ -112,15 +105,13 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
112
105
AdapterTypes :: EthereumAdapter ( adapter) => {
113
106
run (
114
107
Application :: new ( * adapter, config, logger, redis, postgres) ,
115
- clustered,
116
108
port,
117
109
)
118
110
. await
119
111
}
120
112
AdapterTypes :: DummyAdapter ( adapter) => {
121
113
run (
122
114
Application :: new ( * adapter, config, logger, redis, postgres) ,
123
- clustered,
124
115
port,
125
116
)
126
117
. await
@@ -131,7 +122,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
131
122
}
132
123
133
124
/// Starts the `hyper` `Server`.
134
- async fn run < A : Adapter + ' static > ( app : Application < A > , _clustered : bool , port : u16 ) {
125
+ async fn run < A : Adapter + ' static > ( app : Application < A > , port : u16 ) {
135
126
let addr = ( [ 127 , 0 , 0 , 1 ] , port) . into ( ) ;
136
127
let logger = app. logger . clone ( ) ;
137
128
info ! ( & logger, "Listening on port {}!" , port) ;
0 commit comments