Method restoreBridgeState

internal/bridge/bridge.go:359–383

(restoreSpite bool)

}

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

	if err := b.registerListener(); err != nil {
		return err
	}
	if err := b.registerPipeline(); err != nil {
		return err
	}
	if err := b.openJobStream(); err != nil {
		return err
	}
	if restoreSpite {
		if err := b.openSpiteStream(); err != nil {
			return err
		}
	}

	// StartPipeline can block until JobStream receives CtrlPipelineStart,
	// so it must run outside the reconnect caller's Recv loop.
	b.startPipelineAsync()
	b.reregisterSessions()
	return nil
}

func shouldRestoreBridgeState(err error) bool {
	if err == nil {