We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent acd267f commit f71d354Copy full SHA for f71d354
src/ServiceControl.Audit.Persistence.PostgreSQL/PostgreSQLPersistenceInstaller.cs
@@ -156,6 +156,14 @@ CREATE INDEX IF NOT EXISTS idx_processed_messages_by_query ON processed_messages
156
await cmd.ExecuteNonQueryAsync(cancellationToken);
157
}
158
159
+ await using (var cmd = new NpgsqlCommand(@"
160
+ CREATE INDEX IF NOT EXISTS idx_processed_messages_audit_counts ON processed_messages (
161
+ receiving_endpoint_name, processed_at
162
+ );", connection))
163
+ {
164
+ await cmd.ExecuteNonQueryAsync(cancellationToken);
165
+ }
166
+
167
// Create saga_snapshots table
168
await using (var cmd = new NpgsqlCommand(@"
169
CREATE TABLE IF NOT EXISTS saga_snapshots (
0 commit comments