Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1201 - 1210 of 1,713 for Fake (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. cmd/bitrot-streaming.go

    		data:       data,
    		volume:     volume,
    		filePath:   filePath,
    		tillOffset: ceilFrac(tillOffset, shardSize)*int64(h.Size()) + tillOffset,
    		h:          h,
    		shardSize:  shardSize,
    		hashBytes:  make([]byte, h.Size()),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top