Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 536 for mult (0.04 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // to create Client objects configured for SHA-512 hashing.
    var KafkaSHA512 scram.HashGeneratorFcn = sha512.New
    
    // XDGSCRAMClient implements the client-side of an authentication
    // conversation with a server.  A new conversation must be created for
    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. internal/grid/connection_test.go

    		t.Log("Roundtrip:", time.Since(start), resp, err)
    		gotResp <- struct{}{}
    	}()
    	<-gotCall
    	remote.debugMsg(debugKillInbound)
    	local.debugMsg(debugKillInbound)
    	<-gotResp
    
    	// Must reconnect
    	errFatal(remoteConn.WaitForConnect(context.Background()))
    
    	stream, err := remoteConn.NewStream(context.Background(), handlerTest2, []byte(testPayload))
    	errFatal(err)
    	go func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/lifecycle.go

    var (
    	errLifecycleTooManyRules = Errorf("Lifecycle configuration allows a maximum of 1000 rules")
    	errLifecycleNoRule       = Errorf("Lifecycle configuration should have at least one rule")
    	errLifecycleDuplicateID  = Errorf("Rule ID must be unique. Found same ID for more than one rule")
    	errXMLNotWellFormed      = Errorf("The XML you provided was not well-formed or did not validate against our published schema")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. docs/bigdata/README.md

    addition to the compute nodes, MinIO containers are also managed by Kubernetes as stateful containers with local storage (JBOD/JBOF) mapped as persistent local volumes. This architecture enables multi-tenant MinIO, allowing isolation of data between customers.
    
    MinIO also supports multi-cluster, multi-site federation similar to AWS regions and tiers. Using MinIO Information Lifecycle Management (ILM), you can configure data to be tiered between NVMe based hot storage, and HDD based warm storage....
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  5. internal/bpool/bpool.go

    // byte arrays sized based on width.
    func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) {
    	if capwidth <= 0 {
    		panic("total buffer capacity must be provided")
    	}
    	if capwidth < 64 {
    		panic("buffer capped with smaller than 64 bytes is not supported")
    	}
    	if width > capwidth {
    		panic("minimum buffer length cannot be > capacity of the buffer")
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. internal/s3select/sql/evaluate.go

    	lval, lerr := e.Left.evalNode(r, tableAlias)
    	if lerr != nil || len(e.Right) == 0 {
    		return lval, lerr
    	}
    
    	// Process remaining child nodes - result must be
    	// numeric. This AST node is for terms separated by + or -
    	// symbols.
    	for _, rightTerm := range e.Right {
    		op := rightTerm.Op
    		rval, rerr := rightTerm.Right.evalNode(r, tableAlias)
    		if rerr != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/arch/mips.go

    	case mips.ACMPEQF, mips.ACMPEQD, mips.ACMPGEF, mips.ACMPGED,
    		mips.ACMPGTF, mips.ACMPGTD:
    		return true
    	}
    	return false
    }
    
    // IsMIPSMUL reports whether the op (as defined by an mips.A* constant) is
    // one of the MUL/DIV/REM/MADD/MSUB instructions that require special handling.
    func IsMIPSMUL(op obj.As) bool {
    	switch op {
    	case mips.AMUL, mips.AMULU, mips.AMULV, mips.AMULVU,
    		mips.ADIV, mips.ADIVU, mips.ADIVV, mips.ADIVVU,
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Mar 04 19:06:44 UTC 2020
    - 1.7K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. src/archive/tar/strconv.go

    	}
    	if len(sn) < maxNanoSecondDigits {
    		sn += strings.Repeat("0", maxNanoSecondDigits-len(sn)) // Right pad
    	} else {
    		sn = sn[:maxNanoSecondDigits] // Right truncate
    	}
    	nsecs, _ := strconv.ParseInt(sn, 10, 64) // Must succeed
    	if len(ss) > 0 && ss[0] == '-' {
    		return time.Unix(secs, -1*nsecs), nil // Negative correction
    	}
    	return time.Unix(secs, nsecs), nil
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  10. buildscripts/disable-root.sh

    ./mc admin user add sitea foobar foo12345
    
    ./mc admin policy attach sitea/ consoleAdmin --user=foobar
    
    ./mc admin user info siteb foobar
    
    killall -9 minio
    
    echo "turning off root access, however site replication must continue"
    export MINIO_API_ROOT_ACCESS=off
    
    minio server --address 127.0.0.1:9001 "http://127.0.0.1:9001/tmp/multisitea/data/disterasure/xl{1...4}" \
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top