Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 620 for uint24 (0.05 sec)

  1. internal/crypto/key.go

    		return ErrSecretKeyMismatch
    	}
    	return nil
    }
    
    // DerivePartKey derives an unique 256 bit key from an ObjectKey and the part index.
    func (key ObjectKey) DerivePartKey(id uint32) (partKey [32]byte) {
    	var bin [4]byte
    	binary.LittleEndian.PutUint32(bin[:], id)
    
    	mac := hmac.New(sha256.New, key[:])
    	mac.Write(bin[:])
    	mac.Sum(partKey[:0])
    	return partKey
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:28:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. src/bufio/example_test.go

    	fmt.Fprint(w, "Hello, ")
    	fmt.Fprint(w, "world!")
    	w.Flush() // Don't forget to flush!
    	// Output: Hello, world!
    }
    
    func ExampleWriter_AvailableBuffer() {
    	w := bufio.NewWriter(os.Stdout)
    	for _, i := range []int64{1, 2, 3, 4} {
    		b := w.AvailableBuffer()
    		b = strconv.AppendInt(b, i, 10)
    		b = append(b, ' ')
    		w.Write(b)
    	}
    	w.Flush()
    	// Output: 1 2 3 4
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/dynamic-timeouts_test.go

    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    				for j := 0; j < 100; j++ {
    					timeout.LogSuccess(time.Duration(float64(time.Second) * rng.Float64()))
    				}
    				to := timeout.Timeout()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  4. callbacks.go

    		if !stmt.ReflectValue.IsValid() {
    			db.AddError(ErrInvalidValue)
    		}
    	}
    
    	for _, f := range p.fns {
    		f(db)
    	}
    
    	if stmt.SQL.Len() > 0 {
    		db.Logger.Trace(stmt.Context, curTime, func() (string, int64) {
    			sql, vars := stmt.SQL.String(), stmt.Vars
    			if filter, ok := db.Logger.(ParamsFilter); ok {
    				sql, vars = filter.ParamsFilter(stmt.Context, stmt.SQL.String(), stmt.Vars...)
    			}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 26 03:33:36 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/policy/v1beta1/generated.proto

      optional int32 max = 2;
    }
    
    // IDRange provides a min/max of an allowed range of IDs.
    message IDRange {
      // min is the start of the range, inclusive.
      optional int64 min = 1;
    
      // max is the end of the range, inclusive.
      optional int64 max = 2;
    }
    
    // PodDisruptionBudget is an object to define the max disruption that can be caused to a collection of pods
    message PodDisruptionBudget {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/ztunnelserver_test.go

    	"k8s.io/apimachinery/pkg/types"
    
    	"istio.io/istio/pkg/monitoring/monitortest"
    	"istio.io/istio/pkg/test/util/assert"
    	"istio.io/istio/pkg/zdsapi"
    )
    
    var ztunnelTestCounter atomic.Uint32
    
    func TestZtunnelSendsPodSnapshot(t *testing.T) {
    	ztunnelKeepAliveCheckInterval = time.Second / 10
    	mt := monitortest.New(t)
    	setupLogging()
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/batch/v1beta1/generated.proto

      optional string timeZone = 8;
    
      // Optional deadline in seconds for starting the job if it misses scheduled
      // time for any reason.  Missed jobs executions will be counted as failed ones.
      // +optional
      optional int64 startingDeadlineSeconds = 2;
    
      // Specifies how to treat concurrent executions of a Job.
      // Valid values are:
      //
      // - "Allow" (default): allows CronJobs to run concurrently;
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. cmd/data-scanner_test.go

    		bucket:     bucket,
    		prefix:     "",
    		objectName: obj,
    		lifeCycle:  &lc,
    	}
    
    	modTime := time.Now()
    	uuids := make([]uuid.UUID, 5)
    	for i := range uuids {
    		uuids[i] = uuid.UUID([16]byte{15: uint8(i + 1)})
    	}
    	fivs := make([]FileInfo, 5)
    	for i := 0; i < 5; i++ {
    		fivs[i] = FileInfo{
    			Volume:      bucket,
    			Name:        obj,
    			VersionID:   uuids[i].String(),
    			IsLatest:    i == 0,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. internal/http/response-recorder.go

    // ReadFrom implements support for calling internal io.ReaderFrom implementations
    // returns an error if the underlying ResponseWriter does not implement io.ReaderFrom
    func (lrw *ResponseRecorder) ReadFrom(r io.Reader) (int64, error) {
    	if lrw.ReaderFrom != nil {
    		n, err := lrw.ReaderFrom.ReadFrom(r)
    		lrw.bytesWritten += int(n)
    		return n, err
    	}
    	return 0, ErrNotImplemented
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver.go

    }
    
    func (c *connMgr) addConn(conn *ZtunnelConnection) {
    	log.Debug("ztunnel connected")
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	c.connectionSet[conn] = struct{}{}
    	c.latestConn = conn
    	ztunnelConnected.RecordInt(int64(len(c.connectionSet)))
    }
    
    func (c *connMgr) LatestConn() *ZtunnelConnection {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	return c.latestConn
    }
    
    func (c *connMgr) deleteConn(conn *ZtunnelConnection) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top