Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 458 for Runnable (0.04 sec)

  1. internal/event/target/kafka.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of Kafka `%s`: %w", id, err)
    		}
    	}
    
    	target := &KafkaTarget{
    		id:         event.TargetID{ID: id, Name: "kafka"},
    		args:       args,
    		store:      queueStore,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    			}
    		}()
    
    		func() {
    			defer dcancel()
    
    			err := p.storage.WriteAll(ctx, minioMetaTmpBucket, fn, toWrite)
    			if err != nil {
    				if osErrToFileErr(err) == errFaultyDisk {
    					goOffline(fmt.Errorf("unable to write: %w", err), 0)
    				}
    				return
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java

            validClasses.add(new WeakReference<Class<? extends Exception>>(exceptionClass));
          }
        }
    
        /**
         * Returns the ClassValue-using validator, or falls back to the "weak Set" implementation if
         * unable to do so.
         */
        static GetCheckedTypeValidator getBestValidator() {
          return weakSetValidator();
        }
      }
    
      // TODO(cpovirk): change parameter order to match other helper methods (Class, Throwable)?
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  4. cmd/bootstrap-peer-server.go

    // registerBootstrapRESTHandlers - register bootstrap rest router.
    func registerBootstrapRESTHandlers(gm *grid.Manager) {
    	server := &bootstrapRESTServer{}
    	logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler")
    }
    
    // client to talk to bootstrap NEndpoints.
    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    // Verify function verifies the server config.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. internal/grid/manager.go

    			w.WriteHeader(http.StatusForbidden)
    			return
    		}
    		conn, _, _, err := ws.UpgradeHTTP(req, w)
    		if err != nil {
    			if debugPrint {
    				fmt.Printf("grid: Unable to upgrade: %v. http.ResponseWriter is type %T\n", err, w)
    			}
    			w.WriteHeader(http.StatusUpgradeRequired)
    			return
    		}
    		m.IncomingConn(ctx, conn)
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 12 20:41:41 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. internal/event/target/postgresql.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of PostgreSQL `%s`: %w", id, err)
    		}
    	}
    
    	target := &PostgreSQLTarget{
    		id:         event.TargetID{ID: id, Name: "postgresql"},
    		args:       args,
    		firstPing:  false,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  7. docs/ru/docs/tutorial/path-params.md

    ```JSON
    {
      "detail": [
        {
          "type": "int_parsing",
          "loc": [
            "path",
            "item_id"
          ],
          "msg": "Input should be a valid integer, unable to parse string as an integer",
          "input": "foo"
        }
      ]
    }
    ```
    
    из-за того, что параметр пути `item_id` имеет значение `"foo"`, которое не является типом `int`.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  8. build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportWorkAction.kt

                                    versionToIncubating.getOrPut(version) { mutableSetOf() }.addAll(incubating)
                                }
                            } catch (e: Exception) {
                                throw Exception("Unable to parse $sourceFile", e)
                            }
                        }
                    }
                }
                generateTextReport(versionToIncubating)
                generateHtmlReport(versionToIncubating)
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Mon Jun 02 09:57:54 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  9. apache-maven/src/assembly/maven/bin/mvn

            else
              echo "Ignoring --debug option as MAVEN_DEBUG_OPTS is already set"
            fi
            ;;
          --yjp)
            if [ ! -f "$YJPLIB" ]; then
              echo "Error: Unable to autodetect the YJP library location. Please set YJPLIB variable" >&2
              exit 1
            fi
            MAVEN_OPTS="-agentpath:$YJPLIB=onexit=snapshot,onexit=memory,tracing,onlylocal $MAVEN_OPTS"
            ;;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Dec 10 16:40:06 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  10. docs/de/docs/tutorial/handling-errors.md

                "type": "type_error.integer"
            }
        ]
    }
    ```
    
    eine Textversion mit:
    
    ```
    Validation errors:
    Field: ('path', 'item_id'), Error: Input should be a valid integer, unable to parse string as an integer
    ```
    
    ### Überschreiben des `HTTPException`-Fehlerhandlers { #override-the-httpexception-error-handler }
    
    Auf die gleiche Weise können Sie den `HTTPException`-Handler überschreiben.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top