Skip to content

Commit 44a3bd9

Browse files
committed
Added constructor overloads to allow supply of a Uri or DnsEndPoint
1 parent 81c0e03 commit 44a3bd9

1 file changed

Lines changed: 32 additions & 7 deletions

File tree

‎src/EventStore.ClientAPI.NetCore/Projections/QueryManager.cs‎

Lines changed: 32 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
using System;
2-
using System.Net;
3-
using System.Threading.Tasks;
41
using EventStore.ClientAPI.Common.Utils;
52
using EventStore.ClientAPI.Common.Utils.Threading;
63
using EventStore.ClientAPI.SystemData;
74
using Newtonsoft.Json.Linq;
5+
using System;
6+
using System.Net;
7+
using System.Threading.Tasks;
88

99
namespace 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

Comments
 (0)