extended sharding

MinaFoundation · Mar 1, 2024 · 2e13639 · 2e13639
1 parent 6158c73
commit 2e13639
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/delegation_backend/aws_keyspaces.go b/src/delegation_backend/aws_keyspaces.go
@@ -169,9 +169,12 @@ func (kc *KeyspaceContext) insertSubmission(submission *Submission) error {
 	}, maxRetries, initialBackoff)
 }
 
+// calculateShard returns the shard number for a given submission time.
+// 0-599 are the possible shard numbers, each representing a 6-second interval.
 func calculateShard(submittedAt time.Time) int {
-	// return minute of the hour
-	return submittedAt.Minute()
+	minute := submittedAt.Minute()
+	second := submittedAt.Second()
+	return minute*10 + second/6
 }
 
 func (kc *KeyspaceContext) tryInsertSubmission(submission *Submission, includeRawBlock bool) error {