-
Notifications
You must be signed in to change notification settings - Fork 874
Expand file tree
/
Copy pathLogMessages.cs
More file actions
486 lines (401 loc) · 22.7 KB
/
LogMessages.cs
File metadata and controls
486 lines (401 loc) · 22.7 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
using System;
using System.Collections.Generic;
using System.Data;
using Microsoft.Extensions.Logging;
using NpgsqlTypes;
namespace Npgsql;
// ReSharper disable InconsistentNaming
#pragma warning disable SYSLIB1015 // Argument is not referenced from the logging message
#pragma warning disable SYSLIB1006 // Multiple logging methods are using event id
static partial class LogMessages
{
#region Connection
[LoggerMessage(
EventId = NpgsqlEventId.OpeningConnection,
Level = LogLevel.Trace,
Message = "Opening connection to {Host}:{Port}/{Database}...")]
internal static partial void OpeningConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString);
[LoggerMessage(
EventId = NpgsqlEventId.OpenedConnection,
Level = LogLevel.Debug,
Message = "Opened connection to {Host}:{Port}/{Database}")]
internal static partial void OpenedConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ClosingConnection,
Level = LogLevel.Trace,
Message = "Closing connection to {Host}:{Port}/{Database}...")]
internal static partial void ClosingConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ClosedConnection,
Level = LogLevel.Debug,
Message = "Closed connection to {Host}:{Port}/{Database}")]
internal static partial void ClosedConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.OpeningPhysicalConnection,
Level = LogLevel.Trace,
Message = "Opening physical connection to {Host}:{Port}/{Database}...")]
internal static partial void OpeningPhysicalConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString);
[LoggerMessage(
EventId = NpgsqlEventId.OpenedPhysicalConnection,
Level = LogLevel.Debug,
Message = "Opened physical connection to {Host}:{Port}/{Database} (in {DurationMs}ms)")]
internal static partial void OpenedPhysicalConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, long DurationMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ClosingPhysicalConnection,
Level = LogLevel.Trace,
Message = "Closing physical connection to {Host}:{Port}/{Database}...")]
internal static partial void ClosingPhysicalConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ClosedPhysicalConnection,
Level = LogLevel.Debug,
Message = "Closed physical connection to {Host}:{Port}/{Database}")]
internal static partial void ClosedPhysicalConnection(ILogger logger, string Host, int Port, string Database, string ConnectionString, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingWait,
Level = LogLevel.Information,
Message = "Starting to wait (timeout={TimeoutMs}ms)...")]
internal static partial void StartingWait(ILogger logger, int TimeoutMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ReceivedNotice,
Level = LogLevel.Debug,
Message = "Received notice: {NoticeText}")]
internal static partial void ReceivedNotice(ILogger logger, string NoticeText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ConnectionExceededMaximumLifetime,
Level = LogLevel.Debug,
Message = "Connection has exceeded its maximum lifetime ('{ConnectionMaximumLifeTime}') and will be closed.")]
internal static partial void ConnectionExceededMaximumLifetime(ILogger logger, TimeSpan ConnectionMaximumLifeTime, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.SendingKeepalive,
Level = LogLevel.Trace,
Message = "Sending keepalive...")]
internal static partial void SendingKeepalive(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CompletedKeepalive,
Level = LogLevel.Trace,
Message = "Completed keepalive")]
internal static partial void CompletedKeepalive(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.KeepaliveFailed,
Level = LogLevel.Trace,
Message = "Keepalive failed")]
internal static partial void KeepaliveFailed(ILogger logger, int ConnectorId, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.BreakingConnection,
Level = LogLevel.Trace,
Message = "Breaking connection")]
internal static partial void BreakingConnection(ILogger logger, int ConnectorId, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.CaughtUserExceptionInNoticeEventHandler,
Level = LogLevel.Error,
Message = "User exception caught when emitting notice event")]
internal static partial void CaughtUserExceptionInNoticeEventHandler(ILogger logger, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.CaughtUserExceptionInNotificationEventHandler,
Level = LogLevel.Error,
Message = "User exception caught when emitting notification event")]
internal static partial void CaughtUserExceptionInNotificationEventHandler(ILogger logger, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.ExceptionWhenClosingPhysicalConnection,
Level = LogLevel.Warning,
Message = "Exception while closing connector")]
internal static partial void ExceptionWhenClosingPhysicalConnection(ILogger logger, int ConnectorId, Exception exception);
[LoggerMessage(
Level = LogLevel.Trace,
Message = "Start user action")]
internal static partial void StartUserAction(ILogger logger, int ConnectorId);
[LoggerMessage(
Level = LogLevel.Trace,
Message = "End user action")]
internal static partial void EndUserAction(ILogger logger, int ConnectorId);
#endregion Connection
#region Command
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingCommand,
Level = LogLevel.Debug,
Message = "Executing command: {CommandText}",
SkipEnabledCheck = true)]
internal static partial void ExecutingCommand(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingCommand,
Level = LogLevel.Debug,
Message = "Executing command: {CommandText}\n Parameters: {Parameters}",
SkipEnabledCheck = true)]
internal static partial void ExecutingCommandWithParameters(ILogger logger, string CommandText, IEnumerable<object> Parameters, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingCommand,
Level = LogLevel.Debug,
Message = "Executing batch: {BatchCommands}",
SkipEnabledCheck = true)]
internal static partial void ExecutingBatch(ILogger logger, string[] BatchCommands, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingCommand,
Level = LogLevel.Debug,
Message = "Executing batch: {BatchCommands}",
SkipEnabledCheck = true)]
internal static partial void ExecutingBatchWithParameters(ILogger logger, (string CommandText, IEnumerable<object> Parameters)[] BatchCommands, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommandExecutionCompleted,
Level = LogLevel.Information,
Message = "Command execution completed (duration={DurationMs}ms): {CommandText}",
SkipEnabledCheck = true)]
internal static partial void CommandExecutionCompleted(ILogger logger, string CommandText, long DurationMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommandExecutionCompleted,
Level = LogLevel.Information,
Message = "Command execution completed (duration={DurationMs}ms): {CommandText}\n Parameters: {Parameters}",
SkipEnabledCheck = true)]
internal static partial void CommandExecutionCompletedWithParameters(ILogger logger, string CommandText, IEnumerable<object> Parameters, long DurationMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommandExecutionCompleted,
Level = LogLevel.Information,
Message = "Batch execution completed (duration={DurationMs}ms): {BatchCommands}",
SkipEnabledCheck = true)]
internal static partial void BatchExecutionCompleted(ILogger logger, string[] BatchCommands, long DurationMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommandExecutionCompleted,
Level = LogLevel.Information,
Message = "Batch execution completed (duration={DurationMs}ms): {BatchCommands}",
SkipEnabledCheck = true)]
internal static partial void BatchExecutionCompletedWithParameters(
ILogger logger, (string CommandText, IEnumerable<object> Parameters)[] BatchCommands, long DurationMs, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CancellingCommand,
Level = LogLevel.Debug,
Message = "Sending PostgreSQL cancellation...")]
internal static partial void CancellingCommand(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingInternalCommand,
Level = LogLevel.Debug,
Message = "Executing internal command: {CommandText}")]
internal static partial void ExecutingInternalCommand(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.PreparingCommandExplicitly,
Level = LogLevel.Debug,
Message = "Preparing command explicitly: {CommandText}",
SkipEnabledCheck = true)]
internal static partial void PreparingCommandExplicitly(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommandPreparedExplicitly,
Level = LogLevel.Information,
Message = "Prepared command explicitly")]
internal static partial void CommandPreparedExplicitly(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.AutoPreparingStatement,
Level = LogLevel.Debug,
Message = "Auto-preparing statement: {CommandText}")]
internal static partial void AutoPreparingStatement(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.UnpreparingCommand,
Level = LogLevel.Debug,
Message = "Prepared command explicitly")]
internal static partial void UnpreparingCommand(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.DerivingParameters,
Level = LogLevel.Debug,
Message = "Deriving Parameters for query: {CommandText}")]
internal static partial void DerivingParameters(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
Level = LogLevel.Trace,
Message = "Cleaning up reader")]
internal static partial void ReaderCleanup(ILogger logger, int ConnectorId);
#endregion Command
#region Transaction
[LoggerMessage(
EventId = NpgsqlEventId.StartedTransaction,
Level = LogLevel.Debug,
Message = "Starting transaction")]
internal static partial void StartedTransaction(ILogger logger, IsolationLevel IsolationLevel, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommittedTransaction,
Level = LogLevel.Debug,
Message = "Committed transaction")]
internal static partial void CommittedTransaction(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.RolledBackTransaction,
Level = LogLevel.Debug,
Message = "Rolled back transaction")]
internal static partial void RolledBackTransaction(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CreatingSavepoint,
Level = LogLevel.Debug,
Message = "Creating savepoint '{SavepointName}'")]
internal static partial void CreatingSavepoint(ILogger logger, string SavepointName, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.RolledBackToSavepoint,
Level = LogLevel.Debug,
Message = "Rolled back to savepoint '{SavepointName}'")]
internal static partial void RolledBackToSavepoint(ILogger logger, string SavepointName, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ReleasedSavepoint,
Level = LogLevel.Debug,
Message = "Released savepoint '{SavepointName}'")]
internal static partial void ReleasedSavepoint(ILogger logger, string SavepointName, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExceptionDuringTransactionDispose,
Level = LogLevel.Error,
Message = "Exception while disposing transaction")]
internal static partial void ExceptionDuringTransactionDispose(ILogger logger, int ConnectorId, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.EnlistedVolatileResourceManager,
Level = LogLevel.Debug,
Message = "Enlisted volatile resource manager (local transaction ID={LocalTransactionIdentifier})")]
internal static partial void EnlistedVolatileResourceManager(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommittingSinglePhaseTransaction,
Level = LogLevel.Debug,
Message = "Committing single-phase transaction (local ID={LocalTransactionIdentifier})")]
internal static partial void CommittingSinglePhaseTransaction(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.RollingBackSinglePhaseTransaction,
Level = LogLevel.Debug,
Message = "Rolling back single-phase transaction (local ID={LocalTransactionIdentifier})")]
internal static partial void RollingBackSinglePhaseTransaction(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.SinglePhaseTransactionRollbackFailed,
Level = LogLevel.Error,
Message = "Exception during single-phase transaction rollback (local ID={LocalTransactionIdentifier})")]
internal static partial void SinglePhaseTransactionRollbackFailed(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.PreparingTwoPhaseTransaction,
Level = LogLevel.Debug,
Message = "Preparing two-phase transaction (local ID={LocalTransactionIdentifier})")]
internal static partial void PreparingTwoPhaseTransaction(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CommittingTwoPhaseTransaction,
Level = LogLevel.Debug,
Message = "Committing two-phase transaction (local ID={LocalTransactionIdentifier})")]
internal static partial void CommittingTwoPhaseTransaction(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.TwoPhaseTransactionCommitFailed,
Level = LogLevel.Error,
Message = "Exception during two-phase transaction commit (local ID={LocalTransactionIdentifier})")]
internal static partial void TwoPhaseTransactionCommitFailed(ILogger logger, string LocalTransactionIdentifier, int ConnectorId, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.RollingBackTwoPhaseTransaction,
Level = LogLevel.Debug,
Message = "Rolling back two-phase transaction (local ID={LocalTransactionIdentifier})")]
internal static partial void RollingBackTwoPhaseTransaction(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.TwoPhaseTransactionRollbackFailed,
Level = LogLevel.Debug,
Message = "Exception during two-phase transaction rollback (local ID={LocalTransactionIdentifier})")]
internal static partial void TwoPhaseTransactionRollbackFailed(ILogger logger, string LocalTransactionIdentifier, int ConnectorId, Exception exception);
[LoggerMessage(
EventId = NpgsqlEventId.TwoPhaseTransactionInDoubt,
Level = LogLevel.Warning,
Message = "Two-phase transaction in doubt (local ID={LocalTransactionIdentifier})")]
internal static partial void TwoPhaseTransactionInDoubt(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ConnectionInUseWhenRollingBack,
Level = LogLevel.Warning,
Message = "Connection in use while trying to rollback, will cancel and retry (local ID={LocalTransactionIdentifier}")]
internal static partial void ConnectionInUseWhenRollingBack(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CleaningUpResourceManager,
Level = LogLevel.Trace,
Message = "Cleaning up resource manager (local ID={LocalTransactionIdentifier})")]
internal static partial void CleaningUpResourceManager(ILogger logger, string LocalTransactionIdentifier, int ConnectorId);
#endregion Transaction
#region Copy
[LoggerMessage(
EventId = NpgsqlEventId.StartingBinaryExport,
Level = LogLevel.Information,
Message = "Starting binary export")]
internal static partial void StartingBinaryExport(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingBinaryImport,
Level = LogLevel.Information,
Message = "Starting binary import")]
internal static partial void StartingBinaryImport(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingTextExport,
Level = LogLevel.Information,
Message = "Starting text export")]
internal static partial void StartingTextExport(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingTextImport,
Level = LogLevel.Information,
Message = "Starting text import")]
internal static partial void StartingTextImport(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingRawCopy,
Level = LogLevel.Information,
Message = "Starting raw COPY operation")]
internal static partial void StartingRawCopy(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CopyOperationCompleted,
Level = LogLevel.Information,
Message = "Binary COPY operation completed ({Rows} rows transferred)")]
internal static partial void BinaryCopyOperationCompleted(ILogger logger, ulong Rows, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CopyOperationCompleted,
Level = LogLevel.Information,
Message = "COPY operation completed")]
internal static partial void CopyOperationCompleted(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.CopyOperationCancelled,
Level = LogLevel.Information,
Message = "COPY operation was cancelled")]
internal static partial void CopyOperationCancelled(ILogger logger, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExceptionWhenDisposingCopyOperation,
Level = LogLevel.Debug,
Message = "Exception when disposing a COPY operation")]
internal static partial void ExceptionWhenDisposingCopyOperation(ILogger logger, int ConnectorId, Exception exception);
#endregion Copy
#region Replication
[LoggerMessage(
EventId = NpgsqlEventId.CreatingReplicationSlot,
Level = LogLevel.Information,
Message = "Creating replication slot '{SlotName}'")]
internal static partial void CreatingReplicationSlot(ILogger logger, string SlotName, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.DroppingReplicationSlot,
Level = LogLevel.Information,
Message = "Dropping replication slot '{SlotName}'")]
internal static partial void DroppingReplicationSlot(ILogger logger, string SlotName, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingLogicalReplication,
Level = LogLevel.Information,
Message = "Starting logical replication on slot '{SlotName}'")]
internal static partial void StartingLogicalReplication(ILogger logger, string SlotName, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.StartingPhysicalReplication,
Level = LogLevel.Information,
Message = "Starting physical replication on slot: '{SlotName}'")]
internal static partial void StartingPhysicalReplication(ILogger logger, string? SlotName, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ExecutingReplicationCommand,
Level = LogLevel.Debug,
Message = "Executing replication command: {CommandText}")]
internal static partial void ExecutingReplicationCommand(ILogger logger, string CommandText, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ReceivedReplicationPrimaryKeepalive,
Level = LogLevel.Trace,
Message = "Received replication primary keepalive message from the server with current end of WAL of {EndLsn} and timestamp of {Timestamp}")]
internal static partial void ReceivedReplicationPrimaryKeepalive(ILogger logger, NpgsqlLogSequenceNumber EndLsn, DateTime Timestamp, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.SendingReplicationStandbyStatusUpdate,
Level = LogLevel.Trace,
Message = "Sending a replication standby status update because {Reason}")]
internal static partial void SendingReplicationStandbyStatusUpdate(ILogger logger, string Reason, int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.SentReplicationFeedbackMessage,
Level = LogLevel.Trace,
Message = "Feedback message sent with LastReceivedLsn={LastReceivedLsn}, LastFlushedLsn={LastFlushedLsn}, LastAppliedLsn={LastAppliedLsn}, Timestamp={Timestamp}",
SkipEnabledCheck = true)]
internal static partial void SentReplicationFeedbackMessage(
ILogger logger,
NpgsqlLogSequenceNumber LastReceivedLsn,
NpgsqlLogSequenceNumber LastFlushedLsn,
NpgsqlLogSequenceNumber LastAppliedLsn,
DateTime Timestamp,
int ConnectorId);
[LoggerMessage(
EventId = NpgsqlEventId.ReplicationFeedbackMessageSendingFailed,
Level = LogLevel.Error,
Message = "An exception occurred while sending a feedback message")]
internal static partial void ReplicationFeedbackMessageSendingFailed(ILogger logger, int? ConnectorId, Exception exception);
#endregion Replication
}