logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-06 16:13:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: pagesize

Browse Source
This commit is contained in:
Richard Ramos 2024-05-29 22:59:13 -04:00
parent 1e9ed245f1
commit 7a98002155
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/storemsgcounter/execute.go
View File

@ -292,7 +292,7 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
ContentFilter: protocol.NewContentFilter(topic),
TimeStart: proto.Int64(startTime.UnixNano()),
TimeEnd: proto.Int64(endTime.UnixNano()),
}, store.WithPeer(node.ID))
}, store.WithPeer(node.ID), store.WithPaging(false, 100))
if err != nil {
logger.Error("could not query storenode", zap.Stringer("storenode", node), zap.Error(err))
storeNodeFailure = true
@ -335,7 +335,7 @@ func retrieveHistory(ctx context.Context, runId string, storenodes []peer.AddrIn
nextRetryLbl:
for i := 0; i < maxAttempts; i++ {
logger.Info("EXECUTING NEXT!!!")
logger.Info("EXECUTING NEXT!!!", zap.String("cursor", hex.EncodeToString(result.Cursor())))
err = result.Next(ctx)
if err != nil {
logger.Error("could not query storenode", zap.Stringer("storenode", node), zap.Error(err))