- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for ssdopts (0.19 sec)
-
istioctl/pkg/multixds/gather.go
return nil, ControlPlaneNotFoundError{istioNamespace} } responses := []*discovery.DiscoveryResponse{} xdsOpts := clioptions.CentralControlPlaneOptions{ XDSSAN: makeSan(istioNamespace, kubeClient.Revision()), CertDir: centralOpts.CertDir, Timeout: centralOpts.Timeout, } dialOpts, err := xds.DialOptions(xdsOpts, istioNamespace, tokenServiceAccount, kubeClient) if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 13.6K bytes - Viewed (0) -
src/database/sql/ctxutil.go
func ctxDriverBegin(ctx context.Context, opts *TxOptions, ci driver.Conn) (driver.Tx, error) { if ciCtx, is := ci.(driver.ConnBeginTx); is { dopts := driver.TxOptions{} if opts != nil { dopts.Isolation = driver.IsolationLevel(opts.Isolation) dopts.ReadOnly = opts.ReadOnly } return ciCtx.BeginTx(ctx, dopts) } if opts != nil { // Check the transaction level. If the transaction level is non-default
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 02 12:57:37 UTC 2019 - 3.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
return } switch msgp.UnsafeString(field) { case "startTs": z.StartTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "StartTime") return } case "stopTs": z.EndTime, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "EndTime") return } case "status": { var zb0002 uint8 zb0002, err = dc.ReadUint8()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 26.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
workloadEntriesSchemas := collection.NewSchemasBuilder(). MustAdd(collections.WorkloadEntry). Build() crdOpts := crdclient.Option{Revision: revision, DomainSuffix: opts.DomainSuffix, Identifier: "mc-workload-entry-controller"} return crdclient.NewForSchemas(client, crdOpts, workloadEntriesSchemas)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/cmd.go
} if out, err := protomarshal.ToYAML(proxyConfig); err != nil { log.Infof("Failed to serialize to YAML: %v", err) } else { log.Infof("Effective config: %s", out) } secOpts, err := options.NewSecurityOptions(proxyConfig, proxyArgs.StsPort, proxyArgs.TokenManagerPlugin) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/istio-agent/agent_test.go
dir := mktemp() copyCerts(t, dir) secOpts := &security.Options{} secOpts.RootCertFilePath = filepath.Join(dir, "/root-cert.pem") secOpts.CertChainFilePath = filepath.Join(dir, "/cert-chain.pem") secOpts.KeyFilePath = filepath.Join(dir, "/key.pem") secretCache, err := cache.NewSecretManagerClient(nil, secOpts) if err != nil { t.Fatal(err) } defer secretCache.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/speedtest.go
case <-ctx.Done(): return } } for { select { case <-ctx.Done(): // If the client got disconnected stop the speedtest. return default: } sopts := speedTestOpts{ objectSize: opts.objectSize, concurrency: concurrency, duration: opts.duration, storageClass: opts.storageClass, bucketName: opts.bucketName,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
return true, nil } rsOpts.NewSize = pvSpecCap rsOpts.OldSize = pvcStatusCap resizeOp := nodeResizeOperationOpts{ vmt: volumeToMount, pvc: pvc, pv: pv, pluginResizeOpts: rsOpts, volumePlugin: expandablePlugin, actualStateOfWorld: actualStateOfWorld, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
platforms/software/ivy/src/test/groovy/org/gradle/api/publish/ivy/internal/publication/DefaultIvyPublicationTest.groovy
then: publication.artifacts.empty publication.publishableArtifacts.files.files == [ivyDescriptorFile] as Set !publication.descriptor.dependencies.isPresent() } def "adopts configurations, artifacts and publishableFiles from added component"() { given: def publication = createPublication() def artifact = Mock(PublishArtifact) def ivyArtifact = createArtifact()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 19 01:33:41 UTC 2023 - 15.3K bytes - Viewed (0) -
platforms/software/maven/src/test/groovy/org/gradle/api/publish/maven/internal/publication/DefaultMavenPublicationTest.groovy
then: publication.publishableArtifacts.files.files == [pomFile, gradleMetadataFile, artifactFile] as Set publication.artifacts == [mavenArtifact] as Set } def "adopts module dependency from added component"() { given: def publication = createPublication() def moduleDependency = Mock(ExternalDependency) def artifact = Mock(DependencyArtifact) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 19 01:33:41 UTC 2023 - 24.8K bytes - Viewed (0)