- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 406 for chen (0.16 sec)
-
cmd/storage-interface.go
// For that individual storage API calls will fail properly. The purpose // of this function is to know if the "drive" has "format.json" or not // if it has a "format.json" then is it correct "format.json" or not. IsOnline() bool // Returns the last time this disk (re)-connected LastConn() time.Time // Indicates if disk is local or not. IsLocal() bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/erasure.go
} // Put all buckets into channel. bucketCh := make(chan BucketInfo, len(buckets)) // Shuffle buckets to ensure total randomness of buckets, being scanned. // Otherwise same set of buckets get scanned across erasure sets always. // at any given point in time. This allows different buckets to be scanned // in different order per erasure set, this wider spread is needed when
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
src/archive/tar/reader.go
// an ASCII string, then we fallback on the pre-Go1.8 behavior // of treating these fields as the USTAR prefix field. // // Note that this will not use the fallback logic for all possible // files generated by a pre-Go1.8 toolchain. If the generated file // happened to have a prefix field that parses as valid // atime and ctime fields (e.g., when they are valid octal strings),
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
internal/kms/kes.go
// parameters - like KMS endpoints or authentication // credentials. type Config struct { // Endpoints contains a list of KMS server // HTTP endpoints. Endpoints []string // DefaultKeyID is the key ID used when // no explicit key ID is specified for // a cryptographic operation. DefaultKeyID string // APIKey is an credential provided by env. var. // to authenticate to a KES server. Either an
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{} readerWg sync.WaitGroup } // Read - reads single record.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/object-api-interface.go
DeletePrefixObject bool // set true when object's erasure set is resolvable by object name (using getHashedSetIndex) Speedtest bool // object call specifically meant for SpeedTest code, set to 'true' when invoked by SpeedtestHandler. // Use the maximum parity (N/2), used when saving server configuration files MaxParity bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/metacache-set.go
// Caller should close the channel when done. // The returned function will return the results once there is enough or input is closed, // or the context is canceled. func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) { resultsDone := make(chan metaCacheEntriesSorted) // Copy so we can mutate resCh := resultsDone
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/notification.go
} consolidatedReport.BucketStats[opts] = d } } return consolidatedReport } func (sys *NotificationSys) collectPeerMetrics(ctx context.Context, peerChannels []<-chan MetricV2, g *errgroup.Group) <-chan MetricV2 { ch := make(chan MetricV2) var wg sync.WaitGroup for index, err := range g.Wait() { if err != nil { if sys.peerClients[index] != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
quorum := len(restClnts) - tolerance if !isReadLock { // In situations for write locks, as a special case // to avoid split brains we make sure to acquire // quorum + 1 when tolerance is exactly half of the // total locker clients. if quorum == tolerance { quorum++ } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0)