Method reconnectJobStream

internal/bridge/bridge.go:333–357

reconnectJobStream attempts to re-open the JobStream with exponential backoff.

(lastErr error)

// reconnectJobStream attempts to re-open the JobStream with exponential backoff.
func (b *Bridge) reconnectJobStream(lastErr error) {
	restore := shouldRestoreBridgeState(lastErr)
	for attempt := 1; ; attempt++ {
		select {
		case <-b.ctx.Done():
			return
		case <-time.After(reconnectDelay(attempt)):
		}
		var err error
		if restore {
			err = b.restoreBridgeState(false)
		} else {
			err = b.openJobStream()
			if shouldRestoreBridgeState(err) {
				restore = true
			}
		}
		if err != nil {
			log.Errorf("[bridge] JobStream reconnect attempt %d failed: %v", attempt, err)
			continue
		}
		log.Infof("[bridge] JobStream reconnected after %d attempts", attempt)
		return
	}
}

func (b *Bridge) restoreBridgeState(restoreSpite bool) error {
	b.reconnectMu.Lock()