- Sort Score
- Result 10 results
- Languages All
Results 1201 - 1210 of 1,713 for Fake (0.04 sec)
-
docs/bigdata/README.md
``` sudo pip install yq alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"' ```
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
src/bufio/scan_test.go
} if c != 0 { t.Fatalf("stopped with %d left to process", c) } } // Make sure we can read a huge token if a big enough buffer is provided. func TestHugeBuffer(t *testing.T) { text := strings.Repeat("x", 2*MaxScanTokenSize) s := NewScanner(strings.NewReader(text + "\n")) s.Buffer(make([]byte, 100), 3*MaxScanTokenSize) for s.Scan() { token := s.Text() if token != text {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Sep 22 16:22:42 UTC 2023 - 14.3K bytes - Viewed (0) -
common-protos/k8s.io/api/apps/v1/generated.proto
// +optional optional int32 revisionHistoryLimit = 6; // Indicates that the deployment is paused. // +optional optional bool paused = 7; // The maximum time in seconds for a deployment to make progress before it // is considered to be failed. The deployment controller will continue to // process failed deployments and a condition with a ProgressDeadlineExceeded
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/xl-storage-free-version_test.go
NumVersions: 1, SuccessorModTime: time.Time{}, } fi.SetTierFreeVersionID(uuid.New().String()) // Test if free version is created when SkipTier wasn't set on fi j := xlMetaV2Object{} j.MetaSys = make(map[string][]byte) j.MetaSys[metaTierName] = []byte("WARM-1") j.MetaSys[metaTierStatus] = []byte(lifecycle.TransitionComplete) j.MetaSys[metaTierObjName] = []byte("obj-1") if _, ok := j.InitFreeVersion(fi); !ok {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Mar 02 05:11:03 UTC 2024 - 7.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
fullBuffer.read(bytesOut, lastFrame.start + length) outFrames.add(OutFrame(lastFrame.sequence, lastFrame.start, true)) return writer } fun takeFrame(): InFrame = inFrames.take() fun play() { check(serverSocket == null) serverSocket = ServerSocket() serverSocket!!.reuseAddress = false serverSocket!!.bind(InetSocketAddress("localhost", 0), 1)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.7K bytes - Viewed (0) -
android/guava/pom.xml
</dependencies> <build> <resources> <resource> <directory>..</directory> <includes> <include>LICENSE</include> <!-- copied from the parent pom because I couldn't figure out a way to make combine.children="append" work --> <include>proguard/*</include> </includes> <targetPath>META-INF</targetPath> </resource> </resources> <plugins> <plugin>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jul 24 18:53:31 UTC 2024 - 9.1K bytes - Viewed (0) -
cmd/main.go
// Main main for minio server. func Main(args []string) { // Set the minio app name. appName := filepath.Base(args[0]) if debugNoExit { freeze := func(_ int) { // Infinite blocking op <-make(chan struct{}) } // Override the logger os.Exit() logger.ExitFunc = freeze defer func() { if err := recover(); err != nil { fmt.Println("panic:", err) fmt.Println("")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 30 22:59:48 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/bitrot-streaming.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
if err = validateTransitionTier(bucketLifecycle); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Create a map of updated set of rules in request updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules)) for _, rule := range bucketLifecycle.Rules { updatedRules[rule.ID] = rule } // Get list of rules for the bucket from disk
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
it := gcs.client.Bucket(gcs.Bucket).Objects(ctx, &storage.Query{ Delimiter: "/", Prefix: gcs.Prefix, Versions: false, }) pager := iterator.NewPager(it, 1, "") gcsObjects := make([]*storage.ObjectAttrs, 0) _, err := pager.NextPage(&gcsObjects) if err != nil { return false, gcsToObjectError(err, gcs.Bucket, gcs.Prefix) } if len(gcsObjects) > 0 { return true, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 6.1K bytes - Viewed (0)