- Sort Score
- Num 10 results
- Language All
Results 351 - 360 of 1,207 for func_ (0.04 seconds)
-
internal/s3select/select_benchmark_test.go
return buf.Bytes() } type nullResponseWriter struct{} func (w *nullResponseWriter) Header() http.Header { return nil } func (w *nullResponseWriter) Write(p []byte) (int, error) { return len(p), nil } func (w *nullResponseWriter) WriteHeader(statusCode int) { } func (w *nullResponseWriter) Flush() { } func benchmarkSelect(b *testing.B, count int, query string) { requestXML := []byte(`
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5K bytes - Click Count (0) -
internal/logger/utils.go
var ansiRE = regexp.MustCompile("(\x1b[^m]*m)") // Print ANSI Control escape func ansiEscape(format string, args ...any) { Esc := "\x1b" fmt.Printf("%s%s", Esc, fmt.Sprintf(format, args...)) } func ansiMoveRight(n int) { if runtime.GOOS == "windows" { return } if color.IsTerminal() { ansiEscape("[%dC", n) } } func ansiSaveAttributes() { if runtime.GOOS == "windows" { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.6K bytes - Click Count (0) -
cmd/batch-expire_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "time" "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BatchJobExpire) 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--
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.9K bytes - Click Count (0) -
internal/bpool/bpool.go
func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w } // WidthCap returns the cap width of the byte arrays in this pool. func (bp *BytePoolCap) WidthCap() (n int) { if bp == nil { return 0 } return bp.wcap } // CurrentSize returns current size of buffer pool func (bp *BytePoolCap) CurrentSize() int { if bp == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3K bytes - Click Count (0) -
api/go1.11.txt
pkg regexp/syntax, method (Op) String() string pkg runtime/trace, func IsEnabled() bool pkg runtime/trace, func Log(context.Context, string, string) pkg runtime/trace, func Logf(context.Context, string, string, ...interface{}) pkg runtime/trace, func NewTask(context.Context, string) (context.Context, *Task) pkg runtime/trace, func StartRegion(context.Context, string) *Region pkg runtime/trace, func WithRegion(context.Context, string, func())
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Wed Aug 22 03:48:56 GMT 2018 - 25K bytes - Click Count (0) -
cmd/data-usage-cache_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "testing" "github.com/dustin/go-humanize" ) func TestSizeHistogramToMap(t *testing.T) { tests := []struct { sizes []int64 want map[string]uint64 }{ { sizes: []int64{100, 1000, 72_000, 100_000}, want: map[string]uint64{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Jan 13 07:51:08 GMT 2024 - 2.6K bytes - Click Count (0) -
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) -
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) -
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) -
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)