- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for instanceOf (0.18 sec)
-
cmd/metrics.go
Help: "Time taken by requests served by current MinIO server instance", Buckets: []float64{.05, .1, .25, .5, 1, 2.5, 5, 10}, }, []string{"api"}, ) bucketHTTPRequestsDuration = prometheus.NewHistogramVec( prometheus.HistogramOpts{ Name: "s3_ttfb_seconds", Help: "Time taken by requests served by current MinIO server instance per bucket", Buckets: []float64{.05, .1, .25, .5, 1, 2.5, 5, 10}, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
Long: `Retrieve information about certificates for the Ztunnel instance.`, Example: ` # Retrieve summary about workload configuration for a randomly chosen ztunnel. istioctl x ztunnel-config certificates # Retrieve full certificate dump of workloads for a given Ztunnel instance. istioctl x ztunnel-config certificates <ztunnel-name[.namespace]> -o json `,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
) continue } } } return nil } func ObjectToInstance(c controllers.Object) *resource.Instance { return &resource.Instance{ Origin: &legacykube.Origin{ Type: kubetypes.GvkFromObject(c), FullName: resource.FullName{ Namespace: resource.Namespace(c.GetNamespace()), Name: resource.LocalName(c.GetName()),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/erasure-object_test.go
{"bucket", "dir/", ObjectNotFound{Bucket: "bucket", Object: "dir/"}}, {"bucket", "dir/obj", nil}, } ctx, cancel := context.WithCancel(context.Background()) defer cancel() // Create an instance of xl backend xl, fsDirs, err := prepareErasure16(ctx) if err != nil { t.Fatal(err) } defer xl.Shutdown(context.Background()) err = xl.MakeBucket(ctx, "bucket", MakeBucketOptions{}) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
finisher_api.go
db.assignInterfacesToValue(exprs) } return } } } } // FirstOrInit finds the first matching record, otherwise if not found initializes a new instance with given conds. // Each conds must be a struct or map. // // FirstOrInit never modifies the database. It is often used with Assign and Attrs. // // // assign an email if the record is not found
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 22.7K bytes - Viewed (0) -
internal/jwt/parser.go
// Expects key type of []byte for both signing and validation type SigningMethodHMAC struct { Name string Hash crypto.Hash HasherPool sync.Pool } // Specific instances for HS256, HS384, HS512 var ( SigningMethodHS256 *SigningMethodHMAC SigningMethodHS384 *SigningMethodHMAC SigningMethodHS512 *SigningMethodHMAC ) const base64BufferSize = 64 * humanize.KiByte var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
internal/grid/types.go
type ArrayOf[T RoundTripper] struct { aPool sync.Pool // Arrays ePool sync.Pool // Elements } // NewArrayOf returns a new ArrayOf. // You must provide a function that returns a new instance of T. func NewArrayOf[T RoundTripper](newFn func() T) *ArrayOf[T] { return &ArrayOf[T]{ ePool: sync.Pool{New: func() any { return newFn() }}, } } // New returns a new empty Array.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/bucket-targets.go
sys.arnErrsMap[arn] = arnErrs{ updateInProgress: v.updateInProgress, count: v.count + 1, } } } // GetRemoteTargetClient returns minio-go client for replication target instance func (sys *BucketTargetSys) GetRemoteTargetClient(bucket, arn string) *TargetClient { sys.RLock() tgt := sys.arnRemotesMap[arn] sys.RUnlock() if tgt.Client != nil { return tgt.Client }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/update.go
return env.Get("KUBERNETES_SERVICE_HOST", "") != "" } // IsBOSH returns true if minio is deployed from a bosh package func IsBOSH() bool { // "/var/vcap/bosh" exists in BOSH deployed instance. _, err := os.Stat("/var/vcap/bosh") if osIsNotExist(err) { return false } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
dstRecords, err = globalDNSConfig.Get(dstBucket) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Send PutObject request to appropriate instance (in federated deployment) core, rerr := getRemoteInstanceClient(r, getHostFromSrv(dstRecords)) if rerr != nil { writeErrorResponse(ctx, w, toAPIError(ctx, rerr), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0)