- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 1,122 for contextos (0.12 sec)
-
guava-tests/test/com/google/common/collect/SetsFilterHashSetTest.java
import java.util.Set; public final class SetsFilterHashSetTest extends AbstractFilteredSetTest<Set<Integer>> { @Override Set<Integer> createUnfiltered(Iterable<Integer> contents) { return newHashSet(contents); } @Override Set<Integer> filter(Set<Integer> elements, Predicate<? super Integer> predicate) { return Sets.filter(elements, predicate); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 1.2K bytes - Viewed (0) -
cmd/utils.go
ep, err := unescapeGeneric(p, escapeFn) if err != nil { return p } return ep } func updateReqContext(ctx context.Context, objects ...ObjectV) context.Context { req := logger.GetReqInfo(ctx) if req != nil { req.Lock() defer req.Unlock() req.Objects = make([]logger.ObjectVersion, 0, len(objects)) for _, ov := range objects {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
cmd/metrics.go
tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if ok { tc.FuncName = "handler.MetricsLegacy" tc.ResponseRecorder.LogErrBody = true } mfs, err := gatherers.Gather() if err != nil { if len(mfs) == 0 { writeErrorResponseJSON(r.Context(), w, toAdminAPIErr(r.Context(), err), r.URL) return } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 16.6K bytes - Viewed (0) -
internal/mcontext/ctxt.go
package mcontext // Share a common context information between different // packages in github.com/minio/minio import ( xhttp "github.com/minio/minio/internal/http" ) // ContextTraceType represents the type of golang Context key type ContextTraceType string // ContextTraceKey is the key of TraceCtxt saved in a Golang context const ContextTraceKey = ContextTraceType("ctx-trace-info")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 06 17:27:26 UTC 2022 - 1.3K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
//go:build !race // +build !race // Tests in this file are not run under the `-race` flag as they are too slow // and cause context deadline errors. package cmd import ( "context" "fmt" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/pkg/v3/sync/errgroup" )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 4K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/UpgradePropertiesRuleSetup.java
} @Override public void execute(ViolationCheckContext context) { List<UpgradedProperty> currentUpgradedProperties = UpgradedProperties.parse(params.get(CURRENT_UPGRADED_PROPERTIES_KEY)); List<UpgradedProperty> baselineUpgradedProperties = UpgradedProperties.parse(params.get(BASELINE_UPGRADED_PROPERTIES_KEY)); context.putUserData(CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES, diff(
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Mon Aug 19 15:30:48 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/test-utils_test.go
globalIAMSys.Init(ctx, obj, globalEtcdClient, 2*time.Second) return obj, fsDirs[0], nil } func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) { return prepareErasure(ctx, 32) } func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) { fsDirs, err := getRandomDisks(nDisks) if err != nil { return nil, nil, err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
cmd/erasure-decode_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" crand "crypto/rand" "io" "math/rand" "testing" "github.com/dustin/go-humanize" ) func (a badDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) { return 0, errFaultyDisk }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 21.1K bytes - Viewed (0) -
cmd/metacache-bucket.go
cachesRoot map[string][]string `msg:"-"` // Internal state mu sync.RWMutex `msg:"-"` updated bool `msg:"-"` } type deleteAllStorager interface { deleteAll(ctx context.Context, bucket, prefix string) } // newBucketMetacache creates a new bucketMetacache. // Optionally remove all existing caches. func newBucketMetacache(bucket string, cleanup bool) *bucketMetacache { if cleanup {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
package cmd import ( "bytes" "context" "fmt" "os" "path/filepath" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" ) // Returns the latest updated FileInfo files and error in case of failure. func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0)