Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,214 for Func (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top