Skip to content
This repository was archived by the owner on Feb 16, 2019. It is now read-only.

Commit 58e4d78

Browse files
committed
Revert divergent PR - will be moved to main repo and released with unified client
1 parent 6162cf3 commit 58e4d78

1 file changed

Lines changed: 7 additions & 32 deletions

File tree

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

Lines changed: 7 additions & 32 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;
14
using EventStore.ClientAPI.Common.Utils;
25
using EventStore.ClientAPI.Common.Utils.Threading;
36
using EventStore.ClientAPI.SystemData;
47
using Newtonsoft.Json.Linq;
5-
using System;
6-
using System.Net;
7-
using System.Threading.Tasks;
88

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

Comments
 (0)