Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,179 for funcs (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/site-replication-metrics_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgRStat(b *testing.B) {
    	v := RStat{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgRStat(b *testing.B) {
    	v := RStat{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  6. internal/grid/msg_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgconnectReq(b *testing.B) {
    	v := connectReq{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgconnectReq(b *testing.B) {
    	v := connectReq{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    func (oi ObjectInfo) TraceVersionID() string {
    	return oi.VersionID
    }
    
    func (m *batchJobMetrics) trace(d batchJobMetric, job string, attempts int) func(info objTraceInfoer, err error) {
    	startTime := time.Now()
    	return func(info objTraceInfoer, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers_test.go

    			}
    		}
    	}
    }
    
    type byResourceUID struct{ madmin.LockEntries }
    
    func (b byResourceUID) Less(i, j int) bool {
    	toUniqLock := func(entry madmin.LockEntry) string {
    		return fmt.Sprintf("%s/%s", entry.Resource, entry.ID)
    	}
    	return toUniqLock(b.LockEntries[i]) < toUniqLock(b.LockEntries[j])
    }
    
    func TestTopLockEntries(t *testing.T) {
    	locksHeld := make(map[string][]lockRequesterInfo)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. api/go1.17.txt

    pkg syscall (openbsd-amd64-cgo), const MSG_CMSG_CLOEXEC = 2048
    pkg syscall (openbsd-amd64-cgo), const MSG_CMSG_CLOEXEC ideal-int
    pkg syscall (windows-386), func CreateIoCompletionPort //deprecated
    pkg syscall (windows-386), func GetQueuedCompletionStatus //deprecated
    pkg syscall (windows-386), func PostQueuedCompletionStatus //deprecated
    pkg syscall (windows-386), type SysProcAttr struct, AdditionalInheritedHandles []Handle
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 18K bytes
    - Viewed (0)
  10. internal/s3select/json/errors.go

    	cause      error
    }
    
    func (err *s3Error) Cause() error {
    	return err.cause
    }
    
    func (err *s3Error) ErrorCode() string {
    	return err.code
    }
    
    func (err *s3Error) ErrorMessage() string {
    	return err.message
    }
    
    func (err *s3Error) HTTPStatusCode() int {
    	return err.statusCode
    }
    
    func (err *s3Error) Error() string {
    	return err.message
    }
    
    func errInvalidJSONType(err error) *s3Error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
Back to top