- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 93 for Hoeger (0.25 sec)
-
cmd/erasure-server-pool.go
}) healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx] if !healthy { storageLogIf(logger.SetReqInfo(ctx, reqInfo), fmt.Errorf("Write quorum may be lost on pool: %d, set: %d, expected write quorum: %d", poolIdx, setIdx, poolWriteQuorums[poolIdx]), logger.FatalKind) } result.Healthy = result.Healthy && healthy
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
tests/preload_test.go
{Name: "Jinzhu Tool 1"}, {Name: "Jinzhu Tool 2"}, }, }, }, } DB.Create(&users) query := make([]string, 0) sess := DB.Session(&gorm.Session{Logger: Tracer{ Logger: DB.Config.Logger, Test: func(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { sql, _ := fc() query = append(query, sql) }, }}) var result []User
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Apr 25 12:21:03 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} }, finished: nil, }) return err } func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error { ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{}) const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS" workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets)) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
internal/bucket/lifecycle/rule_test.go
// appropriate errors on validation func TestInvalidRules(t *testing.T) { invalidTestCases := []struct { inputXML string expectedErr error }{ { // Rule with ID longer than 255 characters inputXML: ` <Rule>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
}) return err } // rebalanceBucket rebalances objects under bucket in poolIdx pool func (z *erasureServerPools) rebalanceBucket(ctx context.Context, bucket string, poolIdx int) (err error) { ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{}) var vc *versioning.Versioning var lc *lifecycle.Lifecycle var lr objectlock.Retention var rcfg *replication.Config if bucket != minioMetaBucket {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/metrics-v2.go
} func getWebhookMetrics() *MetricsGroupV2 { mg := &MetricsGroupV2{ cacheInterval: 10 * time.Second, } mg.RegisterRead(func(ctx context.Context) []MetricV2 { tgts := append(logger.SystemTargets(), logger.AuditTargets()...) metrics := make([]MetricV2, 0, len(tgts)*4) for _, t := range tgts { isOnline := 0 if t.IsOnline(ctx) { isOnline = 1 } labels := map[string]string{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
* * <p>The returned iterator supports {@code remove()} if the provided iterator does. After {@code * remove()} is called, subsequent cycles omit the removed element, which is no longer in {@code * iterable}. The iterator's {@code hasNext()} method returns {@code true} until {@code iterable} * is empty. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Apr 30 18:43:01 GMT 2024 - 51.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
* * @author Nishant Thakkar * @author Sven Mawson * @since 1.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class ExecutionList { /** Logger to log exceptions caught when running runnables. */ private static final LazyLogger log = new LazyLogger(ExecutionList.class); /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/metrics-v3-types.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "fmt" "strings" "sync" "github.com/minio/minio/internal/logger" "github.com/pkg/errors" "github.com/prometheus/client_golang/prometheus" "golang.org/x/exp/slices" ) type collectorPath string // metricPrefix converts a collector path to a metric name prefix. The path is
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
.bazelrc
# TODO(mihaimaruseac): Document this option or remove if no longer needed build --enable_platform_specific_config # Enable XLA support by default. build --define=with_xla_support=true # TODO(mihaimaruseac): Document this option or remove if no longer needed build --config=short_logs # TODO(mihaimaruseac): Document this option or remove if no longer needed build --config=v2 # Disable AWS/HDFS support by default
Plain Text - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Thu May 02 19:34:20 GMT 2024 - 52.8K bytes - Viewed (2)