- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,214 for Func (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)