Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 258 for qint32 (0.05 sec)

  1. cni/pkg/nodeagent/fakes_test.go

    	return &fakeFileFakeFds{File: f, fd: 0}
    }
    
    type fakeIptablesDeps struct {
    	AddRouteErr           error
    	AddInpodMarkIPRuleCnt atomic.Int32
    	DelInpodMarkIPRuleCnt atomic.Int32
    	AddLoopbackRoutesCnt  atomic.Int32
    	DelLoopbackRoutesCnt  atomic.Int32
    }
    
    var _ iptables.NetlinkDependencies = &fakeIptablesDeps{}
    
    func (r *fakeIptablesDeps) AddInpodMarkIPRule(cfg *iptables.Config) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // +optional
      optional int32 handSize = 2;
    
      // `queueLengthLimit` is the maximum number of requests allowed to
      // be waiting in a given queue of this priority level at a time;
      // excess requests are rejected.  This value must be positive.  If
      // not specified, it will be defaulted to 50.
      // +optional
      optional int32 queueLengthLimit = 3;
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  3. cmd/site-replication-utils_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *SiteResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2-legacy.go

    	}
    	return bts, fmt.Errorf("unknown xlHeaderVersion: %d", v)
    }
    
    // unmarshalV1 decodes version 1, never released.
    func (x *xlMetaV2VersionHeader) unmarshalV1(bts []byte) (o []byte, err error) {
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadArrayHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0001 != 4 {
    		err = msgp.ArrayError{Wanted: 4, Got: zb0001}
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 19 16:43:43 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. internal/s3select/genmessage.go

    	headerLength := len(header)
    	payloadLength := 0
    	totalLength := totalByteLength(headerLength, payloadLength)
    
    	buf = new(bytes.Buffer)
    	binary.Write(buf, binary.BigEndian, uint32(totalLength))
    	binary.Write(buf, binary.BigEndian, uint32(headerLength))
    	prelude := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
    	buf.Write(header)
    	message := buf.Bytes()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/policy/v1/generated.proto

      // Number of pod disruptions that are currently allowed.
      optional int32 disruptionsAllowed = 3;
    
      // current number of healthy pods
      optional int32 currentHealthy = 4;
    
      // minimum desired number of healthy pods
      optional int32 desiredHealthy = 5;
    
      // total number of pods counted by this disruption budget
      optional int32 expectedPods = 6;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/autoscaling/v2/generated.proto

      // value contains the amount of change which is permitted by the policy.
      // It must be greater than zero
      optional int32 value = 2;
    
      // periodSeconds specifies the window of time for which the policy should hold true.
      // PeriodSeconds must be greater than zero and less than or equal to 1800 (30 min).
      optional int32 periodSeconds = 3;
    }
    
    // HPAScalingRules configures the scaling behavior for one direction.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/monitor_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/coordination/v1/generated.proto

      // leaseDurationSeconds is a duration that candidates for a lease need
      // to wait to force acquire it. This is measure against time of last
      // observed renewTime.
      // +optional
      optional int32 leaseDurationSeconds = 2;
    
      // acquireTime is a time when the current lease was acquired.
      // +optional
      optional k8s.io.apimachinery.pkg.apis.meta.v1.MicroTime acquireTime = 3;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/coordination/v1beta1/generated.proto

      // leaseDurationSeconds is a duration that candidates for a lease need
      // to wait to force acquire it. This is measure against time of last
      // observed renewTime.
      // +optional
      optional int32 leaseDurationSeconds = 2;
    
      // acquireTime is a time when the current lease was acquired.
      // +optional
      optional k8s.io.apimachinery.pkg.apis.meta.v1.MicroTime acquireTime = 3;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top