Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 681 - 690 of 1,019 for Var (0.01 seconds)

  1. internal/s3select/jstream/scanner.go

    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  2. cmd/erasure-healing-common_test.go

    		return FileInfo{}, reducedErr
    	}
    
    	// List all the file commit ids from parts metadata.
    	modTimes := listObjectModtimes(partsMetadata, errs)
    
    	// Count all latest updated FileInfo values
    	var count int
    	var latestFileInfo FileInfo
    
    	// Reduce list of UUIDs to a single common value - i.e. the last updated Time
    	modTime := commonTime(modTimes, expectedRQuorum)
    
    	if modTime.IsZero() || modTime.Equal(timeSentinel) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. cmd/admin-router.go

    func adminMiddleware(f http.HandlerFunc, flags ...hFlag) http.HandlerFunc {
    	// Collect all flags with bitwise-OR and assign operator
    	var handlerFlags hFlag
    	for _, flag := range flags {
    		handlerFlags |= flag
    	}
    
    	// Get name of the handler using reflection.
    	handlerName := getHandlerName(f, "adminAPIHandlers")
    
    	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		// Update request context with `logger.ReqInfo`.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  4. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/tasks/AbstractVersionsUpdateTask.kt

            compatibilityDocFile: RegularFileProperty,
            linePrefix: String,
            firstVersion: String,
            latestVersion: String,
        ) {
            val docFile = compatibilityDocFile.get().asFile
            var lineFound = false
            docFile.writeText(
                docFile.readLines().joinToString(separator = "\n", postfix = "\n") { line ->
                    if (line.startsWith(linePrefix)) {
                        lineFound = true
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Fri Oct 24 09:10:28 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  5. lib/time/mkzip.go

    }
    
    func main() {
    	log.SetPrefix("mkzip: ")
    	log.SetFlags(0)
    	flag.Usage = usage
    	flag.Parse()
    	args := flag.Args()
    	if len(args) != 1 || !strings.HasSuffix(args[0], ".zip") {
    		usage()
    	}
    
    	var zb bytes.Buffer
    	zw := zip.NewWriter(&zb)
    	seen := make(map[string]bool)
    	err := filepath.WalkDir(".", func(path string, d fs.DirEntry, err error) error {
    		if d.IsDir() {
    			return nil
    		}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  6. tests/compose.yml

        hostname: opengauss-server
        ports:
          - "127.0.0.1:9950:5432"
        environment:
          - TZ=Asia/Shanghai
          - GS_PASSWORD=Gaussdb@123
          - GS_CLUSTER_NAME=opengauss_cluster
          - PGDATA=/var/lib/opengauss/data
        entrypoint: ""
        command: |-
          /bin/sh -c 'set -euo pipefail;
          /usr/local/bin/entrypoint.sh gaussdb &
          counter=1;
          while [ "$$counter" -le 20 ]; do
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Aug 04 04:07:30 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  7. internal/config/identity/openid/rsa-sha3_contrib.go

    	"crypto"
    
    	"github.com/golang-jwt/jwt/v4"
    
    	// Needed for SHA3 to work - See: https://golang.org/src/crypto/crypto.go?s=1034:1288
    	_ "golang.org/x/crypto/sha3"
    )
    
    // Specific instances for RS256 and company
    var (
    	SigningMethodRS3256 *jwt.SigningMethodRSA
    	SigningMethodRS3384 *jwt.SigningMethodRSA
    	SigningMethodRS3512 *jwt.SigningMethodRSA
    )
    
    func init() {
    	// RS3256
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  8. internal/kms/secret-key_test.go

    			t.Fatalf("Test %d: failed to decrypt key: %v", i, err)
    		}
    		if !bytes.Equal(plaintext, dataKey) {
    			t.Fatalf("Test %d: decrypted key does not generated one: got %x - want %x", i, plaintext, dataKey)
    		}
    	}
    }
    
    var decryptKeyTests = []struct {
    	KeyID      string
    	Plaintext  string
    	Ciphertext string
    	Context    Context
    }{
    	{
    		KeyID:      "my-key",
    		Plaintext:  "zmS7NrG765UZ0ZN85oPjybelxqVvpz01vxsSpOISy2M=",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  9. cmd/ilm-config.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"sync"
    
    	"github.com/minio/minio/internal/config/ilm"
    )
    
    var globalILMConfig = ilmConfig{
    	cfg: ilm.Config{
    		ExpirationWorkers: 100,
    		TransitionWorkers: 100,
    	},
    }
    
    type ilmConfig struct {
    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Mar 05 02:50:24 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  10. internal/grid/errors.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package grid
    
    import (
    	"errors"
    	"fmt"
    )
    
    var (
    	// ErrUnknownHandler is returned when an unknown handler is requested.
    	ErrUnknownHandler = errors.New("unknown mux handler")
    
    	// ErrHandlerAlreadyExists is returned when a handler is already registered.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 1.4K bytes
    - Click Count (0)
Back to Top