- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,179 for funcs (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)