forked from akkadotnet/akka.net
-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathCoreAPISpec.ApproveClusterSharding.Net.verified.txt
607 lines (607 loc) · 47.4 KB
/
CoreAPISpec.ApproveClusterSharding.Net.verified.txt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
[assembly: System.Reflection.AssemblyMetadataAttribute("RepositoryUrl", "https://github.com/akkadotnet/akka.net")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Cluster.Benchmarks")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Cluster.Sharding.Tests")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Cluster.Sharding.Tests.MultiNode")]
[assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.DistributedData.Tests")]
[assembly: System.Runtime.InteropServices.ComVisibleAttribute(false)]
[assembly: System.Runtime.InteropServices.GuidAttribute("a05c31e8-0246-46a1-b3bc-4d6fe7a9aa49")]
[assembly: System.Runtime.Versioning.TargetFrameworkAttribute(".NETStandard,Version=v2.0", FrameworkDisplayName=".NET Standard 2.0")]
namespace Akka.Cluster.Sharding
{
[System.Runtime.CompilerServices.NullableAttribute(0)]
public class ClusterSharding : Akka.Actor.IExtension
{
public ClusterSharding(Akka.Actor.ExtendedActorSystem system) { }
public Akka.Cluster.Sharding.ClusterShardingSettings Settings { get; }
public System.Collections.Immutable.ImmutableHashSet<string> ShardTypeNames { get; }
public static Akka.Configuration.Config DefaultConfig() { }
public Akka.Cluster.Sharding.IShardAllocationStrategy DefaultShardAllocationStrategy(Akka.Cluster.Sharding.ClusterShardingSettings settings) { }
public static Akka.Cluster.Sharding.ClusterSharding Get(Akka.Actor.ActorSystem system) { }
public Akka.Actor.IActorRef ShardRegion(string typeName) { }
public Akka.Actor.IActorRef ShardRegionProxy(string typeName) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public Akka.Actor.IActorRef Start(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public Akka.Actor.IActorRef Start(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public Akka.Actor.IActorRef Start(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
public Akka.Actor.IActorRef Start(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public Akka.Actor.IActorRef Start(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public Akka.Actor.IActorRef Start(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public Akka.Actor.IActorRef Start(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
public Akka.Actor.IActorRef Start(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, Akka.Actor.Props entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor, Akka.Cluster.Sharding.IShardAllocationStrategy allocationStrategy, object handOffStopMessage) { }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartAsync(string typeName, System.Func<string, Akka.Actor.Props> entityPropsFactory, Akka.Cluster.Sharding.ClusterShardingSettings settings, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public Akka.Actor.IActorRef StartProxy(string typeName, string role, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public Akka.Actor.IActorRef StartProxy(string typeName, string role, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
[System.ObsoleteAttribute("Use one of the overloads that accepts an IMessageExtractor instead")]
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartProxyAsync(string typeName, string role, Akka.Cluster.Sharding.ExtractEntityId extractEntityId, Akka.Cluster.Sharding.ExtractShardId extractShardId) { }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> StartProxyAsync(string typeName, string role, Akka.Cluster.Sharding.IMessageExtractor messageExtractor) { }
}
[System.Runtime.CompilerServices.NullableAttribute(new byte[] {
0,
1})]
public sealed class ClusterShardingExtensionProvider : Akka.Actor.ExtensionIdProvider<Akka.Cluster.Sharding.ClusterSharding>
{
public ClusterShardingExtensionProvider() { }
public override Akka.Cluster.Sharding.ClusterSharding CreateExtension(Akka.Actor.ExtendedActorSystem system) { }
}
public sealed class ClusterShardingSettings : Akka.Actor.INoSerializationVerificationNeeded
{
public readonly Akka.Cluster.Tools.Singleton.ClusterSingletonManagerSettings CoordinatorSingletonSettings;
public readonly string JournalPluginId;
public readonly Akka.Coordination.LeaseUsageSettings LeaseSettings;
public readonly System.TimeSpan PassivateIdleEntityAfter;
public readonly bool RememberEntities;
public readonly Akka.Cluster.Sharding.RememberEntitiesStore RememberEntitiesStore;
public readonly string Role;
public readonly System.TimeSpan ShardRegionQueryTimeout;
public readonly string SnapshotPluginId;
public readonly Akka.Cluster.Sharding.StateStoreMode StateStoreMode;
public readonly Akka.Cluster.Sharding.TuningParameters TuningParameters;
public ClusterShardingSettings(string role, bool rememberEntities, string journalPluginId, string snapshotPluginId, System.TimeSpan passivateIdleEntityAfter, Akka.Cluster.Sharding.StateStoreMode stateStoreMode, Akka.Cluster.Sharding.TuningParameters tuningParameters, Akka.Cluster.Tools.Singleton.ClusterSingletonManagerSettings coordinatorSingletonSettings) { }
public ClusterShardingSettings(string role, bool rememberEntities, string journalPluginId, string snapshotPluginId, System.TimeSpan passivateIdleEntityAfter, Akka.Cluster.Sharding.StateStoreMode stateStoreMode, Akka.Cluster.Sharding.TuningParameters tuningParameters, Akka.Cluster.Tools.Singleton.ClusterSingletonManagerSettings coordinatorSingletonSettings, Akka.Coordination.LeaseUsageSettings leaseSettings) { }
public ClusterShardingSettings(string role, bool rememberEntities, string journalPluginId, string snapshotPluginId, System.TimeSpan passivateIdleEntityAfter, Akka.Cluster.Sharding.StateStoreMode stateStoreMode, Akka.Cluster.Sharding.RememberEntitiesStore rememberEntitiesStore, System.TimeSpan shardRegionQueryTimeout, Akka.Cluster.Sharding.TuningParameters tuningParameters, Akka.Cluster.Tools.Singleton.ClusterSingletonManagerSettings coordinatorSingletonSettings, Akka.Coordination.LeaseUsageSettings leaseSettings) { }
public static Akka.Cluster.Sharding.ClusterShardingSettings Create(Akka.Actor.ActorSystem system) { }
public static Akka.Cluster.Sharding.ClusterShardingSettings Create(Akka.Configuration.Config config, Akka.Configuration.Config singletonConfig) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithCoordinatorSingletonSettings(Akka.Cluster.Tools.Singleton.ClusterSingletonManagerSettings coordinatorSingletonSettings) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithJournalPluginId(string journalPluginId) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithLeaseSettings(Akka.Coordination.LeaseUsageSettings leaseSettings) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithPassivateIdleAfter(System.TimeSpan duration) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithRememberEntities(bool rememberEntities) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithRole(string role) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithSnapshotPluginId(string snapshotPluginId) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithStateStoreMode(Akka.Cluster.Sharding.StateStoreMode mode) { }
public Akka.Cluster.Sharding.ClusterShardingSettings WithTuningParameters(Akka.Cluster.Sharding.TuningParameters tuningParameters) { }
}
public sealed class ClusterShardingStats : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.ClusterShardingStats>
{
public readonly System.Collections.Immutable.IImmutableDictionary<Akka.Actor.Address, Akka.Cluster.Sharding.ShardRegionStats> Regions;
public ClusterShardingStats(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.Address, Akka.Cluster.Sharding.ShardRegionStats> regions) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.ClusterShardingStats other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class CurrentRegions : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.CurrentRegions>
{
public readonly System.Collections.Immutable.IImmutableSet<Akka.Actor.Address> Regions;
public CurrentRegions(System.Collections.Immutable.IImmutableSet<Akka.Actor.Address> regions) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.CurrentRegions other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class CurrentShardRegionState : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.CurrentShardRegionState>
{
public readonly System.Collections.Immutable.IImmutableSet<string> Failed;
public readonly System.Collections.Immutable.IImmutableSet<Akka.Cluster.Sharding.ShardState> Shards;
[System.ObsoleteAttribute("Use constructor with `failed` argument. Obsolete since 1.5.0-alpha1")]
public CurrentShardRegionState(System.Collections.Immutable.IImmutableSet<Akka.Cluster.Sharding.ShardState> shards) { }
public CurrentShardRegionState(System.Collections.Immutable.IImmutableSet<Akka.Cluster.Sharding.ShardState> shards, System.Collections.Immutable.IImmutableSet<string> failed) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.CurrentShardRegionState other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class EntityLocation
{
public EntityLocation(string entityId, string shardId, Akka.Actor.Address shardRegion, Akka.Util.Option<Akka.Actor.IActorRef> entityRef) { }
public string EntityId { get; }
public Akka.Util.Option<Akka.Actor.IActorRef> EntityRef { get; }
public string ShardId { get; }
public Akka.Actor.Address ShardRegion { get; }
}
public class static EnumerableExtensions
{
public static System.Collections.Generic.IEnumerable<System.Collections.Generic.IEnumerable<T>> Grouped<T>(this System.Collections.Generic.IEnumerable<T> items, int size) { }
}
[System.ObsoleteAttribute("Use HashCodeMessageExtractor or IMessageExtractor instead.")]
[return: System.Runtime.CompilerServices.NullableAttribute(new byte[] {
0,
0,
1,
1})]
public delegate Akka.Util.Option<System.ValueTuple<string, object>> ExtractEntityId(object message);
[System.ObsoleteAttribute("Use HashCodeMessageExtractor or IMessageExtractor instead.")]
public delegate string ExtractShardId(object message);
public sealed class GetClusterShardingStats : Akka.Cluster.Sharding.IClusterShardingSerializable, Akka.Cluster.Sharding.IShardRegionQuery, System.IEquatable<Akka.Cluster.Sharding.GetClusterShardingStats>
{
public readonly System.TimeSpan Timeout;
public GetClusterShardingStats(System.TimeSpan timeout) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.GetClusterShardingStats other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class GetCurrentRegions : Akka.Cluster.Sharding.IClusterShardingSerializable, Akka.Cluster.Sharding.IShardRegionQuery
{
public static readonly Akka.Cluster.Sharding.GetCurrentRegions Instance;
public override string ToString() { }
}
public sealed class GetEntityLocation : Akka.Cluster.Sharding.IShardRegionQuery
{
public GetEntityLocation(string entityId, System.TimeSpan timeout) { }
public string EntityId { get; }
public System.TimeSpan Timeout { get; }
}
public sealed class GetShardRegionState : Akka.Cluster.Sharding.IClusterShardingSerializable, Akka.Cluster.Sharding.IShardRegionQuery
{
public static readonly Akka.Cluster.Sharding.GetShardRegionState Instance;
public override string ToString() { }
}
public sealed class GetShardRegionStats : Akka.Cluster.Sharding.IClusterShardingSerializable, Akka.Cluster.Sharding.IShardRegionQuery
{
public static readonly Akka.Cluster.Sharding.GetShardRegionStats Instance;
public override string ToString() { }
}
public sealed class GracefulShutdown : Akka.Cluster.Sharding.IShardRegionCommand
{
public static readonly Akka.Cluster.Sharding.GracefulShutdown Instance;
}
[System.Runtime.CompilerServices.NullableAttribute(0)]
public abstract class HashCodeMessageExtractor : Akka.Cluster.Sharding.IMessageExtractor
{
public readonly int MaxNumberOfShards;
protected HashCodeMessageExtractor(int maxNumberOfShards) { }
public static Akka.Cluster.Sharding.HashCodeMessageExtractor Create(int maxNumberOfShards, [System.Runtime.CompilerServices.NullableAttribute(new byte[] {
1,
1,
2})] System.Func<object, string> entityIdExtractor, [System.Runtime.CompilerServices.NullableAttribute(new byte[] {
2,
1,
1})] System.Func<object, object> messageExtractor = null) { }
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public abstract string EntityId(object message);
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public virtual object EntityMessage(object message) { }
[System.ObsoleteAttribute("Use ShardId(string, object?) instead. Since v1.5.15")]
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public virtual string ShardId(object message) { }
public virtual string ShardId(string entityId, [System.Runtime.CompilerServices.NullableAttribute(2)] object messageHint = null) { }
}
public interface IActorSystemDependentAllocationStrategy : Akka.Actor.INoSerializationVerificationNeeded, Akka.Cluster.Sharding.IShardAllocationStrategy
{
void Start(Akka.Actor.ActorSystem system);
}
public interface IClusterShardingSerializable { }
public interface IMessageExtractor
{
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
string EntityId(object message);
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
object EntityMessage(object message);
[System.ObsoleteAttribute("Use ShardId(EntityId, object) instead.")]
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
string ShardId(object message);
string ShardId(string entityId, [System.Runtime.CompilerServices.NullableAttribute(2)] object messageHint = null);
}
public interface IShardAllocationStrategy : Akka.Actor.INoSerializationVerificationNeeded
{
System.Threading.Tasks.Task<Akka.Actor.IActorRef> AllocateShard(Akka.Actor.IActorRef requester, string shardId, System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations);
System.Threading.Tasks.Task<System.Collections.Immutable.IImmutableSet<string>> Rebalance(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations, System.Collections.Immutable.IImmutableSet<string> rebalanceInProgress);
}
public interface IShardRegionCommand { }
public interface IShardRegionQuery { }
[Akka.Annotations.InternalApiAttribute()]
public interface IShardingBufferedMessageAdapter
{
object Adapt(object message);
}
public interface IStartableAllocationStrategy : Akka.Actor.INoSerializationVerificationNeeded, Akka.Cluster.Sharding.IShardAllocationStrategy
{
void Start();
}
[System.ObsoleteAttribute("Use ShardAllocationStrategy.LeastShardAllocationStrategy instead. This will be re" +
"moved in v1.6.")]
public class LeastShardAllocationStrategy : Akka.Cluster.Sharding.Internal.AbstractLeastShardAllocationStrategy
{
public LeastShardAllocationStrategy(int rebalanceThreshold, int maxSimultaneousRebalance) { }
public override System.Threading.Tasks.Task<System.Collections.Immutable.IImmutableSet<string>> Rebalance(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations, System.Collections.Immutable.IImmutableSet<string> rebalanceInProgress) { }
}
public sealed class Passivate : Akka.Cluster.Sharding.IShardRegionCommand
{
public Passivate(object stopMessage) { }
public object StopMessage { get; }
}
public enum RememberEntitiesStore
{
DData = 0,
Eventsourced = 1,
Custom = 2,
}
public class static ShardAllocationStrategy
{
public static Akka.Cluster.Sharding.IShardAllocationStrategy LeastShardAllocationStrategy(int absoluteLimit, double relativeLimit) { }
}
[Akka.Annotations.InternalStableApiAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class ShardRegion : Akka.Actor.ActorBase, Akka.Actor.IWithTimers
{
public ShardRegion(string typeName, [System.Runtime.CompilerServices.NullableAttribute(new byte[] {
2,
1,
1})] System.Func<string, Akka.Actor.Props> entityProps, Akka.Cluster.Sharding.ClusterShardingSettings settings, string coordinatorPath, Akka.Cluster.Sharding.IMessageExtractor messageExtractor, object handOffStopMessage, [System.Runtime.CompilerServices.NullableAttribute(2)] Akka.Cluster.Sharding.Internal.IRememberEntitiesProvider rememberEntitiesProvider) { }
public Akka.Actor.ITimerScheduler Timers { get; set; }
protected override void PostStop() { }
protected override void PreStart() { }
protected override bool Receive(object message) { }
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class StartEntity : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.ShardRegion.StartEntity>
{
public readonly string EntityId;
public StartEntity(string entityId) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.ShardRegion.StartEntity other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
}
public sealed class ShardRegionStats : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.ShardRegionStats>
{
public readonly System.Collections.Immutable.IImmutableSet<string> Failed;
public readonly System.Collections.Immutable.IImmutableDictionary<string, int> Stats;
[System.ObsoleteAttribute("Use constructor with `failed` argument. Obsolete since 1.5.0-alpha1")]
public ShardRegionStats(System.Collections.Immutable.IImmutableDictionary<string, int> stats) { }
public ShardRegionStats(System.Collections.Immutable.IImmutableDictionary<string, int> stats, System.Collections.Immutable.IImmutableSet<string> failed) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.ShardRegionStats other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class ShardState : Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.ShardState>
{
public readonly System.Collections.Immutable.IImmutableSet<string> EntityIds;
public readonly string ShardId;
public ShardState(string shardId, System.Collections.Immutable.IImmutableSet<string> entityIds) { }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.ShardState other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
[Akka.Annotations.ApiMayChangeAttribute()]
[Akka.Annotations.DoNotInheritAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public class ShardedDaemonProcess : Akka.Actor.IExtension
{
public ShardedDaemonProcess(Akka.Actor.ExtendedActorSystem system) { }
public static Akka.Cluster.Sharding.ShardedDaemonProcess Get(Akka.Actor.ActorSystem system) { }
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public Akka.Actor.IActorRef Init(string name, int numberOfInstances, System.Func<int, Akka.Actor.Props> propsFactory) { }
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public Akka.Actor.IActorRef Init(string name, int numberOfInstances, System.Func<int, Akka.Actor.Props> propsFactory, [System.Runtime.CompilerServices.NullableAttribute(2)] object stopMessage) { }
[return: System.Runtime.CompilerServices.NullableAttribute(2)]
public Akka.Actor.IActorRef Init(string name, int numberOfInstances, System.Func<int, Akka.Actor.Props> propsFactory, Akka.Cluster.Sharding.ShardedDaemonProcessSettings settings, [System.Runtime.CompilerServices.NullableAttribute(2)] object stopMessage) { }
public Akka.Actor.IActorRef InitProxy(string name, int numberOfInstances, string role) { }
}
[System.Runtime.CompilerServices.NullableAttribute(new byte[] {
0,
1})]
public class ShardedDaemonProcessExtensionProvider : Akka.Actor.ExtensionIdProvider<Akka.Cluster.Sharding.ShardedDaemonProcess>
{
public ShardedDaemonProcessExtensionProvider() { }
public override Akka.Cluster.Sharding.ShardedDaemonProcess CreateExtension(Akka.Actor.ExtendedActorSystem system) { }
}
[Akka.Annotations.ApiMayChangeAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class ShardedDaemonProcessSettings
{
public readonly System.TimeSpan KeepAliveInterval;
[System.Runtime.CompilerServices.NullableAttribute(2)]
public readonly string Role;
[System.Runtime.CompilerServices.NullableAttribute(2)]
public readonly Akka.Cluster.Sharding.ClusterShardingSettings ShardingSettings;
public static Akka.Cluster.Sharding.ShardedDaemonProcessSettings Create(Akka.Actor.ActorSystem system) { }
public static Akka.Cluster.Sharding.ShardedDaemonProcessSettings FromConfig(Akka.Configuration.Config config) { }
public Akka.Cluster.Sharding.ShardedDaemonProcessSettings WithKeepAliveInterval(System.TimeSpan keepAliveInterval) { }
public Akka.Cluster.Sharding.ShardedDaemonProcessSettings WithRole(string role) { }
public Akka.Cluster.Sharding.ShardedDaemonProcessSettings WithShardingSettings(Akka.Cluster.Sharding.ClusterShardingSettings shardingSettings) { }
}
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class ShardingEnvelope : Akka.Actor.IWrappedMessage, Akka.Cluster.Sharding.IClusterShardingSerializable, System.IEquatable<Akka.Cluster.Sharding.ShardingEnvelope>
{
public ShardingEnvelope(string entityId, object message) { }
public string EntityId { get; }
public object Message { get; }
public bool Equals(Akka.Cluster.Sharding.ShardingEnvelope other) { }
public override bool Equals(object obj) { }
public override int GetHashCode() { }
public override string ToString() { }
}
[Akka.Annotations.InternalApiAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public class ShardingSetup : Akka.Actor.Setup.Setup
{
public Akka.Cluster.Sharding.IShardingBufferedMessageAdapter BufferedMessageAdapter { get; }
public static Akka.Cluster.Sharding.ShardingSetup Create(Akka.Cluster.Sharding.IShardingBufferedMessageAdapter bufferedMessageAdapter) { }
}
public enum StateStoreMode
{
Persistence = 0,
DData = 1,
Custom = 2,
}
public class TuningParameters
{
public readonly int BufferSize;
public readonly System.TimeSpan CoordinatorFailureBackoff;
public readonly int CoordinatorStateReadMajorityPlus;
public readonly int CoordinatorStateWriteMajorityPlus;
public readonly System.TimeSpan EntityRecoveryConstantRateStrategyFrequency;
public readonly int EntityRecoveryConstantRateStrategyNumberOfEntities;
public readonly string EntityRecoveryStrategy;
public readonly System.TimeSpan EntityRestartBackoff;
public readonly System.TimeSpan HandOffTimeout;
public readonly int KeepNrOfBatches;
public readonly int LeastShardAllocationAbsoluteLimit;
public readonly int LeastShardAllocationMaxSimultaneousRebalance;
public readonly int LeastShardAllocationRebalanceThreshold;
public readonly double LeastShardAllocationRelativeLimit;
public readonly System.TimeSpan RebalanceInterval;
public readonly System.TimeSpan RetryInterval;
public readonly System.TimeSpan ShardFailureBackoff;
public readonly System.TimeSpan ShardStartTimeout;
public readonly int SnapshotAfter;
public readonly System.TimeSpan UpdatingStateTimeout;
public readonly System.TimeSpan WaitingForStateTimeout;
public TuningParameters(
System.TimeSpan coordinatorFailureBackoff,
System.TimeSpan retryInterval,
int bufferSize,
System.TimeSpan handOffTimeout,
System.TimeSpan shardStartTimeout,
System.TimeSpan shardFailureBackoff,
System.TimeSpan entityRestartBackoff,
System.TimeSpan rebalanceInterval,
int snapshotAfter,
int keepNrOfBatches,
int leastShardAllocationRebalanceThreshold,
int leastShardAllocationMaxSimultaneousRebalance,
System.TimeSpan waitingForStateTimeout,
System.TimeSpan updatingStateTimeout,
string entityRecoveryStrategy,
System.TimeSpan entityRecoveryConstantRateStrategyFrequency,
int entityRecoveryConstantRateStrategyNumberOfEntities,
int coordinatorStateWriteMajorityPlus,
int coordinatorStateReadMajorityPlus,
int leastShardAllocationAbsoluteLimit,
double leastShardAllocationRelativeLimit) { }
public Akka.Cluster.Sharding.TuningParameters WithBufferSize(int bufferSize) { }
public Akka.Cluster.Sharding.TuningParameters WithCoordinatorFailureBackoff(System.TimeSpan coordinatorFailureBackoff) { }
public Akka.Cluster.Sharding.TuningParameters WithCoordinatorStateReadMajorityPlus(int coordinatorStateReadMajorityPlus) { }
public Akka.Cluster.Sharding.TuningParameters WithCoordinatorStateWriteMajorityPlus(int coordinatorStateWriteMajorityPlus) { }
public Akka.Cluster.Sharding.TuningParameters WithEntityRecoveryConstantRateStrategyFrequency(System.TimeSpan entityRecoveryConstantRateStrategyFrequency) { }
public Akka.Cluster.Sharding.TuningParameters WithEntityRecoveryConstantRateStrategyNumberOfEntities(int entityRecoveryConstantRateStrategyNumberOfEntities) { }
public Akka.Cluster.Sharding.TuningParameters WithEntityRecoveryStrategy(string entityRecoveryStrategy) { }
public Akka.Cluster.Sharding.TuningParameters WithEntityRestartBackoff(System.TimeSpan entityRestartBackoff) { }
public Akka.Cluster.Sharding.TuningParameters WithHandOffTimeout(System.TimeSpan handOffTimeout) { }
public Akka.Cluster.Sharding.TuningParameters WithKeepNrOfBatches(int keepNrOfBatches) { }
public Akka.Cluster.Sharding.TuningParameters WithLeastShardAllocationAbsoluteLimit(int leastShardAllocationAbsoluteLimit) { }
public Akka.Cluster.Sharding.TuningParameters WithLeastShardAllocationMaxSimultaneousRebalance(int leastShardAllocationMaxSimultaneousRebalance) { }
public Akka.Cluster.Sharding.TuningParameters WithLeastShardAllocationRebalanceThreshold(int leastShardAllocationRebalanceThreshold) { }
public Akka.Cluster.Sharding.TuningParameters WithLeastShardAllocationRelativeLimit(double leastShardAllocationRelativeLimit) { }
public Akka.Cluster.Sharding.TuningParameters WithRebalanceInterval(System.TimeSpan rebalanceInterval) { }
public Akka.Cluster.Sharding.TuningParameters WithRetryInterval(System.TimeSpan retryInterval) { }
public Akka.Cluster.Sharding.TuningParameters WithShardFailureBackoff(System.TimeSpan shardFailureBackoff) { }
public Akka.Cluster.Sharding.TuningParameters WithShardStartTimeout(System.TimeSpan shardStartTimeout) { }
public Akka.Cluster.Sharding.TuningParameters WithSnapshotAfter(int snapshotAfter) { }
public Akka.Cluster.Sharding.TuningParameters WithUpdatingStateTimeout(System.TimeSpan updatingStateTimeout) { }
public Akka.Cluster.Sharding.TuningParameters WithWaitingForStateTimeout(System.TimeSpan waitingForStateTimeout) { }
}
}
namespace Akka.Cluster.Sharding.Delivery
{
[Akka.Annotations.ApiMayChangeAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public class static ShardingConsumerController
{
public static Akka.Actor.Props Create<[System.Runtime.CompilerServices.NullableAttribute(2)] T>(System.Func<Akka.Actor.IActorRef, Akka.Actor.Props> consumerProps, Akka.Cluster.Sharding.Delivery.ShardingConsumerController.Settings settings) { }
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class Settings : System.IEquatable<Akka.Cluster.Sharding.Delivery.ShardingConsumerController.Settings>
{
public bool AllowBypass { get; set; }
public int BufferSize { get; set; }
public Akka.Delivery.ConsumerController.Settings ConsumerControllerSettings { get; set; }
public static Akka.Cluster.Sharding.Delivery.ShardingConsumerController.Settings Create(Akka.Actor.ActorSystem system) { }
public override string ToString() { }
}
}
[Akka.Annotations.ApiMayChangeAttribute()]
[System.Runtime.CompilerServices.NullableAttribute(0)]
public class static ShardingProducerController
{
public static Akka.Actor.Props Create<[System.Runtime.CompilerServices.NullableAttribute(2)] T>(string producerId, Akka.Actor.IActorRef shardRegion, [System.Runtime.CompilerServices.NullableAttribute(new byte[] {
0,
1})] Akka.Util.Option<Akka.Actor.Props> durableQueue, Akka.Cluster.Sharding.Delivery.ShardingProducerController.Settings settings) { }
public interface IShardingProducerControllerCommand<T> { }
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class MessageWithConfirmation<[System.Runtime.CompilerServices.NullableAttribute(2)] T> : Akka.Cluster.Sharding.Delivery.ShardingProducerController.IShardingProducerControllerCommand<T>, System.IEquatable<Akka.Cluster.Sharding.Delivery.ShardingProducerController.MessageWithConfirmation<T>>
{
public MessageWithConfirmation(string EntityId, T Message, Akka.Actor.IActorRef ReplyTo) { }
public string EntityId { get; set; }
public T Message { get; set; }
public Akka.Actor.IActorRef ReplyTo { get; set; }
}
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class RequestNext<[System.Runtime.CompilerServices.NullableAttribute(2)] T> : System.IEquatable<Akka.Cluster.Sharding.Delivery.ShardingProducerController.RequestNext<T>>
{
public RequestNext(Akka.Actor.IActorRef SendNextTo, Akka.Actor.IActorRef AskNextToRef, System.Collections.Immutable.ImmutableHashSet<string> EntitiesWithDemand, System.Collections.Immutable.ImmutableDictionary<string, int> BufferedForEntitiesWithoutDemand) { }
public Akka.Actor.IActorRef AskNextToRef { get; set; }
public System.Collections.Immutable.ImmutableDictionary<string, int> BufferedForEntitiesWithoutDemand { get; set; }
public System.Collections.Immutable.ImmutableHashSet<string> EntitiesWithDemand { get; set; }
public Akka.Actor.IActorRef SendNextTo { get; set; }
public System.Threading.Tasks.Task<long> AskNextTo(string entityId, T msg, System.Threading.CancellationToken cancellationToken = null) { }
public void AskNextTo(Akka.Cluster.Sharding.Delivery.ShardingProducerController.MessageWithConfirmation<T> msgWithConfirmation) { }
}
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class Settings : System.IEquatable<Akka.Cluster.Sharding.Delivery.ShardingProducerController.Settings>
{
public int BufferSize { get; set; }
public System.TimeSpan CleanupUnusedAfter { get; set; }
public System.TimeSpan InternalAskTimeout { get; set; }
public Akka.Delivery.ProducerController.Settings ProducerControllerSettings { get; set; }
public System.TimeSpan ResendFirstUnconfirmedIdleTimeout { get; set; }
public static Akka.Cluster.Sharding.Delivery.ShardingProducerController.Settings Create(Akka.Actor.ActorSystem system) { }
public static Akka.Cluster.Sharding.Delivery.ShardingProducerController.Settings Create(Akka.Configuration.Config config, Akka.Configuration.Config producerControllerConfig) { }
}
[System.Runtime.CompilerServices.NullableAttribute(0)]
public sealed class Start<[System.Runtime.CompilerServices.NullableAttribute(2)] T> : Akka.Cluster.Sharding.Delivery.ShardingProducerController.IShardingProducerControllerCommand<T>
{
public Start(Akka.Actor.IActorRef producer) { }
public Akka.Actor.IActorRef Producer { get; }
}
}
}
namespace Akka.Cluster.Sharding.External
{
public class ClientTimeoutException : System.Exception
{
public ClientTimeoutException(string message) { }
public ClientTimeoutException(string message, System.Exception innerEx) { }
protected ClientTimeoutException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) { }
}
public sealed class ExternalShardAllocation : Akka.Actor.IExtension
{
public ExternalShardAllocation(Akka.Actor.ExtendedActorSystem system) { }
public Akka.Cluster.Sharding.External.IExternalShardAllocationClient ClientFor(string typeName) { }
public static Akka.Cluster.Sharding.External.ExternalShardAllocation Get(Akka.Actor.ActorSystem system) { }
}
public class ExternalShardAllocationExtensionProvider : Akka.Actor.ExtensionIdProvider<Akka.Cluster.Sharding.External.ExternalShardAllocation>
{
public ExternalShardAllocationExtensionProvider() { }
public override Akka.Cluster.Sharding.External.ExternalShardAllocation CreateExtension(Akka.Actor.ExtendedActorSystem system) { }
}
public class ExternalShardAllocationStrategy : Akka.Actor.INoSerializationVerificationNeeded, Akka.Cluster.Sharding.IShardAllocationStrategy, Akka.Cluster.Sharding.IStartableAllocationStrategy
{
public ExternalShardAllocationStrategy(Akka.Actor.ActorSystem system, string typeName) { }
protected virtual System.TimeSpan Timeout { get; }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> AllocateShard(Akka.Actor.IActorRef requester, string shardId, System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations) { }
protected virtual Akka.Actor.IActorRef CreateShardStateActor() { }
public System.Threading.Tasks.Task<System.Collections.Immutable.IImmutableSet<string>> Rebalance(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations, System.Collections.Immutable.IImmutableSet<string> rebalanceInProgress) { }
public void Start() { }
public sealed class GetShardLocation : Akka.Actor.INoSerializationVerificationNeeded, System.IEquatable<Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocation>
{
public GetShardLocation(string shard) { }
public string Shard { get; }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocation other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class GetShardLocationResponse : Akka.Actor.INoSerializationVerificationNeeded, System.IEquatable<Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocationResponse>
{
public GetShardLocationResponse(Akka.Actor.Address address) { }
public Akka.Actor.Address Address { get; }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocationResponse other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class GetShardLocations : Akka.Actor.INoSerializationVerificationNeeded
{
public static readonly Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocations Instance;
public override string ToString() { }
}
public sealed class GetShardLocationsResponse : Akka.Actor.INoSerializationVerificationNeeded, System.IEquatable<Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocationsResponse>
{
public GetShardLocationsResponse(System.Collections.Immutable.IImmutableDictionary<string, Akka.Actor.Address> desiredAllocations) { }
public System.Collections.Immutable.IImmutableDictionary<string, Akka.Actor.Address> DesiredAllocations { get; }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.GetShardLocationsResponse other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
public sealed class ShardLocation : Akka.Actor.INoSerializationVerificationNeeded, System.IEquatable<Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.ShardLocation>
{
public ShardLocation(Akka.Actor.Address address) { }
public Akka.Actor.Address Address { get; }
public override bool Equals(object obj) { }
public bool Equals(Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.ShardLocation other) { }
public override int GetHashCode() { }
public override string ToString() { }
}
}
public interface IExternalShardAllocationClient
{
System.Threading.Tasks.Task<Akka.Cluster.Sharding.External.ShardLocations> ShardLocations();
System.Threading.Tasks.Task<Akka.Done> UpdateShardLocation(string shard, Akka.Actor.Address location);
System.Threading.Tasks.Task<Akka.Done> UpdateShardLocations(System.Collections.Immutable.IImmutableDictionary<string, Akka.Actor.Address> locations);
}
public sealed class ShardLocations
{
public ShardLocations(System.Collections.Immutable.IImmutableDictionary<string, Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.ShardLocation> locations) { }
public System.Collections.Immutable.IImmutableDictionary<string, Akka.Cluster.Sharding.External.ExternalShardAllocationStrategy.ShardLocation> Locations { get; }
}
}
namespace Akka.Cluster.Sharding.Internal
{
public abstract class AbstractLeastShardAllocationStrategy : Akka.Actor.INoSerializationVerificationNeeded, Akka.Cluster.Sharding.IActorSystemDependentAllocationStrategy, Akka.Cluster.Sharding.IShardAllocationStrategy
{
protected AbstractLeastShardAllocationStrategy() { }
protected virtual Akka.Cluster.ClusterEvent.CurrentClusterState ClusterState { get; }
protected virtual Akka.Cluster.Member SelfMember { get; }
public System.Threading.Tasks.Task<Akka.Actor.IActorRef> AllocateShard(Akka.Actor.IActorRef requester, string shardId, System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations) { }
protected bool IsAGoodTimeToRebalance(System.Collections.Generic.IEnumerable<Akka.Cluster.Sharding.Internal.AbstractLeastShardAllocationStrategy.RegionEntry> regionEntries) { }
[return: System.Runtime.CompilerServices.TupleElementNamesAttribute(new string[] {
"Region",
"Shards"})]
protected System.ValueTuple<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> MostSuitableRegion(System.Collections.Generic.IEnumerable<Akka.Cluster.Sharding.Internal.AbstractLeastShardAllocationStrategy.RegionEntry> regionEntries) { }
public abstract System.Threading.Tasks.Task<System.Collections.Immutable.IImmutableSet<string>> Rebalance(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations, System.Collections.Immutable.IImmutableSet<string> rebalanceInProgress);
protected System.Collections.Immutable.ImmutableList<Akka.Cluster.Sharding.Internal.AbstractLeastShardAllocationStrategy.RegionEntry> RegionEntriesFor(System.Collections.Immutable.IImmutableDictionary<Akka.Actor.IActorRef, System.Collections.Immutable.IImmutableList<string>> currentShardAllocations) { }
public void Start(Akka.Actor.ActorSystem system) { }
public sealed class RegionEntry
{
public RegionEntry(Akka.Actor.IActorRef region, Akka.Cluster.Member member, System.Collections.Immutable.IImmutableList<string> shardIds) { }
public Akka.Cluster.Member Member { get; }
public Akka.Actor.IActorRef Region { get; }
public System.Collections.Immutable.IImmutableList<string> ShardIds { get; }
}
}
public interface IRememberEntitiesProvider
{
Akka.Actor.Props CoordinatorStoreProps();
Akka.Actor.Props ShardStoreProps(string shardId);
}
}
namespace Akka.Cluster.Sharding.Serialization
{
public class ClusterShardingMessageSerializer : Akka.Serialization.SerializerWithStringManifest
{
public ClusterShardingMessageSerializer(Akka.Actor.ExtendedActorSystem system) { }
public override object FromBinary(byte[] bytes, string manifest) { }
public override string Manifest(object o) { }
public override byte[] ToBinary(object obj) { }
}
}