- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 135 for bean (0.14 sec)
-
internal/jwt/parser.go
// // This method parses the token but doesn't validate the signature. It's only // ever useful in cases where you know the signature is valid (because it has // been checked previously in the stack) and you want to extract values from // it. func ParseUnverifiedStandardClaims(token []byte, claims *StandardClaims, buf []byte) (*SigningMethodHMAC, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
cmd/untar.go
}, } type untarOptions struct { ignoreDirs bool ignoreErrs bool prefixAll string } // disconnectReader will ensure that no reads can take place on // the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock() defer d.mu.Unlock() if d.r != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/object-api-errors.go
} // AllAccessDisabled All access to this object has been disabled type AllAccessDisabled GenericError // Error returns string an error formatted as the given text. func (e AllAccessDisabled) Error() string { return "All access to this object has been disabled" } // IncompleteBody You did not provide the number of bytes specified by the Content-Length HTTP header.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
cmd/tier-journal.go
jd.WalkEntries(ctx, deleteObjectFromRemoteTier) case <-ctx.Done(): jd.Close() return } } } func (jd *tierDiskJournal) addEntry(je jentry) error { // Open journal if it hasn't been err := jd.Open() if err != nil { return err } b, err := je.MarshalMsg(nil) if err != nil { return err } jd.Lock() defer jd.Unlock() _, err = jd.file.Write(b)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
istioctl/cmd/root.go
orig.HelpFunc()(cmd, args) }) } func ConfigureLogging(_ *cobra.Command, _ []string) error { return log.Configure(root.LoggingOptions) } // seeExperimentalCmd is used for commands that have been around for a release but not graduated from // Other alternative // for graduatedCmd see https://github.com/istio/istio/pull/26408 // for softGraduatedCmd see https://github.com/istio/istio/pull/26563
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
src/builtin/builtin.go
// bidirectional or send-only. It should be executed only by the sender, // never the receiver, and has the effect of shutting down the channel after // the last sent value is received. After the last value has been received // from a closed channel c, any receive from c will succeed without // blocking, returning the zero value for the channel element. The form // // x, ok := <-c //
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
enabled = false } } // No need to continue loading if the config is not enabled. if !enabled { continue } // Validate that client ID has not been duplicately specified. if seenClientIDs.Contains(p.ClientID) { return c, config.Errorf("Client ID %s is present with multiple OpenID configurations", p.ClientID) } seenClientIDs.Add(p.ClientID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusNotFound, }, ErrNoSuchUpload: { Code: "NoSuchUpload", Description: "The specified multipart upload does not exist. The upload ID may be invalid, or the upload may have been aborted or completed.", HTTPStatusCode: http.StatusNotFound, }, ErrInvalidVersionID: { Code: "InvalidArgument", Description: "Invalid version id specified",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
internal/grid/types.go
sz := msgp.ArrayHeaderSize for _, v := range j.val { sz += v.Msgsize() } return sz } // Value returns the underlying value. // Regular append mechanics should be observed. // If no value has been set yet, a new array is created. func (j *Array[T]) Value() []T { if j.val == nil { j.val = j.p.newA(10) } return j.val } // Append a value to the underlying array.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
return err } func (z *erasureServerPools) checkIfRebalanceDone(poolIdx int) bool { z.rebalMu.Lock() defer z.rebalMu.Unlock() // check if enough objects have been rebalanced r := z.rebalMeta poolStats := r.PoolStats[poolIdx] if poolStats.Info.Status == rebalCompleted { return true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0)