Skip to content

Commit 3d7a50b

Browse files
Added action names for all implicit transactions
1 parent a69e7f2 commit 3d7a50b

1 file changed

Lines changed: 9 additions & 9 deletions

File tree

Sources/CodableDatastore/Datastore/Datastore.swift

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ extension Datastore {
165165
}
166166
let warmupTask = Task {
167167
try await persistence._withTransaction(
168-
actionName: "Migrate Entries",
168+
actionName: "Migrate \(key) Instances",
169169
options: []
170170
) { transaction, _ in
171171
try await self.registerAndMigrate(with: transaction)
@@ -382,7 +382,7 @@ extension Datastore where AccessMode == ReadWrite {
382382
let indexRepresentation = AnyIndexRepresentation(indexRepresentation: self.format[keyPath: index])
383383

384384
try await persistence._withTransaction(
385-
actionName: "Migrate Entries",
385+
actionName: "Migrate \(key) Instances",
386386
options: []
387387
) { transaction, _ in
388388
guard
@@ -460,7 +460,7 @@ extension Datastore {
460460
try await warmupIfNeeded()
461461

462462
return try await persistence._withTransaction(
463-
actionName: "Check Count",
463+
actionName: "Check \(key) Count",
464464
options: [.idempotent, .readOnly]
465465
) { transaction, _ in
466466
let descriptor = try await transaction.datastoreDescriptor(for: self.key)
@@ -476,7 +476,7 @@ extension Datastore {
476476
try await warmupIfNeeded()
477477

478478
return try await persistence._withTransaction(
479-
actionName: nil,
479+
actionName: "Load \(key) ID",
480480
options: [.idempotent, .readOnly]
481481
) { transaction, _ in
482482
do {
@@ -515,7 +515,7 @@ extension Datastore {
515515
}
516516

517517
try await self.persistence._withTransaction(
518-
actionName: nil,
518+
actionName: "Load \(self.key) ID Range",
519519
options: [.readOnly]
520520
) { transaction, _ in
521521
do {
@@ -602,7 +602,7 @@ extension Datastore {
602602
try await self.warmupIfNeeded()
603603

604604
try await self.persistence._withTransaction(
605-
actionName: nil,
605+
actionName: "Load \(self.key) \(declaredIndex.indexName)",
606606
options: [.readOnly]
607607
) { transaction, _ in
608608
do {
@@ -753,7 +753,7 @@ extension Datastore {
753753
try await warmupIfNeeded()
754754

755755
return try await persistence._withTransaction(
756-
actionName: nil,
756+
actionName: "Start \(key) Observations",
757757
options: [.idempotent, .readOnly]
758758
) { transaction, _ in
759759
try await transaction.makeObserver(
@@ -791,7 +791,7 @@ extension Datastore where AccessMode == ReadWrite {
791791
let instanceData = try await self.encoder(instance)
792792

793793
return try await persistence._withTransaction(
794-
actionName: "Persist Entry",
794+
actionName: "Persist \(key) Instance",
795795
options: [.idempotent]
796796
) { transaction, _ in
797797
/// Create any missing indexes or prime the datastore for writing.
@@ -977,7 +977,7 @@ extension Datastore where AccessMode == ReadWrite {
977977
try await warmupIfNeeded()
978978

979979
return try await persistence._withTransaction(
980-
actionName: "Delete Entry",
980+
actionName: "Delete \(key) Instance",
981981
options: [.idempotent]
982982
) { transaction, _ in
983983
/// Get a cursor to the entry within the primary index.

0 commit comments

Comments
 (0)