@@ -62,37 +62,7 @@ let ``WorkerPlugin Init, Start, Stop should be invoked once for Warmup and once
6262 test <@ List.rev invocationOrder = [ " init" ; " start" ; " stop" ; " start" ; " stop" ; " get_stats" ; " get_hints" ; " dispose" ] @>
6363
6464[<Fact>]
65- let ``StartTest should be invoked once`` () =
66-
67- let scenarios = PluginTestHelper.createScenarios()
68- let mutable pluginStartTestInvokedCounter = 0
69-
70- let plugin = {
71- new IWorkerPlugin with
72- member _.PluginName = " TestPlugin"
73- member _.Init ( _ , _ ) = Task.CompletedTask
74-
75- member _.Start () =
76- pluginStartTestInvokedCounter <- pluginStartTestInvokedCounter + 1
77- Task.CompletedTask
78-
79- member _.GetHints () = Array.empty
80- member _.GetStats ( _ ) = Task.FromResult( new DataSet())
81- member _.Stop () = Task.CompletedTask
82- member _.Dispose () = ()
83- }
84-
85- NBomberRunner.registerScenarios scenarios
86- |> NBomberRunner.withWorkerPlugins [ plugin]
87- |> NBomberRunner.run
88- |> Result.mapError( fun x -> failwith x)
89- |> ignore
90-
91- test <@ pluginStartTestInvokedCounter = 1 @>
92-
93-
94- [<Fact>]
95- let ``StartTest should be invoked with infra config`` () =
65+ let ``Init should be invoked with infra config`` () =
9666
9767 let scenarios = PluginTestHelper.createScenarios()
9868 let mutable pluginConfig = Unchecked.defaultof<_>
@@ -123,62 +93,6 @@ let ``StartTest should be invoked with infra config`` () =
12393
12494 test <@ isNull serilogConfig = false @>
12595
126- [<Fact>]
127- let ``GetStats should be invoked only one time when final stats fetching`` () =
128-
129- let scenarios = PluginTestHelper.createScenarios()
130- let mutable pluginGetStatsInvokedCounter = 0
131-
132- let plugin = {
133- new IWorkerPlugin with
134- member _.PluginName = " TestPlugin"
135- member _.Init ( _ , _ ) = Task.CompletedTask
136- member _.Start () = Task.CompletedTask
137-
138- member _.GetStats ( stats ) =
139- pluginGetStatsInvokedCounter <- pluginGetStatsInvokedCounter + 1
140- Task.FromResult( new DataSet())
141-
142- member _.GetHints () = Array.empty
143- member _.Stop () = Task.CompletedTask
144- member _.Dispose () = ()
145- }
146-
147- NBomberRunner.registerScenarios scenarios
148- |> NBomberRunner.withWorkerPlugins [ plugin]
149- |> NBomberRunner.run
150- |> Result.mapError( fun x -> failwith x)
151- |> ignore
152-
153- test <@ pluginGetStatsInvokedCounter = 1 @>
154-
155- [<Fact>]
156- let ``StopTest should be invoked once`` () =
157-
158- let scenarios = PluginTestHelper.createScenarios()
159- let mutable pluginFinishTestInvokedCounter = 0
160-
161- let plugin = {
162- new IWorkerPlugin with
163- member _.PluginName = " TestPlugin"
164- member _.Init ( _ , _ ) = Task.CompletedTask
165- member _.Start () = Task.CompletedTask
166- member _.GetStats ( _ ) = Task.FromResult( new DataSet())
167- member _.GetHints () = Array.empty
168- member _.Stop () =
169- pluginFinishTestInvokedCounter <- pluginFinishTestInvokedCounter + 1
170- Task.CompletedTask
171- member _.Dispose () = ()
172- }
173-
174- NBomberRunner.registerScenarios scenarios
175- |> NBomberRunner.withWorkerPlugins [ plugin]
176- |> NBomberRunner.run
177- |> Result.mapError( fun x -> failwith x)
178- |> ignore
179-
180- test <@ pluginFinishTestInvokedCounter = 1 @>
181-
18296[<Fact>]
18397let ``PluginStats should return empty data set in case of execution timeout`` () =
18498 let inMemorySink = new InMemorySink()
0 commit comments