- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 166 for qsub (0.12 sec)
-
internal/grid/msg.go
if len(h) < 32 { return nil, nil, fmt.Errorf("want subroute len 32, got %v", len(h)) } subID := (*[32]byte)(h[len(h)-32:]) sub = (*subHandlerID)(subID) // Add if more modifications to h is needed h = h[:len(h)-32] } return sub, h, nil } // setZeroPayloadFlag will clear or set the FlagPayloadIsZero if // m.Payload is length 0, but not nil. func (m *message) setZeroPayloadFlag() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/handlers/proxy.go
// e.g. Forwarded: for=192.0.2.60;proto=https;by=203.0.113.43 forwarded = http.CanonicalHeaderKey("Forwarded") // Allows for a sub-match of the first value after 'for=' to the next // comma, semi-colon or space. The match is case-insensitive. forRegex = regexp.MustCompile(`(?i)(?:for=)([^(;|,| )]+)(.*)`) // Allows for a sub-match for the first instance of scheme (http|https) // prefixed by 'proto='. The match is case-insensitive.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/mountinfo/mountinfo_windows.go
package mountinfo import ( "path/filepath" "sync" "golang.org/x/sys/windows" ) // CheckCrossDevice - check if any input path has multiple sub-mounts. // this is a dummy function and returns nil for now. func CheckCrossDevice(paths []string) error { return nil } // mountPointCache contains results of IsLikelyMountPoint var mountPointCache sync.Map
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 2K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
mp := []mountInfo{ {"/dev/2", "/path/to/1/2", "type2", []string{"flags"}, "2", "2"}, } msg := fmt.Sprintf("Cross-device mounts detected on path (/path/to/1) at following locations %s. Export path should not have any sub-mounts, refusing to start.", mp) if err.Error() != msg { t.Fatalf("Expected msg %s, got %s", msg, err) } } // Failure case when input path is not absolute. { absPaths := []string{"."}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
cmd/sts-datatypes.go
// the user and the application that acquired the WebIdentityToken (pairwise identifier). // For OpenID Connect ID tokens, this field contains the value returned by the identity // provider as the token's sub (Subject) claim. SubjectFromWebIdentityToken string `xml:",omitempty"` } // AssumeRoleWithClientGrantsResponse contains the result of successful AssumeRoleWithClientGrants request.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 9.9K bytes - Viewed (0) -
docs/iam/identity-management-plugin.md
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 27 00:58:09 GMT 2022 - 4.2K bytes - Viewed (0) -
internal/grid/grid_test.go
register := func(manager *Manager) { errFatal(handler.Register(manager, func(ctx context.Context, pp *testRequest, in <-chan *testRequest, out chan<- *testResponse) *RemoteErr { sub := GetSubroute(ctx) if sub != "subroute/1" { t.Fatal("expected subroute/1, got", sub) } n := 0 for i := range in { if n > payloads { panic("too many requests") } // t.Log("Got request:", *i)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
docs/sts/web-identity.go
if !oauth2Token.Valid() { return nil, errors.New("invalid token") } return &credentials.WebIdentityToken{ Token: oauth2Token.Extra("id_token").(string), Expiry: int(oauth2Token.Expiry.Sub(time.Now().UTC()).Seconds()), }, nil } } sts, err := credentials.NewSTSWebIdentity(stsEndpoint, getWebTokenExpiry) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 19 09:13:33 GMT 2023 - 7.8K bytes - Viewed (3) -
cmd/common-main.go
var downloadURL string if lrTime.After(currentReleaseTime) { older = lrTime.Sub(currentReleaseTime) downloadURL = getDownloadURL(releaseTimeToReleaseTag(lrTime)) } updateMsg := prepareUpdateMessage(downloadURL, older) if updateMsg == "" { return } logger.Info(prepareUpdateMessage("Run `mc admin update ALIAS`", lrTime.Sub(currentReleaseTime))) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
helm-releases/minio-3.5.0.tgz
standard storage class. ## If the PV uses a different storage class, specify that here. storageClass: "" VolumeName: "" accessMode: ReadWriteOnce size: 500Gi ## If subPath is set mount a sub folder of a volume instead of the root of the volume. ## This is especially handy for volume plugins that don't natively support sub mounting (like glusterfs). ## subPath: "" ## Expose the MinIO service to be accessed from outside the cluster (LoadBalancer service). ## or access it from within the cluster (ClusterIP...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 02 00:16:41 GMT 2022 - 15.2K bytes - Viewed (0)