- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 173 for vnopts (0.87 sec)
-
cmd/object-handlers.go
} return nil } var opts untarOptions opts.ignoreDirs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreDirs), "true") opts.ignoreErrs = strings.EqualFold(r.Header.Get(xhttp.MinIOSnowballIgnoreErrors), "true") opts.prefixAll = r.Header.Get(xhttp.MinIOSnowballPrefix) if opts.prefixAll != "" { opts.prefixAll = trimLeadingSlash(pathJoin(opts.prefixAll, slashSeparator)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
defaultJaegerPort = 16686 defaultZipkinPort = 9411 defaultSkywalkingPort = 8080 ) // port-forward to Istio System Prometheus; open browser func promDashCmd(ctx cli.Context) *cobra.Command { var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "prometheus", Short: "Open Prometheus web UI", Long: `Open Istio's Prometheus dashboard`, Example: ` istioctl dashboard prometheus
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
l.LogAndFatal(err) } } if err := applyManifest(kubeClient, client, mstr, name.IstioOperatorComponentName, opts, iop, l); err != nil { l.LogAndFatal(err) } if customResource != "" { if err := applyManifest(kubeClient, client, customResource, name.IstioOperatorComponentName, opts, iop, l); err != nil { l.LogAndFatal(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/clusters.go
func ClustersCommand(ctx cli.Context) *cobra.Command { var opts clioptions.ControlPlaneOptions cmd := &cobra.Command{ Use: "remote-clusters", Short: "Lists the remote clusters each istiod instance is connected to.", RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
func testObjectNewMultipartUpload(obj ObjectLayer, instanceType string, t TestErrHandler) { bucket := "minio-bucket" object := "minio-object" opts := ObjectOptions{} _, err := obj.NewMultipartUpload(context.Background(), "--", object, opts) if err == nil { t.Fatalf("%s: Expected to fail since bucket name is invalid.", instanceType) } errMsg := "Bucket not found: minio-bucket"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
tests/connpool_test.go
// // func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) { // return c.db.BeginTx(ctx, opts) // } // // You should use BeginTx returned gorm.Tx which could wrap *sql.Tx then you can record all queries. func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (gorm.ConnPool, error) { tx, err := c.db.BeginTx(ctx, opts) if err != nil { return nil, err }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Feb 06 02:54:40 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/tier-sweeper.go
// overwritten or deleted depending on bucket versioning status. func (os *objSweeper) GetOpts() ObjectOptions { opts := ObjectOptions{ VersionID: os.VersionID, Versioned: os.Versioned, VersionSuspended: os.Suspended, } if os.Suspended && os.VersionID == "" { opts.VersionID = nullVersionID } return opts } // SetTransitionState sets ILM transition related information from given info.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
cmd/iam-store.go
return updatedAt, auth.ErrInvalidSecretKeyLength } cr.SecretKey = opts.secretKey } if opts.name != "" { cr.Name = opts.name } if opts.description != "" { cr.Description = opts.description } if opts.expiration != nil { expirationInUTC := opts.expiration.UTC() if err := validateSvcExpirationInUTC(expirationInUTC); err != nil { return updatedAt, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/admin-bucket-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } opts := extractReplicateDiffOpts(r.Form) if opts.ARN != "" { tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, opts.ARN) if tgt.Empty() { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, fmt.Errorf("invalid arn : '%s'", opts.ARN)), 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) -
internal/grid/benchmark_test.go
// This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) b.Run("rpc", func(b *testing.B) { for par := 1; par <= 32; par *= 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0)