Skip to content

Commit b4f3010

Browse files
stidsborgstidsborg
committed
Added owner to StoredFlow
1 parent 2a497f9 commit b4f3010

30 files changed

Lines changed: 352 additions & 205 deletions

File tree

‎Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/LeaseUpdaterTests/LeaseUpdaterTestFunctionStore.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,10 @@ public Task<bool> CreateFunction(
3636
long? postponeUntil,
3737
long timestamp,
3838
StoredId? parent,
39+
ReplicaId? owner,
3940
IReadOnlyList<StoredEffect>? effects = null,
4041
IReadOnlyList<StoredMessage>? messages = null
41-
) => _inner.CreateFunction(storedId, humanInstanceId, param, leaseExpiration, postponeUntil, timestamp, parent);
42+
) => _inner.CreateFunction(storedId, humanInstanceId, param, leaseExpiration, postponeUntil, timestamp, parent, owner);
4243

4344
public Task BulkScheduleFunctions(IEnumerable<IdWithParam> functionsWithParam, StoredId? parent)
4445
=> _inner.BulkScheduleFunctions(functionsWithParam, parent);

‎Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/RFunctionTests/DelayedStartUpTests.cs‎

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,8 @@ await store.CreateFunction(
3737
leaseExpiration: DateTime.UtcNow.Ticks,
3838
postponeUntil: null,
3939
timestamp: DateTime.UtcNow.Ticks,
40-
parent: null
40+
parent: null,
41+
owner: null
4142
);
4243

4344
await BusyWait.Until(() => store.GetFunction(registration.MapToStoredId(functionId.Instance)).Map(sf => sf?.Status == Status.Succeeded));
@@ -60,7 +61,8 @@ await store.CreateFunction(
6061
leaseExpiration: DateTime.UtcNow.Ticks,
6162
postponeUntil: null,
6263
timestamp: DateTime.UtcNow.Ticks,
63-
parent: null
64+
parent: null,
65+
owner: null
6466
);
6567

6668
var stopWatch = new Stopwatch();
@@ -102,7 +104,8 @@ await store.CreateFunction(
102104
leaseExpiration: DateTime.UtcNow.Ticks,
103105
postponeUntil: null,
104106
timestamp: DateTime.UtcNow.Ticks,
105-
parent: null
107+
parent: null,
108+
owner: null
106109
);
107110
await store.PostponeFunction(
108111
registration.MapToStoredId(functionId.Instance),
@@ -142,7 +145,8 @@ await store.CreateFunction(
142145
leaseExpiration: DateTime.UtcNow.Ticks,
143146
postponeUntil: null,
144147
timestamp: DateTime.UtcNow.Ticks,
145-
parent: null
148+
parent: null,
149+
owner: null
146150
);
147151
await store.PostponeFunction(
148152
registration.MapToStoredId(functionId.Instance),

‎Core/Cleipnir.ResilientFunctions.Tests/InMemoryTests/ShutdownCoordinationTests/RFunctionsShutdownTests.cs‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,8 @@ await store.CreateFunction(
122122
leaseExpiration: DateTime.UtcNow.Ticks,
123123
postponeUntil: null,
124124
timestamp: DateTime.UtcNow.Ticks,
125-
parent: null
125+
parent: null,
126+
owner: null
126127
).ShouldBeTrueAsync();
127128

128129
await insideRFuncFlag.WaitForRaised();
@@ -174,7 +175,8 @@ await store.CreateFunction(
174175
leaseExpiration: DateTime.UtcNow.Ticks,
175176
postponeUntil: null,
176177
timestamp: DateTime.UtcNow.Ticks,
177-
parent: null
178+
parent: null,
179+
owner: null
178180
).ShouldBeTrueAsync();
179181

180182
await store.PostponeFunction(

‎Core/Cleipnir.ResilientFunctions.Tests/Messaging/TestTemplates/CustomMessageSerializerTests.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,8 @@ await functionStore.CreateFunction(
2727
leaseExpiration: DateTime.UtcNow.Ticks,
2828
postponeUntil: null,
2929
timestamp: DateTime.UtcNow.Ticks,
30-
parent: null
30+
parent: null,
31+
owner: null
3132
);
3233
var eventSerializer = new EventSerializer();
3334
var messagesWriter = new MessageWriter(storedId, functionStore, eventSerializer, scheduleReInvocation: (_, _) => Task.CompletedTask);

‎Core/Cleipnir.ResilientFunctions.Tests/Messaging/TestTemplates/MessageStoreTests.cs‎

Lines changed: 44 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@ await functionStore.CreateFunction(
2626
leaseExpiration: DateTime.UtcNow.Ticks,
2727
postponeUntil: null,
2828
timestamp: DateTime.UtcNow.Ticks,
29-
parent: null
29+
parent: null,
30+
owner: null
3031
);
3132
var messageStore = functionStore.MessageStore;
3233

@@ -63,7 +64,8 @@ await functionStore.CreateFunction(
6364
leaseExpiration: DateTime.UtcNow.Ticks,
6465
postponeUntil: null,
6566
timestamp: DateTime.UtcNow.Ticks,
66-
parent: null
67+
parent: null,
68+
owner: null
6769
);
6870
var messageStore = functionStore.MessageStore;
6971

@@ -106,7 +108,8 @@ await functionStore.CreateFunction(
106108
leaseExpiration: DateTime.UtcNow.Ticks,
107109
postponeUntil: null,
108110
timestamp: DateTime.UtcNow.Ticks,
109-
parent: null
111+
parent: null,
112+
owner: null
110113
);
111114
var messageStore = functionStore.MessageStore;
112115

@@ -150,7 +153,8 @@ await functionStore.CreateFunction(
150153
leaseExpiration: DateTime.UtcNow.Ticks,
151154
postponeUntil: null,
152155
timestamp: DateTime.UtcNow.Ticks,
153-
parent: null
156+
parent: null,
157+
owner: null
154158
);
155159
var messageStore = functionStore.MessageStore;
156160

@@ -194,7 +198,8 @@ await functionStore.CreateFunction(
194198
leaseExpiration: DateTime.UtcNow.Ticks,
195199
postponeUntil: null,
196200
timestamp: DateTime.UtcNow.Ticks,
197-
parent: null
201+
parent: null,
202+
owner: null
198203
);
199204
var messageStore = functionStore.MessageStore;
200205

@@ -235,7 +240,8 @@ await functionStore.CreateFunction(
235240
leaseExpiration: DateTime.UtcNow.Ticks,
236241
postponeUntil: null,
237242
timestamp: DateTime.UtcNow.Ticks,
238-
parent: null
243+
parent: null,
244+
owner: null
239245
);
240246
var messageStore = functionStore.MessageStore;
241247

@@ -263,7 +269,8 @@ await functionStore.CreateFunction(
263269
leaseExpiration: DateTime.UtcNow.Ticks,
264270
postponeUntil: null,
265271
timestamp: DateTime.UtcNow.Ticks,
266-
parent: null
272+
parent: null,
273+
owner: null
267274
);
268275
var messageStore = functionStore.MessageStore;
269276

@@ -292,7 +299,8 @@ await functionStore.CreateFunction(
292299
leaseExpiration: DateTime.UtcNow.Ticks,
293300
postponeUntil: null,
294301
timestamp: DateTime.UtcNow.Ticks,
295-
parent: null
302+
parent: null,
303+
owner: null
296304
);
297305
var messageStore = functionStore.MessageStore;
298306

@@ -313,7 +321,8 @@ await functionStore.CreateFunction(
313321
leaseExpiration: DateTime.UtcNow.Ticks,
314322
postponeUntil: null,
315323
timestamp: DateTime.UtcNow.Ticks,
316-
parent: null
324+
parent: null,
325+
owner: null
317326
);
318327
var messageStore = functionStore.MessageStore;
319328

@@ -352,7 +361,8 @@ await functionStore.CreateFunction(
352361
leaseExpiration: DateTime.UtcNow.Ticks,
353362
postponeUntil: null,
354363
timestamp: DateTime.UtcNow.Ticks,
355-
parent: null
364+
parent: null,
365+
owner: null
356366
);
357367
var messageStore = functionStore.MessageStore;
358368

@@ -392,7 +402,8 @@ await functionStore.CreateFunction(
392402
leaseExpiration: DateTime.UtcNow.Ticks,
393403
postponeUntil: null,
394404
timestamp: DateTime.UtcNow.Ticks,
395-
parent: null
405+
parent: null,
406+
owner: null
396407
);
397408
var messageStore = functionStore.MessageStore;
398409

@@ -430,7 +441,8 @@ await functionStore.CreateFunction(
430441
leaseExpiration: DateTime.UtcNow.Ticks,
431442
postponeUntil: null,
432443
timestamp: DateTime.UtcNow.Ticks,
433-
parent: null
444+
parent: null,
445+
owner: null
434446
);
435447
var messageStore = functionStore.MessageStore;
436448

@@ -457,7 +469,8 @@ await functionStore.CreateFunction(
457469
leaseExpiration: DateTime.UtcNow.Ticks,
458470
postponeUntil: null,
459471
timestamp: DateTime.UtcNow.Ticks,
460-
parent: null
472+
parent: null,
473+
owner: null
461474
);
462475
var messageStore = functionStore.MessageStore;
463476
var events = await messageStore.GetMessages(functionId, skip: 0);
@@ -476,7 +489,8 @@ await functionStore.CreateFunction(
476489
leaseExpiration: DateTime.UtcNow.Ticks,
477490
postponeUntil: null,
478491
timestamp: DateTime.UtcNow.Ticks,
479-
parent: null
492+
parent: null,
493+
owner: null
480494
);
481495
var messageStore = functionStore.MessageStore;
482496

@@ -526,7 +540,8 @@ await functionStore.CreateFunction(
526540
leaseExpiration: DateTime.UtcNow.Ticks,
527541
postponeUntil: null,
528542
timestamp: DateTime.UtcNow.Ticks,
529-
parent: null
543+
parent: null,
544+
owner: null
530545
);
531546
var messageStore = functionStore.MessageStore;
532547

@@ -577,7 +592,8 @@ await functionStore.CreateFunction(
577592
leaseExpiration: DateTime.UtcNow.Ticks,
578593
postponeUntil: null,
579594
timestamp: DateTime.UtcNow.Ticks,
580-
parent: null
595+
parent: null,
596+
owner: null
581597
).ShouldBeTrueAsync();
582598
await functionStore.CreateFunction(
583599
id2,
@@ -586,7 +602,8 @@ await functionStore.CreateFunction(
586602
leaseExpiration: DateTime.UtcNow.Ticks,
587603
postponeUntil: null,
588604
timestamp: DateTime.UtcNow.Ticks,
589-
parent: null
605+
parent: null,
606+
owner: null
590607
).ShouldBeTrueAsync();
591608
var messageStore = functionStore.MessageStore;
592609

@@ -628,7 +645,8 @@ await functionStore.CreateFunction(
628645
leaseExpiration: DateTime.UtcNow.Ticks,
629646
postponeUntil: long.MaxValue,
630647
timestamp: DateTime.UtcNow.Ticks,
631-
parent: null
648+
parent: null,
649+
owner: null
632650
).ShouldBeTrueAsync();
633651
await functionStore.CreateFunction(
634652
id2,
@@ -637,7 +655,8 @@ await functionStore.CreateFunction(
637655
leaseExpiration: DateTime.UtcNow.Ticks,
638656
postponeUntil: long.MaxValue,
639657
timestamp: DateTime.UtcNow.Ticks,
640-
parent: null
658+
parent: null,
659+
owner: null
641660
).ShouldBeTrueAsync();
642661
var messageStore = functionStore.MessageStore;
643662

@@ -687,7 +706,8 @@ await functionStore.CreateFunction(
687706
leaseExpiration: DateTime.UtcNow.Ticks,
688707
postponeUntil: long.MaxValue,
689708
timestamp: DateTime.UtcNow.Ticks,
690-
parent: null
709+
parent: null,
710+
owner: null
691711
).ShouldBeTrueAsync();
692712
var messageStore = functionStore.MessageStore;
693713

@@ -722,7 +742,8 @@ await functionStore.CreateFunction(
722742
leaseExpiration: DateTime.UtcNow.Ticks,
723743
postponeUntil: long.MaxValue,
724744
timestamp: DateTime.UtcNow.Ticks,
725-
parent: null
745+
parent: null,
746+
owner: null
726747
).ShouldBeTrueAsync();
727748
await functionStore.CreateFunction(
728749
id2,
@@ -731,7 +752,8 @@ await functionStore.CreateFunction(
731752
leaseExpiration: DateTime.UtcNow.Ticks,
732753
postponeUntil: long.MaxValue,
733754
timestamp: DateTime.UtcNow.Ticks,
734-
parent: null
755+
parent: null,
756+
owner: null
735757
).ShouldBeTrueAsync();
736758
var messageStore = functionStore.MessageStore;
737759

‎Core/Cleipnir.ResilientFunctions.Tests/Messaging/TestTemplates/MessagesSubscriptionTests.cs‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@ await functionStore.CreateFunction(
2626
leaseExpiration: DateTime.UtcNow.Ticks,
2727
postponeUntil: null,
2828
timestamp: DateTime.UtcNow.Ticks,
29-
parent: null
29+
parent: null,
30+
owner: null
3031
);
3132
var messageStore = functionStore.MessageStore;
3233

0 commit comments

Comments
 (0)