Skip to content

Commit

Permalink
fixed small issues
Browse files Browse the repository at this point in the history
  • Loading branch information
pk910 committed Aug 23, 2023
1 parent dfc1c56 commit 0fbaef1
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion indexer/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ func (client *IndexerClient) runIndexerClientLoop() {
for {
err := client.runIndexerClient()
if err != nil {
logger.WithField("client", client.clientName).Errorf("Indexer client error: %v, retrying in 10 sec...", err)
logger.WithField("client", client.clientName).Errorf("indexer client error: %v, retrying in 10 sec...", err)
time.Sleep(10 * time.Second)
} else {
return
Expand Down Expand Up @@ -170,6 +170,7 @@ func (client *IndexerClient) runIndexerClient() error {
client.isConnected = false
return err
}
client.lastStreamEvent = time.Now()
}

currentEpoch := utils.TimeToEpoch(time.Now())
Expand Down

0 comments on commit 0fbaef1

Please sign in to comment.