File tree Expand file tree Collapse file tree 6 files changed +11
-11
lines changed
core/bench/src/args/kinds Expand file tree Collapse file tree 6 files changed +11
-11
lines changed Original file line number Diff line number Diff line change @@ -74,8 +74,8 @@ impl BenchmarkKindProps for BalancedConsumerGroupArgs {
7474 }
7575
7676 fn validate ( & self ) {
77- let cg_number = self . consumer_groups . get ( ) ;
78- let streams = self . streams . get ( ) ;
77+ let cg_number = self . number_of_consumer_groups ( ) ;
78+ let streams = self . streams ( ) ;
7979 let mut cmd = IggyBenchArgs :: command ( ) ;
8080
8181 if cg_number < streams {
Original file line number Diff line number Diff line change @@ -82,7 +82,7 @@ impl BenchmarkKindProps for BalancedProducerArgs {
8282 }
8383
8484 fn validate ( & self ) {
85- let partitions = self . partitions . get ( ) ;
85+ let partitions = self . partitions ( ) ;
8686 let mut cmd = IggyBenchArgs :: command ( ) ;
8787
8888 if partitions < 2 {
Original file line number Diff line number Diff line change @@ -87,8 +87,8 @@ impl BenchmarkKindProps for BalancedProducerAndConsumerGroupArgs {
8787 }
8888
8989 fn validate ( & self ) {
90- let cg_number = self . consumer_groups . get ( ) ;
91- let streams = self . streams . get ( ) ;
90+ let cg_number = self . number_of_consumer_groups ( ) ;
91+ let streams = self . streams ( ) ;
9292 let mut cmd = IggyBenchArgs :: command ( ) ;
9393
9494 if cg_number < streams {
@@ -99,8 +99,8 @@ impl BenchmarkKindProps for BalancedProducerAndConsumerGroupArgs {
9999 . exit ( ) ;
100100 }
101101
102- let partitions = self . partitions . get ( ) ;
103- let consumers = self . consumers . get ( ) ;
102+ let partitions = self . partitions ( ) ;
103+ let consumers = self . consumers ( ) ;
104104
105105 if partitions < consumers {
106106 cmd. error (
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ impl BenchmarkKindProps for EndToEndProducingConsumerArgs {
7575
7676 fn validate ( & self ) {
7777 let mut cmd = IggyBenchArgs :: command ( ) ;
78- let streams = self . streams . get ( ) ;
78+ let streams = self . streams ( ) ;
7979 let producing_consumers = self . producers ( ) ;
8080 if streams > producing_consumers {
8181 cmd. error (
Original file line number Diff line number Diff line change @@ -101,7 +101,7 @@ impl BenchmarkKindProps for EndToEndProducingConsumerGroupArgs {
101101 . exit ( ) ;
102102 }
103103
104- let cg_number = self . consumer_groups . get ( ) ;
104+ let cg_number = self . number_of_consumer_groups ( ) ;
105105 if cg_number < streams {
106106 cmd. error (
107107 ErrorKind :: ArgumentConflict ,
Original file line number Diff line number Diff line change @@ -86,7 +86,7 @@ impl BenchmarkKindProps for PinnedProducerAndConsumerArgs {
8686 }
8787
8888 fn validate ( & self ) {
89- let partitions = self . partitions . get ( ) ;
89+ let partitions = self . partitions ( ) ;
9090 let mut cmd = IggyBenchArgs :: command ( ) ;
9191
9292 if partitions > 1 {
@@ -98,7 +98,7 @@ impl BenchmarkKindProps for PinnedProducerAndConsumerArgs {
9898 }
9999
100100 let streams = self . streams ( ) ;
101- let producers = self . producers . get ( ) ;
101+ let producers = self . producers ( ) ;
102102 let mut cmd = IggyBenchArgs :: command ( ) ;
103103
104104 if streams != producers {
You can’t perform that action at this time.
0 commit comments