Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,425 for Func (0.15 sec)

  1. cmd/metacache-stream.go

    	err     error // stateful error
    	closer  func()
    	creator func() error
    }
    
    // newMetacacheReader creates a new cache reader.
    // Nothing will be read from the stream yet.
    func newMetacacheReader(r io.Reader) *metacacheReader {
    	dec := s2DecPool.Get().(*s2.Reader)
    	dec.Reset(r)
    	mr := msgpNewReader(dec)
    	return &metacacheReader{
    		mr: mr,
    		closer: func() {
    			dec.Reset(nil)
    			s2DecPool.Put(dec)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  2. cmd/object_api_suite_test.go

    		fn(t, func() {
    			resetCompressEncryption()
    			enableCompression(t, false, []string{"*"}, []string{"*"})
    		}, MakeBucketOptions{
    			VersioningEnabled: true,
    		})
    	})
    
    	t.Run("encrypted", func(t *testing.T) {
    		fn(t, func() {
    			resetCompressEncryption()
    			enableEncryption(t)
    		}, MakeBucketOptions{})
    	})
    	t.Run("encrypted+versioned", func(t *testing.T) {
    		fn(t, func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  3. internal/store/queuestore.go

    }
    
    // Del - Deletes an entry from the store.
    func (store *QueueStore[_]) Del(key Key) error {
    	store.Lock()
    	defer store.Unlock()
    	return store.del(key)
    }
    
    // Len returns the entry count.
    func (store *QueueStore[_]) Len() int {
    	store.RLock()
    	l := len(store.entries)
    	defer store.RUnlock()
    	return l
    }
    
    // lockless call
    func (store *QueueStore[_]) del(key Key) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/server_test.go

    type WaitGroup struct {
    	count int32
    	done  chan struct{}
    }
    
    func NewWaitGroup() *WaitGroup {
    	return &WaitGroup{
    		done: make(chan struct{}),
    	}
    }
    
    func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) {
    	wg := &WaitGroup{
    		done: make(chan struct{}),
    	}
    
    	wg.Add(n)
    	return wg, func() {
    		select {
    		case <-wg.C():
    			return
    		case <-time.After(time.Second):
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. internal/handlers/forwarder.go

    type Forwarder struct {
    	RoundTripper http.RoundTripper
    	PassHost     bool
    	Logger       func(error)
    	ErrorHandler func(http.ResponseWriter, *http.Request, error)
    
    	// internal variables
    	rewriter *headerRewriter
    }
    
    // NewForwarder creates an instance of Forwarder based on the provided list of configuration options
    func NewForwarder(f *Forwarder) *Forwarder {
    	f.rewriter = &headerRewriter{}
    	if f.RoundTripper == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  6. 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)
  7. internal/s3select/unused-errors.go

    //
    // /////////////////////////////////////////////////////////////////////
    func errExpressionTooLong(err error) *s3Error {
    	return &s3Error{
    		code:       "ExpressionTooLong",
    		message:    "The SQL expression is too long: The maximum byte-length for the SQL expression is 256 KB.",
    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errColumnTooLong(err error) *s3Error {
    	return &s3Error{
    		code:       "ColumnTooLong",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 20 08:16:35 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  8. migrator/column_type.go

    func (ct ColumnType) ScanType() reflect.Type {
    	if ct.ScanTypeValue != nil {
    		return ct.ScanTypeValue
    	}
    	return ct.SQLColumnType.ScanType()
    }
    
    // Comment returns the comment of current column.
    func (ct ColumnType) Comment() (value string, ok bool) {
    	return ct.CommentValue.String, ct.CommentValue.Valid
    }
    
    // DefaultValue returns the default value of current column.
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Mar 24 01:31:58 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  9. cmd/object-api-input-checks.go

    	"strings"
    
    	"github.com/minio/minio-go/v7/pkg/s3utils"
    )
    
    // Checks on CopyObject arguments, bucket and object.
    func checkCopyObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on GetObject arguments, bucket and object.
    func checkGetObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. cmd/storage-rest-common_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgnsScannerOptions(b *testing.B) {
    	v := nsScannerOptions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgnsScannerOptions(b *testing.B) {
    	v := nsScannerOptions{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 4.6K bytes
    - Viewed (0)
Back to top