- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 1,950 for func (0.05 sec)
-
internal/logger/target/http/http.go
} // Name returns the name of the target func (h *Target) Name() string { return "minio-http-" + h.config.Name } // Type - returns type of the target func (h *Target) Type() types.TargetType { return types.TargetHTTP } // Endpoint returns the backend endpoint func (h *Target) Endpoint() string { return h.config.Endpoint.String() } func (h *Target) String() string { return h.config.Name
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
cmd/prepare-storage.go
"github.com/dustin/go-humanize" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" ) var printEndpointError = func() func(Endpoint, error, bool) { var mutex sync.Mutex printOnce := make(map[Endpoint]map[string]int) return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
cmd/xl-storage-format-v2_string.go
var _VersionType_index = [...]uint8{0, 18, 28, 38, 48, 63} func (i VersionType) String() string { if i >= VersionType(len(_VersionType_index)-1) { return "VersionType(" + strconv.FormatInt(int64(i), 10) + ")" } return _VersionType_name[_VersionType_index[i]:_VersionType_index[i+1]] } func _() { // An "invalid array index" compiler error signifies that the constant values have changed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Dec 02 19:29:16 UTC 2021 - 1.4K bytes - Viewed (0) -
src/bytes/compare_test.go
} func BenchmarkCompareBytesBigUnaligned(b *testing.B) { for i := 1; i < 8; i++ { b.Run(fmt.Sprintf("offset=%d", i), func(b *testing.B) { benchmarkCompareBytesBigUnaligned(b, i) }) } } func benchmarkCompareBytesBigBothUnaligned(b *testing.B, offset int) { b.StopTimer() pattern := []byte("Hello Gophers!") b1 := make([]byte, 0, 1<<20+len(pattern)) for len(b1) < 1<<20 {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 13 23:11:42 UTC 2023 - 6.8K bytes - Viewed (0) -
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.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
internal/grid/msg_gen.go
import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *Flags) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = Flags(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z Flags) EncodeMsg(en *msgp.Writer) (err error) { err = en.WriteUint8(uint8(z))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:07:21 UTC 2024 - 22.4K bytes - Viewed (0) -
internal/config/dns/operator_dns.go
type OperatorOption func(*OperatorDNS) // Authentication - custom username and password for authenticating at the endpoint func Authentication(username, password string) OperatorOption { return func(args *OperatorDNS) { args.username = username args.password = password } } // RootCAs - add custom trust certs pool func RootCAs(certPool *x509.CertPool) OperatorOption { return func(args *OperatorDNS) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 6.6K bytes - Viewed (0) -
cmd/leak-detect_test.go
// function to be run at the end of tests to see whether any // goroutines leaked. // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests. func DetectTestLeak(t TestErrHandler) func() { initialStackSnapShot := NewLeakDetect() return func() { initialStackSnapShot.DetectLeak(t) } } // list of functions to be ignored from the stack trace.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 5.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_unified_experimental.cc
void TF_DeleteAbstractFunction(TF_AbstractFunction* func) { unwrap(func)->Unref(); } void TF_ExecutionContextRegisterFunction(TF_ExecutionContext* ctx, TF_AbstractFunction* func, TF_Status* s) { tsl::Set_TF_Status_from_Status(s, unwrap(ctx)->RegisterFunction(unwrap(func)));
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 9K bytes - Viewed (0)