- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for 500 (0.28 sec)
-
internal/config/api/api.go
if err != nil { return cfg, err } if replicationMaxWorkers <= 0 || replicationMaxWorkers > 500 { return cfg, config.ErrInvalidReplicationWorkersValue(nil).Msg("Number of replication workers should be between 1 and 500") } cfg.ReplicationMaxWorkers = replicationMaxWorkers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
internal/dsync/dsync_test.go
for i := range lockServers[:3] { lockServers[i].setRefreshReply(false) defer lockServers[i].setRefreshReply(true) } dm := NewDRWMutex(ds, "aap") dm.refreshInterval = 500 * time.Millisecond var wg sync.WaitGroup wg.Add(1) ctx, cl := context.WithCancel(context.Background()) cancel := func() { cl() wg.Done() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
tests/hooks_test.go
result.Name += "_clone" AssertObjEqual(t, result, resultClone, "Price", "Name") DB.Model(&result).Update("Price", 500) var result2 Product2 DB.First(&result2, "name = ?", "Nice") if result2.Price != 500 { t.Errorf("Failed to update product's price, expects: %v, got %v", 500, result2.Price) } product3 := Product2{Name: "Nice2", Price: 600, Owner: "admin"}
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sat Feb 18 01:20:29 GMT 2023 - 15.9K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
"istio.io/istio/pkg/kube" istioversion "istio.io/istio/pkg/version" ) const ( // Service account to create tokens in tokenServiceAccount = "default" // Get the pods with limit = 500. kubeClientGetPodLimit = 500 ) type ControlPlaneNotFoundError struct { Namespace string } func (c ControlPlaneNotFoundError) Error() string { return fmt.Sprintf("no running Istio pods in %q", c.Namespace) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
if tgt.Empty() { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, fmt.Errorf("invalid arn : '%s'", opts.ARN)), r.URL) return } } keepAliveTicker := time.NewTicker(500 * time.Millisecond) defer keepAliveTicker.Stop() diffCh, err := getReplicationDiff(ctx, objectAPI, bucket, opts) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
src/archive/tar/tar_test.go
}, { header: &Header{ModTime: time.Unix(1, 500), Format: FormatUSTAR}, paxHdrs: map[string]string{paxMtime: "1.0000005"}, formats: FormatUSTAR, }, { header: &Header{ModTime: time.Unix(1, 500), Format: FormatPAX}, paxHdrs: map[string]string{paxMtime: "1.0000005"}, formats: FormatPAX, }, { header: &Header{ModTime: time.Unix(1, 500), Format: FormatGNU},
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
internal/s3select/message.go
var progressTickerC <-chan time.Time if writer.getProgressFunc != nil { progressTicker = time.NewTicker(1 * time.Minute) progressTickerC = progressTicker.C } recordStagingTicker := time.NewTicker(500 * time.Millisecond) // Exit conditions: // // 1. If a writer.write() returns false, select loop below exits and // closes `doneCh` to indicate to caller to also exit. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} } } // MetricsLoaderFn - represents a function to load metrics from the // metricsCache. // // Note that returning an error here will cause the Metrics handler to return a // 500 Internal Server Error. type MetricsLoaderFn func(context.Context, MetricValues, *metricsCache) error // JoinLoaders - joins multiple loaders into a single loader. The returned
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) -
cmd/iam-object-store.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/generic-handlers.go
// Maximum size for user-defined metadata - See: https://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html maxUserDataSize = 2 * 1024 // maxBuckets upto 500000 for any MinIO deployment. maxBuckets = 500 * 1000 ) // ReservedMetadataPrefix is the prefix of a metadata key which // is reserved and for internal use only. const ( ReservedMetadataPrefix = "X-Minio-Internal-"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0)