- Sort Score
- Result 10 results
- Languages All
Results 341 - 350 of 714 for Contexto (0.09 sec)
-
docs/debugging/s3-verify/main.go
Prefix: sourcePrefix, } topts := minio.ListObjectsOptions{ Recursive: true, Prefix: targetPrefix, } srcCh := sclnt.ListObjects(context.Background(), sourceBucket, sopts) tgtCh := tclnt.ListObjects(context.Background(), targetBucket, topts) srcCtnt, srcOk := nextObject(srcCh) tgtCtnt, tgtOk := nextObject(tgtCh) var srcEOF, tgtEOF bool srcSha256 := sha256.New()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jun 22 15:12:47 UTC 2022 - 8.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
) // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics. func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds))) pluginAuthNMetrics := globalAuthNPlugin.Metrics()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/erasure-utils.go
size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset. func writeDataBlocks(ctx context.Context, dst io.Writer, enBlocks [][]byte, dataBlocks int, offset int64, length int64) (int64, error) { // Offset and out size cannot be negative. if offset < 0 || length < 0 { return 0, errUnexpected }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
return subToken, nodeIndex } func proxyRequestByToken(ctx context.Context, w http.ResponseWriter, r *http.Request, token string) (string, bool) { subToken, nodeIndex := parseRequestToken(token) if nodeIndex > 0 { return subToken, proxyRequestByNodeIndex(ctx, w, r, nodeIndex) } return subToken, false } func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/config-migrate.go
} // Load config from backend func Load(configFile string, data interface{}) (quick.Config, error) { return quick.LoadConfig(configFile, globalEtcdClient, data) } func readConfigWithoutMigrate(ctx context.Context, objAPI ObjectLayer) (config.Config, error) { // Construct path to config.json for the given bucket. configFile := path.Join(minioConfigPrefix, minioConfigFile) configFiles := []string{ getConfigFile(),
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/metrics-v3-system-cpu.go
sysCPUSystemMD = NewGaugeMD(sysCPUSystem, "CPU system time") sysCPUUserMD = NewGaugeMD(sysCPUUser, "CPU user time") ) // loadCPUMetrics - `MetricsLoaderFn` for system CPU metrics. func loadCPUMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { cpuMetrics, _ := c.cpuMetrics.Get() if cpuMetrics.LoadStat != nil { m.Set(sysCPULoad, cpuMetrics.LoadStat.Load1)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jun 20 17:55:03 UTC 2024 - 3K bytes - Viewed (0) -
internal/hash/reader.go
// does not send more content than specified size. func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) { return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil) } func newReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64, disableMD5 bool, forceMD5 []byte) (*Reader, error) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/local-locker_test.go
package cmd import ( "context" "encoding/hex" "fmt" "math/rand" "testing" "time" "github.com/google/uuid" "github.com/minio/minio/internal/dsync" ) func TestLocalLockerExpire(t *testing.T) { wResources := make([]string, 1000) rResources := make([]string, 1000) quorum := 0 l := newLocker() ctx := context.Background() for i := range wResources {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 11.9K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
u.RawQuery = q.Encode() return u.String(), nil } // Put - Adds DNS entries into operator webhook server func (c *OperatorDNS) Put(bucket string) error { ctx, cancel := context.WithTimeout(context.Background(), defaultOperatorContextTimeout) defer cancel() e, err := c.endpoint(bucket, false) if err != nil { return newError(bucket, err) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 6.6K bytes - Viewed (0) -
api/go1.15.txt
pkg crypto/rsa, method (*PublicKey) Equal(crypto.PublicKey) bool pkg crypto/tls, method (*Dialer) Dial(string, string) (net.Conn, error) pkg crypto/tls, method (*Dialer) DialContext(context.Context, string, string) (net.Conn, error) pkg crypto/tls, method (ClientAuthType) String() string pkg crypto/tls, method (CurveID) String() string pkg crypto/tls, method (SignatureScheme) String() string
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Fri Jul 17 02:15:01 UTC 2020 - 7.6K bytes - Viewed (0)