- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for project (0.48 sec)
-
istioctl/pkg/xds/google.go
) type meshAuthCredentials struct { k8sCreds credentials.PerRPCCredentials gcpCreds credentials.PerRPCCredentials project string } func (c *meshAuthCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error) { ret := map[string]string{ "x-goog-user-project": c.project, } if err := updateAuthHdrs(ctx, uri, "k8s", c.k8sCreds, ret, "x-mesh-authorization"); err != nil { return nil, err }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
return err } reason := googleAPIErr.Errors[0].Reason message := googleAPIErr.Errors[0].Message switch reason { case "required": // Anonymous users does not have storage.xyz access to project 123. fallthrough case "keyInvalid": fallthrough case "forbidden": err = PrefixAccessDenied{ Bucket: bucket, Object: object, } case "invalid": err = BucketNameInvalid{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
istioctl/pkg/clioptions/central.go
InsecureSkipVerify bool // XDSSAN is the expected Subject Alternative Name of the XDS server XDSSAN string // Plaintext forces plain text communication (for talking to port 15010) Plaintext bool // GCP project number or ID to use for XDS calls, if any. GCPProject string // Istiod address. For MCP may be different than Xds. IstiodAddr string } // AttachControlPlaneFlags attaches control-plane flags to a Cobra command.
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 3.2K bytes - Viewed (0) -
istioctl/pkg/multixds/google.go
ret := &xdsAddr{host: u.Host} if !strings.HasSuffix(ret.host, ":443") { ret.host += ":443" } const projSeg = "/projects/" i := strings.Index(u.Path, projSeg) if i == -1 { return nil, fmt.Errorf("webhook URL %s doesn't contain the projects segment", u) } i += len(projSeg) j := strings.IndexByte(u.Path[i:], '/') if j == -1 { return nil, fmt.Errorf("webhook URL %s is malformed", u) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 1.5K bytes - Viewed (1) -
cmd/sts-handlers_test.go
"projecta", "projectb" ] } } } ] }` policyProjectsMap = map[string]string{ // grants access to bucket `projecta` if user is in group `projecta` "projecta": policyProjectA, // grants access to bucket `projectb` if user is in group `projectb`
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
tests/associations_test.go
t.Errorf("Failed, got error: %v", err) } if DB.First(&Coupon{}, "id = ?", coupon.ID).Error != nil { t.Errorf("Failed to query saved coupon") } if DB.First(&CouponProduct{}, "coupon_id = ? AND product_id = ?", coupon.ID, "full-save-association-product1").Error != nil { t.Errorf("Failed to query saved association") } orders := []Order{{Num: "order1", Coupon: coupon}, {Num: "order2", Coupon: coupon}}
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Wed Feb 08 08:29:09 GMT 2023 - 10.9K bytes - Viewed (0) -
cmd/iam-object-store.go
xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/kms" "github.com/puzpuzpuz/xsync/v3" ) // IAMObjectStore implements IAMStorageAPI type IAMObjectStore struct { // Protect access to storage within the current server. sync.RWMutex *iamCache cachedIAMListing atomic.Value usersSysType UsersSysType objAPI ObjectLayer }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/update-notifier.go
} // Return the nicely colored and formatted update message. return colorizeUpdateMessage(downloadURL, newerThan) } // colorizeUpdateMessage - inspired from Yeoman project npm package https://github.com/yeoman/update-notifier func colorizeUpdateMessage(updateString string, newerThan string) string { msgLine1Fmt := " You are running an older version of MinIO released %s " msgLine2Fmt := " Update: %s "
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 3.6K bytes - Viewed (0) -
internal/dsync/utils.go
package dsync import ( "math/rand" "time" ) func backoffWait(min, unit, cap time.Duration) func(*rand.Rand, uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(r *rand.Rand, attempt uint) time.Duration { sleep := min sleep += unit * time.Duration(attempt) if sleep > cap { sleep = cap
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat May 13 15:42:21 GMT 2023 - 1.2K bytes - Viewed (0) -
internal/rest/client.go
func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt))
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0)