Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

added DocFx annotations #187

Merged
merged 2 commits into from
May 24, 2024
Merged

added DocFx annotations #187

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
9d41ba7
added DocFx annotations
Aaronontheweb May 24, 2024
c3ede08
Merge branch 'master' into add-docfx
Aaronontheweb May 24, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,9 @@ async Task<ProductCommandResponse> ReplyToSender()

Command<SaveSnapshotSuccess>(success =>
{

// purge older snapshots and messages
DeleteSnapshots(new SnapshotSelectionCriteria(success.Metadata.SequenceNr - 1));
//DeleteMessages(success.Metadata.SequenceNr);
});

Command<FetchProduct>(fetch =>
Expand Down
4 changes: 3 additions & 1 deletion src/clustering/sharding-sqlserver/SqlSharding.Shared/ProductState.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -179,6 +179,7 @@ public static ProductState ProcessEvent(this ProductState productState, IProduct
}
}

// <ProductState>
/// <summary>
/// The state object responsible for all event and message processing
/// </summary>
Expand All @@ -200,4 +201,5 @@ public record ProductState : IWithProductId
public ImmutableSortedSet<ProductInventoryChanged> InventoryChanges { get; init; } = ImmutableSortedSet<ProductInventoryChanged>.Empty;

public bool IsEmpty => Data == ProductData.Empty;
}
}
// </ProductState>
11 changes: 6 additions & 5 deletions src/clustering/sharding-sqlserver/SqlSharding.Sql.Host/Actors/ProductTotalsActor.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,10 @@ public static Props GetProps(string persistenceId)
/// Used to help differentiate what type of entity this is inside Akka.Persistence's database
/// </summary>
public const string TotalsEntityNameConstant = "totals";

private readonly ILoggingAdapter _log = Context.GetLogger();
public override string PersistenceId { get; }
// <ProductStateUsage>
public ProductState State { get; set; }

public ProductTotalsActor(string persistenceId)
{
Expand All @@ -38,6 +40,9 @@ public ProductTotalsActor(string persistenceId)
State = state;
}
});

// rest of message processing
// </ProductStateUsage>

Recover<IProductEvent>(productEvent =>
{
Expand Down Expand Up @@ -96,8 +101,4 @@ public ProductTotalsActor(string persistenceId)
}
});
}

public override string PersistenceId { get; }

public ProductState State { get; set; }
}
Loading