astra
/
plc-mirror
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add a bit more logging for cursor values

main
Max Ignatenko 2024-03-28 16:00:19 +00:00
parent 5d3d562ecc
commit fc5307a971
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/consumer/consumer.go
View File

@ -78,6 +78,11 @@ func (c *Consumer) run(ctx context.Context) {
func (c *Consumer) runOnce(ctx context.Context) error { func (c *Consumer) runOnce(ctx context.Context) error {
log := zerolog.Ctx(ctx) log := zerolog.Ctx(ctx)
log.Info().
Int64("cursor", c.remote.Cursor).
Int64("first_cursor_since_reset", c.remote.FirstCursorSinceReset).
Msgf("Connecting to firehose of %s...", c.remote.Host)
addr, err := url.Parse(c.remote.Host) addr, err := url.Parse(c.remote.Host)
if err != nil { if err != nil {
return fmt.Errorf("parsing URL %q: %s", c.remote.Host, err) return fmt.Errorf("parsing URL %q: %s", c.remote.Host, err)
@ -175,6 +180,11 @@ func (c *Consumer) checkForCursorReset(ctx context.Context, seq int64) error {
// hack to detect cursor resets upon connection for implementations // hack to detect cursor resets upon connection for implementations
// that don't emit an explicit #info when connecting with an outdated cursor. // that don't emit an explicit #info when connecting with an outdated cursor.
zerolog.Ctx(ctx).Info().
Int64("cursor", c.remote.Cursor).
Int64("remote_cursor", seq).
Msgf("Checking for possible cursor reset")
if seq == c.remote.Cursor+1 { if seq == c.remote.Cursor+1 {
// No reset. // No reset.
return nil return nil