- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 166 for vnopts (0.18 sec)
-
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) -
istioctl/pkg/tag/generate.go
func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) { // abort if there exists a revision with the target tag name revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag) if err != nil { return "", err } if !opts.Generate && !opts.Overwrite && len(revWebhookCollisions) > 0 && opts.Tag != DefaultRevisionName {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/storage-interface.go
WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/metacache-set.go
} else { werr = d.WalkDir(ctx, WalkDirOptions{ Limit: opts.perDiskLimit, Bucket: opts.bucket, BaseDir: opts.path, Recursive: opts.recursive, ReportNotFound: opts.reportNotFound, FilterPrefix: opts.filterPrefix, ForwardTo: opts.forwardTo, }, w) } // fallback only when set. for {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
TF_Status* status = TF_NewStatus(); TFE_ContextOptions* opts = TFE_NewContextOptions(); TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(/*enable=*/true)); TFE_ContextOptionsSetDevicePlacementPolicy(opts, TFE_DEVICE_PLACEMENT_SILENT); TFE_Context* ctx = TFE_NewContext(opts, status); EXPECT_EQ(TF_GetCode(status), TF_OK) << TF_Message(status); TFE_DeleteContextOptions(opts);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 09:49:45 GMT 2024 - 23.5K bytes - Viewed (0) -
cmd/peer-rest-client.go
func (client *peerRESTClient) SpeedTest(ctx context.Context, opts speedTestOpts) (SpeedTestResult, error) { values := make(url.Values) values.Set(peerRESTSize, strconv.Itoa(opts.objectSize)) values.Set(peerRESTConcurrent, strconv.Itoa(opts.concurrency)) values.Set(peerRESTDuration, opts.duration.String()) values.Set(peerRESTStorageClass, opts.storageClass) values.Set(peerRESTBucket, opts.bucketName)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
istioctl/pkg/version/version.go
) func NewVersionCommand(ctx cli.Context) *cobra.Command { profileCmd := mesh.ProfileCmd(ctx) var opts clioptions.ControlPlaneOptions versionCmd := istioVersion.CobraCommandWithOptions(istioVersion.CobraOptions{ GetRemoteVersion: getRemoteInfoWrapper(ctx, &profileCmd, &opts), GetProxyVersions: getProxyInfoWrapper(ctx, &opts), }) opts.AttachControlPlaneFlags(versionCmd) versionCmd.Flags().VisitAll(func(flag *pflag.Flag) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.3K bytes - Viewed (0) -
cmd/healthcheck-handler.go
return } ctx, cancel := context.WithTimeout(ctx, globalAPIConfig.getClusterDeadline()) defer cancel() opts := HealthOptions{ Maintenance: r.Form.Get("maintenance") == "true", DeploymentType: r.Form.Get("deployment-type"), } result := objLayer.Health(ctx, opts) w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) (err error) { if err := d.calcError(); err != nil { return err } return d.disk.UpdateMetadata(ctx, volume, path, fi, opts) } func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) { if err := d.calcError(); err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} } func (m *Monitor) init(opts BucketOptions) { m.mlock.Lock() defer m.mlock.Unlock() _, ok := m.bucketsMeasurement[opts] if !ok { m.bucketsMeasurement[opts] = newBucketMeasurement(time.Now()) } } // DeleteBucket deletes monitoring the 'bucket' func (m *Monitor) DeleteBucket(bucket string) { m.tlock.Lock() for opts := range m.bucketsThrottle { if opts.Name == bucket {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0)