From fa39c6732098199b8b13571a6db53513683deaf3 Mon Sep 17 00:00:00 2001 From: Manan Gupta Date: Tue, 3 Dec 2024 11:54:48 +0530 Subject: [PATCH] feat: add a log line for knowing when a keyspace event is received Signed-off-by: Manan Gupta --- go/vt/vtgate/buffer/buffer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/go/vt/vtgate/buffer/buffer.go b/go/vt/vtgate/buffer/buffer.go index 50492640377..eb937a6361c 100644 --- a/go/vt/vtgate/buffer/buffer.go +++ b/go/vt/vtgate/buffer/buffer.go @@ -89,7 +89,7 @@ func CausedByFailover(err error) bool { log.V(2).Infof("Checking error (type: %T) if it is caused by a failover. err: %v", err, err) reason, isFailover := isFailoverError(err) if isFailover { - log.V(2).Infof("CausedByFailover signalling failover for reason: %s", reason) + log.Infof("CausedByFailover signalling failover for reason: %s", reason) } return isFailover } @@ -208,6 +208,7 @@ func (b *Buffer) WaitForFailoverEnd(ctx context.Context, keyspace, shard string, } func (b *Buffer) HandleKeyspaceEvent(ksevent *discovery.KeyspaceEvent) { + log.Infof("Keyspace Event received for keyspace %v", ksevent.Keyspace) for _, shard := range ksevent.Shards { sb := b.getOrCreateBuffer(shard.Target.Keyspace, shard.Target.Shard) if sb != nil {