Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 1,208 for funcs (0.03 seconds)

  1. guava-tests/test/com/google/common/hash/ChecksumHashFunctionTest.java

        checksum.update(bytes, 0, bytes.length);
        long value = checksum.getValue();
    
        String toString = "name";
        HashFunction func = new ChecksumHashFunction(supplier, 32, toString);
        assertThat(func.toString()).isEqualTo(toString);
        assertEquals(value, func.hashBytes(bytes).padToLong());
      }
    
      private static void assertHash32(
          int expected, ImmutableSupplier<Checksum> supplier, String input) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  2. cmd/bucket-listobjects-handlers.go

    	}
    
    	if marker != "" && !HasPrefix(marker, prefix) {
    		return ErrNotImplemented
    	}
    
    	return ErrNone
    }
    
    func (api objectAPIHandlers) ListObjectVersionsHandler(w http.ResponseWriter, r *http.Request) {
    	api.listObjectVersionsHandler(w, r, false)
    }
    
    func (api objectAPIHandlers) ListObjectVersionsMHandler(w http.ResponseWriter, r *http.Request) {
    	api.listObjectVersionsHandler(w, r, true)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  3. cmd/generic-handlers_test.go

    }
    
    func TestSSETLSHandler(t *testing.T) {
    	defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test
    
    	var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
    		w.WriteHeader(http.StatusOK)
    	}
    	for i, test := range sseTLSHandlerTests {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  4. internal/kms/secret-key.go

    // from a single key.
    type secretKey struct {
    	keyID string
    	key   []byte
    }
    
    // Version returns the version of the builtin KMS.
    func (secretKey) Version(ctx context.Context) (string, error) { return "v1", nil }
    
    // APIs returns an error since the builtin KMS does not provide a list of APIs.
    func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Apr 21 16:23:51 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  5. cmd/admin-handlers-users_test.go

    	client   *minio.Client
    }
    
    func newTestSuiteIAM(c TestSuiteCommon, withEtcdBackend bool) *TestSuiteIAM {
    	etcdStr := ""
    	if withEtcdBackend {
    		etcdStr = " (with etcd backend)"
    	}
    	return &TestSuiteIAM{
    		TestSuiteCommon:       c,
    		ServerTypeDescription: fmt.Sprintf("%s%s", c.serverType, etcdStr),
    		withEtcdBackend:       withEtcdBackend,
    	}
    }
    
    func (s *TestSuiteIAM) iamSetup(c *check) {
    	var err error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 50.6K bytes
    - Click Count (0)
  6. cmd/data-scanner.go

    // When the returned function is called it will wait.
    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    	t := time.Now()
    	return func() {
    		doneAt := time.Now()
    		d.Sleep(ctx, doneAt.Sub(t))
    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  7. cmd/kms-handlers.go

    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/policy"
    )
    
    // KMSStatusHandler - GET /minio/kms/v1/status
    func (a kmsAPIHandlers) KMSStatusHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "KMSStatus")
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 10.1K bytes
    - Click Count (0)
  8. cmd/api-response.go

    	http.ResponseWriter
    	headerWritten bool
    }
    
    func (w *trackingResponseWriter) WriteHeader(statusCode int) {
    	if !w.headerWritten {
    		w.headerWritten = true
    		w.ResponseWriter.WriteHeader(statusCode)
    	}
    }
    
    func (w *trackingResponseWriter) Write(b []byte) (int, error) {
    	return w.ResponseWriter.Write(b)
    }
    
    func (w *trackingResponseWriter) Unwrap() http.ResponseWriter {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 35K bytes
    - Click Count (0)
  9. src/bufio/bufio.go

    // size, it returns the underlying [Reader].
    func NewReaderSize(rd io.Reader, size int) *Reader {
    	// Is it already a Reader?
    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    	return r
    }
    
    // NewReader returns a new [Reader] whose buffer has the default size.
    func NewReader(rd io.Reader) *Reader {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  10. utils/tests/utils.go

    		}
    		got := rv.FieldByName(name).Interface()
    		expect := ev.FieldByName(name).Interface()
    		t.Run(name, func(t *testing.T) {
    			AssertEqual(t, got, expect)
    		})
    	}
    }
    
    func AssertEqual(t *testing.T, got, expect interface{}) {
    	if !reflect.DeepEqual(got, expect) {
    		isEqual := func() {
    			if curTime, ok := got.(time.Time); ok {
    				format := "2006-01-02T15:04:05Z07:00"
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Mar 10 09:21:56 GMT 2023
    - 3.9K bytes
    - Click Count (0)
Back to Top