Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for todos (0.15 sec)

  1. cmd/kms-handlers.go

    		DefaultKeyID: stat.DefaultKey,
    		Endpoints:    make(map[string]madmin.ItemState, len(stat.Endpoints)),
    	}
    	for _, endpoint := range stat.Endpoints {
    		status.Endpoints[endpoint] = madmin.ItemOnline // TODO(aead): Implement an online check for mTLS
    	}
    
    	resp, err := json.Marshal(status)
    	if err != nil {
    		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  2. internal/s3select/sql/value.go

    		return nil
    	}
    }
    
    // Value arithmetic functions: we do not expose them outside the
    // module. All arithmetic works only on numeric values with automatic
    // promotion to the "larger" type that can represent the value. TODO:
    // Add support for large number arithmetic.
    
    // Supported arithmetic operators
    const (
    	opPlus     = "+"
    	opMinus    = "-"
    	opDivide   = "/"
    	opMultiply = "*"
    	opModulo   = "%"
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	}
    	xl.SetDiskID(emptyDiskID)
    
    	xl.totalWrites.Store(xl.storage.getWriteAttribute())
    	xl.totalDeletes.Store(xl.storage.getDeleteAttribute())
    	xl.diskCtx, xl.diskCancel = context.WithCancel(context.TODO())
    	for i := range xl.apiLatencies[:] {
    		xl.apiLatencies[i] = &lockedLastMinuteLatency{}
    	}
    	if xl.healthCheck {
    		go xl.monitorDiskWritable(xl.diskCtx)
    	}
    	return &xl
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. cmd/format-erasure.go

    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    	// Rename file `uuid.json` --> `format.json`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  5. internal/grid/muxclient.go

    	}
    	return m.parent.send(m.ctx, dst)
    }
    
    // RequestStateless will send a single payload request and stream back results.
    // req may not be read/written to after calling.
    // TODO: Not implemented
    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    	m.init = true
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  6. cmd/streaming-signature-v4.go

    	if !bytes.HasPrefix(sig, []byte("x-amz-trailer-signature:")) {
    		if cr.debug {
    			fmt.Printf("prefix, want prefix %q, got %q", "x-amz-trailer-signature:", string(sig))
    		}
    		return errMalformedEncoding
    	}
    
    	// TODO: It seems like we may have to be prepared to rewrite and sort trailing headers:
    	// https://docs.aws.amazon.com/IAM/latest/UserGuide/create-signed-request.html
    
    	// Any value must end with a newline.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    		// transitioned tier lies untouched and still accessible
    		opts.Transition.ExpireRestored = true
    		_, err := objectAPI.DeleteObject(ctx, oi.Bucket, oi.Name, opts)
    		if err == nil {
    			// TODO consider including expiry of restored object to events we
    			// notify.
    			auditLogLifecycle(ctx, *oi, ILMExpiry, tags, traceFn)
    		}
    		return err
    	}
    
    	// Delete remote object from warm-tier
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. internal/hash/reader.go

    	MD5, err := hex.DecodeString(md5Hex)
    	if err != nil {
    		return nil, BadDigest{ // TODO(aead): Return an error that indicates that an invalid ETag has been specified
    			ExpectedMD5:   md5Hex,
    			CalculatedMD5: "",
    		}
    	}
    	SHA256, err := hex.DecodeString(sha256Hex)
    	if err != nil {
    		return nil, SHA256Mismatch{ // TODO(aead): Return an error that indicates that an invalid Content-SHA256 has been specified
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
  9. cmd/endpoint-ellipses.go

    			legacy: true,
    			pools:  []poolDisksLayout{{layout: setArgs, cmdline: strings.Join(args, " ")}},
    		}
    		return
    	}
    
    	for _, arg := range args {
    		if !ellipses.HasEllipses(arg) && len(args) > 1 {
    			// TODO: support SNSD deployments to be decommissioned in future
    			return fmt.Errorf("all args must have ellipses for pool expansion (%w) args: %s", errInvalidArgument, args)
    		}
    		setArgs, err = GetAllSets(setDriveCount, arg)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    	} else {
    		handler = c.handlers.subSingle[*subID]
    	}
    	if handler == nil {
    		gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler for type"}))
    		return
    	}
    
    	// TODO: This causes allocations, but escape analysis doesn't really show the cause.
    	// If another faithful engineer wants to take a stab, feel free.
    	go func(m message) {
    		var start time.Time
    		if m.DeadlineMS > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top