Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,385 for _func (0.02 sec)

  1. clause/expression.go

    			builder.AddVar(builder, neq.Value)
    		}
    	}
    }
    
    func (neq Neq) NegationBuild(builder Builder) {
    	Eq(neq).Build(builder)
    }
    
    // Gt greater than for where
    type Gt Eq
    
    func (gt Gt) Build(builder Builder) {
    	builder.WriteQuoted(gt.Column)
    	builder.WriteString(" > ")
    	builder.AddVar(builder, gt.Value)
    }
    
    func (gt Gt) NegationBuild(builder Builder) {
    	Lte(gt).Build(builder)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 10 06:45:48 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  2. cmd/batch-handlers_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobPrefix(b *testing.B) {
    	v := BatchJobPrefix{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobPrefix(b *testing.B) {
    	v := BatchJobPrefix{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. cmd/local-locker_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsglocalLockMap(b *testing.B) {
    	v := localLockMap{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsglocalLockMap(b *testing.B) {
    	v := localLockMap{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. 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)
  5. internal/http/server.go

    }
    
    // GetRequestCount - returns number of request in progress.
    func (srv *Server) GetRequestCount() int {
    	return int(atomic.LoadInt32(&srv.requestCount))
    }
    
    // Init - init HTTP server
    func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) {
    	// Take a copy of server fields.
    	var tlsConfig *tls.Config
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/lock-rest-client.go

    func (c *lockRESTClient) IsOnline() bool {
    	return c.connection.State() == grid.StateConnected
    }
    
    // Not a local locker
    func (c *lockRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close - marks the client as closed.
    func (c *lockRESTClient) Close() error {
    	return nil
    }
    
    // String - returns the remote host of the connection.
    func (c *lockRESTClient) String() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top