Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 540 for fprintf (0.08 sec)

  1. cmd/ftp-server-driver.go

    // ftpDriver implements ftpDriver to store files in minio
    type ftpDriver struct {
    	endpoint string
    }
    
    // NewFTPDriver implements ftp.Driver interface
    func NewFTPDriver() ftp.Driver {
    	return &ftpDriver{endpoint: fmt.Sprintf("127.0.0.1:%s", globalMinioPort)}
    }
    
    func buildMinioPath(p string) string {
    	return strings.TrimPrefix(p, SlashSeparator)
    }
    
    func buildMinioDir(p string) string {
    	v := buildMinioPath(p)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  2. docs_src/custom_request_and_route/tutorial003.py

                duration = time.time() - before
                response.headers["X-Response-Time"] = str(duration)
                print(f"route duration: {duration}")
                print(f"route response: {response}")
                print(f"route response headers: {response.headers}")
                return response
    
            return custom_route_handler
    
    
    app = FastAPI()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 1K bytes
    - Viewed (0)
  3. internal/s3select/jstream/README.md

    ```go
    f, _ := os.Open("input.json")
    decoder := jstream.NewDecoder(f, 1) // extract JSON values at a depth level of 1
    for mv := range decoder.Stream() {
      fmt.Printf("%v\n ", mv.Value)
    }
    ```
    
    output:
    ```
    map[desc:RGB colors:[red green blue]]
    map[desc:CMYK colors:[cyan magenta yellow black]]
    ```
    
    likewise, increasing depth level to `3` yields:
    ```
    red
    green
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. scripts/docs.py

                if non_translatable_path.exists():
                    error_paths.append(non_translatable_path)
        if error_paths:
            print("Non-translated pages found, remove them:")
            for error_path in error_paths:
                print(error_path)
            raise typer.Abort()
        print("No non-translated pages found ✅")
    
    
    @app.command()
    def verify_docs():
        verify_readme()
        verify_config()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Oct 08 11:01:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  5. docs/debugging/xattr/main.go

    		for _, attr := range names {
    			value, err := getxattr(path, attr)
    			if err != nil {
    				data = append(data, []string{attr, errors.Unwrap(err).Error()})
    			} else {
    				data = append(data, []string{attr, fmt.Sprintf("%d", value)})
    			}
    		}
    		table.AppendBulk(data) // Add Bulk Data
    		table.Render()
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Dec 29 23:52:41 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. cmd/metacache-bucket_test.go

    	const elements = 50000
    	const paths = 100
    	if elements%paths != 0 {
    		b.Fatal("elements must be divisible by the number of paths")
    	}
    	var pathNames [paths]string
    	for i := range pathNames[:] {
    		pathNames[i] = fmt.Sprintf("prefix/%d", i)
    	}
    	for i := 0; i < elements; i++ {
    		bm.findCache(listPathOptions{
    			ID:           mustGetUUID(),
    			Bucket:       "",
    			BaseDir:      pathNames[i%paths],
    			Prefix:       "",
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Mar 25 23:29:45 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  7. docs/debugging/hash-set/main.go

    		}
    		for set, files := range distrib {
    			fmt.Println("Set:", set+1, "Objects:", len(files))
    			if !verbose {
    				continue
    			}
    			for _, s := range files {
    				fmt.Printf("\t%s\n", s)
    			}
    		}
    		os.Exit(0)
    	}
    
    	if object == "" {
    		log.Fatalln("object name is mandatory")
    	}
    
    	if shards != 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    		return true
    	}
    
    	// Only check ping when not closed.
    	if got := time.Since(time.Unix(0, atomic.LoadInt64(&m.LastPong))); got > m.clientPingInterval*2 {
    		m.respMu.Unlock()
    		if debugPrint {
    			fmt.Printf("Mux %d: last pong %v ago, disconnecting\n", m.MuxID, got)
    		}
    		m.addErrorNonBlockingClose(respHandler, ErrDisconnected)
    		return false
    	}
    
    	// Send new ping
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/rule_test.go

                                <Status>Enabled</Status>
    	                    </Rule>`,
    			expectedErr: errInvalidRuleDelMarkerExpiration,
    		},
    	}
    
    	for i, tc := range invalidTestCases {
    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var rule Rule
    			err := xml.Unmarshal([]byte(tc.inputXML), &rule)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err := rule.Validate(); err != tc.expectedErr {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. src/bytes/compare_test.go

    		if Compare(b1, b2[offset:]) != 0 {
    			b.Fatal("b1 != b2")
    		}
    	}
    	b.SetBytes(int64(len(b1)))
    }
    
    func BenchmarkCompareBytesBigUnaligned(b *testing.B) {
    	for i := 1; i < 8; i++ {
    		b.Run(fmt.Sprintf("offset=%d", i), func(b *testing.B) {
    			benchmarkCompareBytesBigUnaligned(b, i)
    		})
    	}
    }
    
    func benchmarkCompareBytesBigBothUnaligned(b *testing.B, offset int) {
    	b.StopTimer()
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
Back to top