Skip to content

Instantly share code, notes, and snippets.

@mseemann

mseemann/UserCollectionChangeStreamService.java

Created September 3, 2021 15:23
Show Gist options
  • Save mseemann/3826d523af8f04540de0fc727d8570ee to your computer and use it in GitHub Desktop.
Save mseemann/3826d523af8f04540de0fc727d8570ee to your computer and use it in GitHub Desktop.
Download ZIP
UserCollectionChangeStreamService
Raw
UserCollectionChangeStreamService.java
Gauge.builder("sync.last.seen.doc.at", this, listener -> listener.lastSeenAt.get())
.strongReference(true)
.register(Metrics.globalRegistry);
Gauge.builder("sync.last.processed.doc.at", this, listener -> listener.lastProcessedAt.get())
.strongReference(true)
.register(Metrics.globalRegistry);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment