1- using System ;
2- using System . Net ;
3- using System . Threading . Tasks ;
41using EventStore . ClientAPI . Common . Utils ;
52using EventStore . ClientAPI . Common . Utils . Threading ;
63using EventStore . ClientAPI . SystemData ;
74using Newtonsoft . Json . Linq ;
5+ using System ;
6+ using System . Net ;
7+ using System . Threading . Tasks ;
88
99namespace EventStore . ClientAPI . Projections
1010{
@@ -21,13 +21,38 @@ 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="httpEndPoint ">HTTP endpoint of an Event Store server.</param>
24+ /// <param name="ipHttpEndPoint ">HTTP IP 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 httpEndPoint , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
27+ public QueryManager ( ILogger log , IPEndPoint ipHttpEndPoint , TimeSpan projectionOperationTimeout , TimeSpan queryTimeout )
2828 {
2929 _queryTimeout = queryTimeout ;
30- _projectionsManager = new ProjectionsManager ( log , httpEndPoint , projectionOperationTimeout ) ;
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+ {
3156 }
3257
3358 /// <summary>
@@ -80,4 +105,4 @@ private async Task<string> GetStatusAsync(string name, UserCredentials userCrede
80105 return projectionStatus . ParseJson < JObject > ( ) [ "status" ] . ToString ( ) ;
81106 }
82107 }
83- }
108+ }
0 commit comments