- Sort Score
- Result 10 results
- Languages All
Results 1131 - 1140 of 1,713 for Fake (0.08 sec)
-
cmd/config-migrate.go
case "30": // V30 -> V31 cfg.OpenID = openid.Config{} cfg.Policy.OPA = opa.Args{ URL: &xnet.URL{}, AuthToken: "", } case "31": // V31 -> V32 cfg.Notify.NSQ = make(map[string]target.NSQArgs) cfg.Notify.NSQ["1"] = target.NSQArgs{} } // Move to latest. cfg.Version = "33" newCfg := newServerConfig() config.SetRegion(newCfg, cfg.Region)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
if c.clusters == nil { return fmt.Errorf("config writer has not been primed") } w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0) clusterEndpoint := make([]EndpointCluster, 0) for _, cluster := range c.clusters.ClusterStatuses { for _, host := range cluster.HostStatuses { if filter.Verify(host, cluster.Name) { addr := retrieveEndpointAddress(host)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 5.8K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} // concurrently load bucket metadata to speed up loading bucket metadata. func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []string) { g := errgroup.WithNErrs(len(buckets)) bucketMetas := make([]BucketMetadata, len(buckets)) for index := range buckets { index := index g.Go(func() error { // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api.h
// // Very similar to TF_OperationDescription with some differences: // (1) TF_Output or TFE_TensorHandle* as arguments to TF_AddInput, // TF_AddInputList // (2) TF_ColocateWith, TF_AddControlInput etc. do not make sense. // (3) Implementation detail: Avoid use of NodeBuilder/NodeDefBuilder since // the additional sanity checks there seem unnecessary; typedef struct TFE_Op TFE_Op;
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 22.8K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
func testCreateBucket(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler, credentials auth.Credentials, t *testing.T, ) { bucketName1 := fmt.Sprintf("%s-1", bucketName) const n = 100 start := make(chan struct{}) var ok, errs int var wg sync.WaitGroup var mu sync.Mutex wg.Add(n) for i := 0; i < n; i++ { go func() { defer wg.Done() // Sync start. <-start
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 32.9K bytes - Viewed (0) -
compat/maven-model-builder/src/test/java/org/apache/maven/model/interpolation/AbstractModelInterpolatorTest.java
Calendar cal = Calendar.getInstance(); cal.setTimeZone(MavenBuildTimestamp.DEFAULT_BUILD_TIME_ZONE); cal.set(Calendar.HOUR, 12); cal.set(Calendar.AM_PM, Calendar.AM); // just to make sure all the bases are covered... cal.set(Calendar.HOUR_OF_DAY, 0); cal.set(Calendar.MINUTE, 16); cal.set(Calendar.SECOND, 0); cal.set(Calendar.YEAR, 1976);
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 22.2K bytes - Viewed (0) -
cmd/data-usage_test.go
t.Fatal(err) } err = os.WriteFile(filepath.Join(base, bucket, f.name), make([]byte, f.size), os.ModePerm) if err != nil { t.Fatal(err) } } } // generateUsageTestFiles create nFolders * nFiles files of size bytes each. func generateUsageTestFiles(t *testing.T, base, bucket string, nFolders, nFiles, size int) { pl := make([]byte, size) for i := 0; i < nFolders; i++ {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 14.7K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
} } target := &ElasticsearchTarget{ id: event.TargetID{ID: id, Name: "elasticsearch"}, args: args, store: queueStore, loggerOnce: loggerOnce, quitCh: make(chan struct{}), } if target.store != nil { store.StreamItems(target.store, target, target.quitCh, target.loggerOnce) } return target, nil } // ES Client definitions and methods
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 15K bytes - Viewed (0) -
cmd/encryption-v1.go
const BatchSize = 250 // We process the objects in batches - 250 is a reasonable default. var ( metadata = make([]map[string]string, 0, BatchSize) buckets = make([]string, 0, BatchSize) names = make([]string, 0, BatchSize) ) for len(objects) > 0 { N := BatchSize if len(objects) < BatchSize { N = len(objects) } batch := objects[:N]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:06:08 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/leak-detect_test.go
relevantRoutines map[string]bool } // NewLeakDetect - Initialize a LeakDetector with the snapshot of relevant Go routines. func NewLeakDetect() LeakDetect { snapshot := LeakDetect{ relevantRoutines: make(map[string]bool), } for _, g := range pickRelevantGoroutines() { snapshot.relevantRoutines[g] = true } return snapshot }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (0)