Skip to content

Commit cb2da30

Browse files
authored
Clarify server side filtering sample and align with docs (#330)
* Encourage developers to use commit position as checkpoint to align with docs
1 parent f267b97 commit cb2da30

File tree

1 file changed

+14
-11
lines changed

1 file changed

+14
-11
lines changed

samples/server-side-filtering/Program.cs

+14-11
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,12 @@
1515
await foreach (var message in subscription.Messages) {
1616
switch (message) {
1717
case StreamMessage.Event(var e):
18-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
18+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
1919
semaphore.Release();
2020
break;
2121
case StreamMessage.AllStreamCheckpointReached(var p):
22-
Console.WriteLine($"checkpoint taken at {p.PreparePosition}");
22+
// Code to save commit position to a persistent store as a checkpoint
23+
Console.WriteLine($"checkpoint taken at {p.CommitPosition}");
2324
break;
2425
}
2526
}
@@ -55,7 +56,7 @@ static async Task ExcludeSystemEvents(EventStoreClient client) {
5556
await foreach (var message in subscription.Messages) {
5657
switch (message) {
5758
case StreamMessage.Event(var e):
58-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
59+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
5960
break;
6061
}
6162
}
@@ -74,7 +75,7 @@ static async Task EventTypePrefix(EventStoreClient client) {
7475
await foreach (var message in subscription.Messages) {
7576
switch (message) {
7677
case StreamMessage.Event(var e):
77-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
78+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
7879
break;
7980
}
8081
}
@@ -91,7 +92,7 @@ static async Task EventTypeRegex(EventStoreClient client) {
9192
await foreach (var message in subscription.Messages) {
9293
switch (message) {
9394
case StreamMessage.Event(var e):
94-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
95+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
9596
break;
9697
}
9798
}
@@ -108,7 +109,7 @@ static async Task StreamPrefix(EventStoreClient client) {
108109
await foreach (var message in subscription.Messages) {
109110
switch (message) {
110111
case StreamMessage.Event(var e):
111-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
112+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
112113
break;
113114
}
114115
}
@@ -125,7 +126,7 @@ static async Task StreamRegex(EventStoreClient client) {
125126
await foreach (var message in subscription.Messages) {
126127
switch (message) {
127128
case StreamMessage.Event(var e):
128-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
129+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
129130
break;
130131
}
131132
}
@@ -140,10 +141,11 @@ static async Task CheckpointCallback(EventStoreClient client) {
140141
await foreach (var message in subscription.Messages) {
141142
switch (message) {
142143
case StreamMessage.Event(var e):
143-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
144+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
144145
break;
145146
case StreamMessage.AllStreamCheckpointReached(var p):
146-
Console.WriteLine($"checkpoint taken at {p.PreparePosition}");
147+
// Save commit position to a persistent store as a checkpoint
148+
Console.WriteLine($"checkpoint taken at {p.CommitPosition}");
147149
break;
148150
}
149151
}
@@ -162,10 +164,11 @@ static async Task CheckpointCallbackWithInterval(EventStoreClient client) {
162164
await foreach (var message in subscription.Messages) {
163165
switch (message) {
164166
case StreamMessage.Event(var e):
165-
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.PreparePosition}");
167+
Console.WriteLine($"{e.Event.EventType} @ {e.Event.Position.CommitPosition}");
166168
break;
167169
case StreamMessage.AllStreamCheckpointReached(var p):
168-
Console.WriteLine($"checkpoint taken at {p.PreparePosition}");
170+
// Save commit position to a persistent store as a checkpoint
171+
Console.WriteLine($"checkpoint taken at {p.CommitPosition}");
169172
break;
170173
}
171174
}

0 commit comments

Comments
 (0)