From 3e9fcf9d7ba50d4f7202eb2e50d6375325dcbb3f Mon Sep 17 00:00:00 2001
From: Simone Gotti <simone.gotti@gmail.com>
Date: Thu, 28 Mar 2019 16:01:33 +0100
Subject: [PATCH] wal: add function to return current changes revision

---
 internal/wal/wal.go | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/internal/wal/wal.go b/internal/wal/wal.go
index cafaf82..61c3402 100644
--- a/internal/wal/wal.go
+++ b/internal/wal/wal.go
@@ -155,6 +155,15 @@ type ChangeGroupsUpdateToken struct {
 
 type changeGroupsRevisions map[string]int64
 
+func (w *WalManager) ChangesCurrentRevision() (int64, error) {
+	w.changes.Lock()
+	defer w.changes.Unlock()
+	if !w.changes.initialized {
+		return 0, errors.Errorf("wal changes not ready")
+	}
+	return w.changes.revision, nil
+}
+
 func (w *WalManager) GetChangeGroupsUpdateToken(cgNames []string) (*ChangeGroupsUpdateToken, error) {
 	w.changes.Lock()
 	defer w.changes.Unlock()