Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,214 for Func (0.03 sec)

  1. cmd/storage-rest-client.go

    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    func (client *storageRESTClient) LastConn() time.Time {
    	return client.restClient.LastConn()
    }
    
    func (client *storageRESTClient) IsLocal() bool {
    	return false
    }
    
    func (client *storageRESTClient) Hostname() string {
    	return client.endpoint.Host
    }
    
    func (client *storageRESTClient) Endpoint() Endpoint {
    	return client.endpoint
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/color/color.go

    		return fmt.Sprint
    	}()
    
    	RedBoldf = func() func(format string, a ...interface{}) string {
    		if IsTerminal() {
    			return color.New(color.FgRed, color.Bold).SprintfFunc()
    		}
    		return fmt.Sprintf
    	}()
    
    	Red = func() func(format string, a ...interface{}) string {
    		if IsTerminal() {
    			return color.New(color.FgRed).SprintfFunc()
    		}
    		return fmt.Sprintf
    	}()
    
    	Blue = func() func(format string, a ...interface{}) string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 17:57:52 UTC 2024
    - 3.8K 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. cmd/logging.go

    }
    
    func rebalanceLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "rebalance", err, errKind...)
    }
    
    func rebalanceLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "rebalance", msg, args...)
    }
    
    func adminLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "admin", err, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top