- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,214 for Func (0.03 sec)
-
src/cmd/asm/internal/lex/tokenizer.go
} func (t *Tokenizer) Text() string { switch t.tok { case LSH: return "<<" case RSH: return ">>" case ARR: return "->" case ROT: return "@>" } return t.s.TokenText() } func (t *Tokenizer) File() string { return t.base.Filename() } func (t *Tokenizer) Base() *src.PosBase { return t.base } func (t *Tokenizer) SetBase(base *src.PosBase) {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Aug 04 20:35:21 UTC 2022 - 3K bytes - Viewed (0) -
cmd/bucket-targets.go
// healthCheck map if missing and default to online status func (sys *BucketTargetSys) isOffline(ep *url.URL) bool { sys.hMutex.RLock() defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep) return false } // markOffline sets endpoint to offline if network i/o timeout seen. func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0) -
tests/helper_test.go
} }) } func tidbSkip(t *testing.T, reason string) { if isTiDB() { t.Skipf("This test case skipped, because of TiDB '%s'", reason) } } func isTiDB() bool { return os.Getenv("GORM_DIALECT") == "tidb" } func isMysql() bool { return os.Getenv("GORM_DIALECT") == "mysql" } func isSqlite() bool { return os.Getenv("GORM_DIALECT") == "sqlite" }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Mar 19 03:50:28 UTC 2024 - 8K bytes - Viewed (0) -
internal/grid/connection_test.go
) func TestDisconnect(t *testing.T) { defer testlogger.T.SetLogTB(t)() defer timeout(10 * time.Second)() hosts, listeners, _ := getHosts(2) dialer := &net.Dialer{ Timeout: 1 * time.Second, } errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } wrapServer := func(handler http.Handler) http.Handler {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 08 21:44:00 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/pubsub/pubsub.go
"encoding/json" "fmt" "sync" "sync/atomic" ) // GetByteBuffer returns a byte buffer from the pool. var GetByteBuffer = func() []byte { return make([]byte, 0, 4096) } // Sub - subscriber entity. type Sub[T Maskable] struct { ch chan T types Mask filter func(entry T) bool } // PubSub holds publishers and subscribers type PubSub[T Maskable, M Maskable] struct { // atomics, keep at top:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
schema/serializer.go
"reflect" "strings" "sync" "time" ) var serializerMap = sync.Map{} // RegisterSerializer register serializer func RegisterSerializer(name string, serializer SerializerInterface) { serializerMap.Store(strings.ToLower(name), serializer) } // GetSerializer get serializer func GetSerializer(name string) (serializer SerializerInterface, ok bool) { v, ok := serializerMap.Load(strings.ToLower(name)) if ok {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Jun 20 08:45:38 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/store/store.go
Extension string ItemCount int } // String returns the filepath name func (k Key) String() string { keyStr := k.Name if k.ItemCount > 1 { keyStr = fmt.Sprintf("%d:%s", k.ItemCount, k.Name) } return keyStr + k.Extension + func() string { if k.Compress { return compressExt } return "" }() } func getItemCount(k string) (count int, err error) { count = 1 v := strings.Split(k, ":")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
cmd/batch-job-common-types.go
line, col int msg string } // message returns the error message excluding line, col information. // Intended to be used in unit tests. func (b BatchJobYamlErr) message() string { return b.msg } // Error implements Error interface func (b BatchJobYamlErr) Error() string { return fmt.Sprintf("%s\n Hint: error near line: %d, col: %d", b.msg, b.line, b.col) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
// Call the returned function to disable logging. func (t *testLogger) SetErrorTB(tb testing.TB) func() { return t.setTB(tb, errorMessage) } // SetFatalTB will set the logger to output to tb.Panic. // Call the returned function to disable logging. func (t *testLogger) SetFatalTB(tb testing.TB) func() { return t.setTB(tb, fatalMessage) } func (t *testLogger) setTB(tb testing.TB, action int32) func() { old := t.action.Swap(action)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
src/bytes/iter.go
func explodeSeq(s []byte) iter.Seq[[]byte] { return func(yield func([]byte) bool) { for len(s) > 0 { _, size := utf8.DecodeRune(s) if !yield(s[:size:size]) { return } s = s[size:] } } } // splitSeq is SplitSeq or SplitAfterSeq, configured by how many // bytes of sep to include in the results (none or all).
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 14 18:23:13 UTC 2024 - 3.7K bytes - Viewed (0)