Skip to content

Commit 3dae7b2

Browse files
KSemenenkoKSemenenko
committed
groups and tests
1 parent e0f37ac commit 3dae7b2

26 files changed

+107
-142
lines changed

‎ManagedCode.Orleans.SignalR.Core/Interfaces/IObserverConnectionManager.cs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,8 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
66

77
public interface IObserverConnectionManager : IGrain
88
{
9-
[OneWay]
109
Task AddConnection(string connectionId, ISignalRObserver observer);
1110

12-
[OneWay]
1311
Task RemoveConnection(string connectionId, ISignalRObserver observer);
1412

1513
[OneWay]

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionCoordinatorGrain.cs‎

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -7,30 +7,22 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
77

88
public interface ISignalRConnectionCoordinatorGrain : IGrainWithStringKey
99
{
10-
[OneWay]
11-
[AlwaysInterleave]
10+
[ReadOnly]
1211
Task<int> GetPartitionCount();
1312

14-
[OneWay]
15-
[AlwaysInterleave]
13+
[ReadOnly]
1614
Task<int> GetPartitionForConnection(string connectionId);
1715

1816
[OneWay]
19-
[AlwaysInterleave]
2017
Task SendToAll(HubMessage message);
2118

2219
[OneWay]
23-
[AlwaysInterleave]
2420
Task SendToAllExcept(HubMessage message, string[] excludedConnectionIds);
2521

26-
[AlwaysInterleave]
2722
Task<bool> SendToConnection(HubMessage message, string connectionId);
2823

2924
[OneWay]
30-
[AlwaysInterleave]
3125
Task SendToConnections(HubMessage message, string[] connectionIds);
3226

33-
[OneWay]
34-
[AlwaysInterleave]
3527
Task NotifyConnectionRemoved(string connectionId);
3628
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionHeartbeatGrain.cs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,8 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
77

88
public interface ISignalRConnectionHeartbeatGrain : IGrainWithStringKey
99
{
10-
[AlwaysInterleave]
1110
Task Start(ConnectionHeartbeatRegistration registration);
1211

1312
[OneWay]
14-
[AlwaysInterleave]
1513
Task Stop();
1614
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionHolderGrain.cs‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,17 +8,13 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
88
public interface ISignalRConnectionHolderGrain : IGrainWithStringKey, IObserverConnectionManager
99
{
1010
[OneWay]
11-
[AlwaysInterleave]
1211
Task SendToAll(HubMessage message);
1312

1413
[OneWay]
15-
[AlwaysInterleave]
1614
Task SendToAllExcept(HubMessage message, string[] excludedConnectionIds);
1715

18-
[AlwaysInterleave]
1916
Task<bool> SendToConnection(HubMessage message, string connectionId);
2017

2118
[OneWay]
22-
[AlwaysInterleave]
2319
Task SendToConnections(HubMessage message, string[] connectionIds);
2420
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRConnectionPartitionGrain.cs‎

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,18 +8,13 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
88
public interface ISignalRConnectionPartitionGrain : IGrainWithIntegerKey, IObserverConnectionManager
99
{
1010
[OneWay]
11-
[AlwaysInterleave]
1211
Task SendToPartition(HubMessage message);
1312

1413
[OneWay]
15-
[AlwaysInterleave]
1614
Task SendToPartitionExcept(HubMessage message, string[] excludedConnectionIds);
1715

18-
[OneWay]
19-
[AlwaysInterleave]
2016
Task<bool> SendToConnection(HubMessage message, string connectionId);
2117

2218
[OneWay]
23-
[AlwaysInterleave]
2419
Task SendToConnections(HubMessage message, string[] connectionIds);
2520
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupCoordinatorGrain.cs‎

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -7,35 +7,26 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
77

88
public interface ISignalRGroupCoordinatorGrain : IGrainWithStringKey
99
{
10-
[OneWay]
11-
[AlwaysInterleave]
10+
[ReadOnly]
1211
Task<int> GetPartitionCount();
1312

14-
[OneWay]
15-
[AlwaysInterleave]
13+
[ReadOnly]
1614
Task<int> GetPartitionForGroup(string groupName);
1715

1816
[OneWay]
19-
[AlwaysInterleave]
2017
Task SendToGroup(string groupName, HubMessage message);
2118

2219
[OneWay]
23-
[AlwaysInterleave]
2420
Task SendToGroupExcept(string groupName, HubMessage message, string[] excludedConnectionIds);
2521

2622
[OneWay]
27-
[AlwaysInterleave]
2823
Task SendToGroups(string[] groupNames, HubMessage message);
2924

3025
[OneWay]
31-
[AlwaysInterleave]
3226
Task AddConnectionToGroup(string groupName, string connectionId, ISignalRObserver observer);
3327

3428
[OneWay]
35-
[AlwaysInterleave]
3629
Task RemoveConnectionFromGroup(string groupName, string connectionId, ISignalRObserver observer);
3730

38-
[OneWay]
39-
[AlwaysInterleave]
4031
Task NotifyGroupRemoved(string groupName);
4132
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupGrain.cs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,8 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
88
public interface ISignalRGroupGrain : IGrainWithStringKey, IObserverConnectionManager
99
{
1010
[OneWay]
11-
[AlwaysInterleave]
1211
Task SendToGroup(HubMessage message);
1312

1413
[OneWay]
15-
[AlwaysInterleave]
1614
Task SendToGroupExcept(HubMessage message, string[] excludedConnectionIds);
1715
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRGroupPartitionGrain.cs‎

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -8,26 +8,20 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
88
public interface ISignalRGroupPartitionGrain : IGrainWithIntegerKey, IObserverConnectionManager
99
{
1010
[OneWay]
11-
[AlwaysInterleave]
1211
Task SendToGroups(HubMessage message, string[] groupNames);
1312

1413
[OneWay]
15-
[AlwaysInterleave]
1614
Task SendToGroupsExcept(HubMessage message, string[] groupNames, string[] excludedConnectionIds);
1715

1816
[OneWay]
19-
[AlwaysInterleave]
2017
Task AddConnectionToGroup(string groupName, string connectionId, ISignalRObserver observer);
2118

2219
[OneWay]
23-
[AlwaysInterleave]
2420
Task RemoveConnectionFromGroup(string groupName, string connectionId, ISignalRObserver observer);
2521

26-
[OneWay]
27-
[AlwaysInterleave]
22+
[ReadOnly]
2823
Task<bool> HasConnection(string connectionId);
2924

3025
[OneWay]
31-
[AlwaysInterleave]
3226
Task EnsureInitialized(string hubKey);
3327
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRInvocationGrain.cs‎

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,18 +9,13 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
99
public interface ISignalRInvocationGrain : IGrainWithStringKey, IObserverConnectionManager
1010
{
1111
[OneWay]
12-
[AlwaysInterleave]
1312
Task TryCompleteResult(string connectionId, HubMessage message);
1413

15-
[AlwaysInterleave]
1614
Task<ReturnType> TryGetReturnType();
1715

18-
[AlwaysInterleave]
1916
Task AddInvocation(ISignalRObserver? observer, InvocationInfo invocationInfo);
2017

21-
[AlwaysInterleave]
2218
Task<InvocationInfo?> RemoveInvocation();
2319

24-
[AlwaysInterleave]
2520
Task<CompletionMessage?> WaitForCompletion();
2621
}

‎ManagedCode.Orleans.SignalR.Core/Interfaces/ISignalRUserGrain.cs‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,8 @@ namespace ManagedCode.Orleans.SignalR.Core.Interfaces;
88
public interface ISignalRUserGrain : IGrainWithStringKey, IObserverConnectionManager
99
{
1010
[OneWay]
11-
[AlwaysInterleave]
1211
Task SendToUser(HubMessage message);
1312

1413
[OneWay]
15-
[AlwaysInterleave]
1614
Task RequestMessage();
1715
}

0 commit comments

Comments
 (0)