- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 168 for could (0.14 sec)
-
istioctl/pkg/writer/pilot/status.go
err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) } meta, err := model.ParseMetadata(clientConfig.GetNode().GetMetadata()) if err != nil { return nil, nil, fmt.Errorf("could not parse node metadata: %w", err) } if s.Namespace != "" && meta.Namespace != s.Namespace { continue }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
expected: 8, errMsg: nil, isValid: true, }, { version: versionInvalid1, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid1.GitVersion), isValid: false, }, { version: versionInvalid2, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid2.GitVersion), isValid: false, }, } for i, c := range cases {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
if err := os.MkdirAll(dirName, os.ModePerm); err != nil { return fmt.Errorf("could not create directory %s; %s", outputDir, err) } } fname := filepath.Join(dirName, componentName) + ".yaml" l.LogAndPrintf("Writing manifest to %s", fname) if !dryRun { if err := os.WriteFile(fname, []byte(ym), 0o644); err != nil { return fmt.Errorf("could not write manifest config; %s", err) } }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
CertDir: opts.CertDir, InsecureSkipVerify: opts.InsecureSkipVerify, XDSSAN: opts.XDSSAN, GrpcOpts: grpcOpts, }, }, nil) if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/sts-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrSTSInvalidClientGrantsToken: { Code: "InvalidClientGrantsToken", Description: "The client grants token that was passed could not be validated by MinIO.", HTTPStatusCode: http.StatusBadRequest, }, ErrSTSMalformedPolicyDocument: { Code: "MalformedPolicyDocument",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/kms/kms.go
// is specified. It is empty if the KMS does not support // a default key. DefaultKey string // Details provides more details about the KMS endpoint status. // including uptime, version and available CPUs. // Could be more in future. Details kes.State } // DEK is a data encryption key. It consists of a // plaintext-ciphertext pair and the ID of the key // used to generate the ciphertext. //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 4.6K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
cmd.PersistentFlags().StringVar(&args.common.watchedNamespaces, "watchedNamespaces", constants.IstioSystemNamespace, "The namespaces the operator controller watches, could be namespace list separated by comma, eg. 'ns1,ns2'") cmd.PersistentFlags().StringVarP(&args.common.manifestsPath, "charts", "", "", ChartsDeprecatedStr)
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K 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 Apr 21 09:35:09 GMT 2024 - Last Modified: Tue Feb 06 02:54:40 GMT 2024 - 5.5K bytes - Viewed (0) -
docs/sts/web-identity.go
Expiry: int(oauth2Token.Expiry.Sub(time.Now().UTC()).Seconds()), }, nil } } sts, err := credentials.NewSTSWebIdentity(stsEndpoint, getWebTokenExpiry) if err != nil { log.Println(fmt.Errorf("Could not get STS credentials: %s", err)) http.Error(w, err.Error(), http.StatusBadRequest) return } opts := &minio.Options{ Creds: sts, BucketLookup: minio.BucketLookupAuto, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
cmd/peer-s3-client.go
} } } // loop through buckets and see if some with lost quorum // these could be stale buckets lying around, queue a heal // of such a bucket. This is needed here as we identify such // buckets here while listing buckets. As part of regular // globalBucketMetadataSys.Init() call would get a valid // buckets only and not the quourum lost ones like this, so // explicit call
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0)