Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 620 for uint24 (0.08 sec)

  1. internal/s3select/jstream/decoder.go

    	emitRecursive bool
    	objectAsKVS   bool
    
    	depth   int
    	scratch *scratch
    	metaCh  chan *MetaValue
    	err     error
    
    	// follow line position to add context to errors
    	lineNo    int
    	lineStart int64
    }
    
    // NewDecoder creates new Decoder to read JSON values at the provided
    // emitDepth from the provider io.Reader.
    // If emitDepth is < 0, values at every depth will be emitted.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	// Add the pod UID as an ipset entry comment, so we can (more) easily find and delete
    	// all relevant entries for a pod later.
    	podUID := string(pod.ObjectMeta.UID)
    	ipProto := uint8(unix.IPPROTO_TCP)
    
    	var ipsetAddrErrs []error
    	var addedIps []netip.Addr
    
    	// For each pod IP
    	for _, pip := range podIPs {
    		// Add to host ipset
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. association.go

    			}
    		}
    	}
    
    	return association.Error
    }
    
    func (association *Association) Clear() error {
    	return association.Replace()
    }
    
    func (association *Association) Count() (count int64) {
    	if association.Error == nil {
    		association.Error = association.buildCondition().Count(&count).Error
    	}
    	return
    }
    
    type assignBack struct {
    	Source reflect.Value
    	Index  int
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:49:45 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. src/bytes/example_test.go

    	os.Stdout.Write(buf.Bytes())
    	// Output: hello world
    }
    
    func ExampleBuffer_AvailableBuffer() {
    	var buf bytes.Buffer
    	for i := 0; i < 4; i++ {
    		b := buf.AvailableBuffer()
    		b = strconv.AppendInt(b, int64(i), 10)
    		b = append(b, ' ')
    		buf.Write(b)
    	}
    	os.Stdout.Write(buf.Bytes())
    	// Output: 0 1 2 3
    }
    
    func ExampleBuffer_Cap() {
    	buf1 := bytes.NewBuffer(make([]byte, 10))
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 07 17:22:36 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  5. schema/schema.go

    			schema.FieldsWithDefaultDBValue = append(schema.FieldsWithDefaultDBValue, field)
    		}
    	}
    
    	if field := schema.PrioritizedPrimaryField; field != nil {
    		switch field.GORMDataType {
    		case Int, Uint:
    			if _, ok := field.TagSettings["AUTOINCREMENT"]; !ok {
    				if !field.HasDefaultValue || field.DefaultValueInterface != nil {
    					schema.FieldsWithDefaultDBValue = append(schema.FieldsWithDefaultDBValue, field)
    				}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    	}
    
    	actualSize, err := objInfo.GetActualSize()
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	objectRSC := s3select.NewObjectReadSeekCloser(
    		func(offset int64) (io.ReadCloser, error) {
    			rs := &HTTPRangeSpec{
    				IsSuffixLength: false,
    				Start:          offset,
    				End:            -1,
    			}
    			opts.NoLock = true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  7. cmd/api-router.go

    	{
    		api:     "analytics",
    		methods: []string{http.MethodDelete, http.MethodPut, http.MethodGet},
    		queries: []string{"analytics", ""},
    	},
    }
    
    // Set of s3 handler options as bit flags.
    type s3HFlag uint8
    
    const (
    	// when provided, disables Gzip compression.
    	noGZS3HFlag = 1 << iota
    
    	// when provided, enables only tracing of headers. Otherwise, both headers
    	// and body are traced.
    	traceHdrsS3HFlag
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. cmd/bucket-replication-handlers.go

    				ReplicationValidityCheck: true, // set this to validate the replication config
    			},
    		}
    		obj := path.Join(minioReservedBucket, globalLocalNodeNameHex, "deleteme")
    		ui, err := c.PutObject(ctx, clnt.Bucket, obj, reader, int64(len(buf)), "", "", putOpts)
    		if err != nil && !isReplicationPermissionCheck(ErrorRespToObjectError(err, bucket, obj)) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  9. statement.go

    		default:
    			switch rv := reflect.ValueOf(v); rv.Kind() {
    			case reflect.Slice, reflect.Array:
    				if rv.Len() == 0 {
    					writer.WriteString("(NULL)")
    				} else if rv.Type().Elem() == reflect.TypeOf(uint8(0)) {
    					stmt.Vars = append(stmt.Vars, v)
    					stmt.DB.Dialector.BindVarTo(writer, stmt, v)
    				} else {
    					writer.WriteByte('(')
    					for i := 0; i < rv.Len(); i++ {
    						if i > 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. cmd/admin-router.go

    	if err != nil {
    		// Static params, so this is very unlikely.
    		logger.Fatal(err, "Unable to initialize server")
    	}
    	return gz
    }()
    
    // Set of handler options as bit flags
    type hFlag uint8
    
    const (
    	// this flag disables gzip compression of responses
    	noGZFlag = 1 << iota
    
    	// this flag enables tracing body and headers instead of just headers
    	traceAllFlag
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 26.2K bytes
    - Viewed (0)
Back to top