xataio / pgstream

PostgreSQL replication with DDL changes
http://www.xata.io
Apache License 2.0
349 stars 11 forks source link

Fix instrumentation #71

Closed eminano closed 2 months ago

eminano commented 2 months ago

This PR updates the wal kafka batch writer to apply the constructor options after the internal writer is initialised (this allows us to wrap it with instrumentation). The search store retrier is updated to return dropped documents as failed documents in the SendDocuments method, instead of only returning retriable failed documents. This way the metric to track failed document errors accurately represents the results.