1+ using System ;
2+ using System . Net ;
3+ using System . Threading . Tasks ;
14using EventStore . ClientAPI . Common . Utils ;
25using EventStore . ClientAPI . Common . Utils . Threading ;
36using EventStore . ClientAPI . SystemData ;
47using Newtonsoft . Json . Linq ;
5- using System ;
6- using System . Net ;
7- using System . Threading . Tasks ;
88
99namespace EventStore . ClientAPI . Projections
1010{
@@ -21,38 +21,13 @@ public class QueryManager
2121 /// Creates a new instance of <see cref="QueryManager"/>.
2222 /// </summary>
2323 /// <param name="log">An instance of <see cref="ILogger"/> to use for logging.</param>
24- /// <param name="ipHttpEndPoint ">HTTP IP endpoint of an Event Store server.</param>
24+ /// <param name="httpEndPoint ">HTTP endpoint of an Event Store server.</param>
2525 /// <param name="projectionOperationTimeout">Timeout of projection API operations</param>
2626 /// <param name="queryTimeout">Timeout of query execution</param>
27- public QueryManager ( ILogger log , IPEndPoint ipHttpEndPoint , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
27+ public QueryManager ( ILogger log , IPEndPoint httpEndPoint , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
2828 {
2929 _queryTimeout = queryTimeout ;
30- _projectionsManager = new ProjectionsManager ( log , ipHttpEndPoint , projectionOperationTimeout ) ;
31- }
32-
33- /// <summary>
34- /// Creates a new instance of <see cref="QueryManager"/>.
35- /// </summary>
36- /// <param name="log">An instance of <see cref="ILogger"/> to use for logging.</param>
37- /// <param name="dnsHttpEndPoint">HTTP DNS endpoint of an Event Store server.</param>
38- /// <param name="projectionOperationTimeout">Timeout of projection API operations</param>
39- /// <param name="queryTimeout">Timeout of query execution</param>
40- public QueryManager ( ILogger log , DnsEndPoint dnsHttpEndPoint , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
41- {
42- _queryTimeout = queryTimeout ;
43- _projectionsManager = new ProjectionsManager ( log , dnsHttpEndPoint , projectionOperationTimeout ) ;
44- }
45-
46- /// <summary>
47- /// Creates a new instance of <see cref="T:EventStore.ClientAPI.Projections.QueryManager" />.
48- /// </summary>
49- /// <param name="log">An instance of <see cref="T:EventStore.ClientAPI.ILogger" /> to use for logging.</param>
50- /// <param name="uri">HTTP URI endpoint of an Event Store server.</param>
51- /// <param name="projectionOperationTimeout">Timeout of projection API operations</param>
52- /// <param name="queryTimeout">Timeout of query execution</param>
53- public QueryManager ( ILogger log , Uri uri , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
54- : this ( log , new DnsEndPoint ( uri . Host , uri . Port ) , projectionOperationTimeout , queryTimeout )
55- {
30+ _projectionsManager = new ProjectionsManager ( log , httpEndPoint , projectionOperationTimeout ) ;
5631 }
5732
5833 /// <summary>
@@ -105,4 +80,4 @@ private async Task<string> GetStatusAsync(string name, UserCredentials userCrede
10580 return projectionStatus . ParseJson < JObject > ( ) [ "status" ] . ToString ( ) ;
10681 }
10782 }
108- }
83+ }
0 commit comments