Skip to content

Commit

Permalink
Log large event stream name
Browse files Browse the repository at this point in the history
  • Loading branch information
bartelink committed Apr 3, 2019
1 parent 6ba49a4 commit c2c63af
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions equinox-sync/Sync/Program.fs
Original file line number Diff line number Diff line change
Expand Up @@ -748,11 +748,10 @@ let enumEvents (xs : EventStore.ClientAPI.ResolvedEvent[]) = seq {
|| e.EventType.StartsWith("compacted",StringComparison.OrdinalIgnoreCase)
|| e.EventStreamId.StartsWith("$")
|| e.EventStreamId.EndsWith("_checkpoints")
|| e.EventStreamId.EndsWith("_checkpoint")
|| e.EventStreamId = "thor_useast2_to_backup_qa2_main" ->
|| e.EventStreamId.EndsWith("_checkpoint") ->
Choice2Of2 e
| e when eb > Ingester.cosmosPayloadLimit ->
Log.Error("ES Event Id {eventId} size {eventSize} exceeds Cosmos ingestion limit {maxCosmosBytes}", e.EventId, eb, Ingester.cosmosPayloadLimit)
Log.Error("ES Event Id {eventId} (#{index} in {stream}, type {type}) size {eventSize} exceeds Cosmos ingestion limit {maxCosmosBytes}", e.EventId, e.EventNumber, e.EventStreamId, e.EventType, eb, Ingester.cosmosPayloadLimit)
Choice2Of2 e
| e -> Choice1Of2 (e.EventStreamId, e.EventNumber, Equinox.Codec.Core.EventData.Create(e.EventType, e.Data, e.Metadata, e.Timestamp))
}
Expand Down

0 comments on commit c2c63af

Please sign in to comment.