- Sort Score
- Num 10 results
- Language All
Results 81 - 90 of 1,208 for funcs (0.02 seconds)
-
cmd/config.go
func (sys *ConfigSys) Init(objAPI ObjectLayer) error { if objAPI == nil { return errInvalidArgument } return initConfig(objAPI) } // NewConfigSys - creates new config system object. func NewConfigSys() *ConfigSys { return &ConfigSys{} } // Initialize and load config from remote etcd or local config directory func initConfig(objAPI ObjectLayer) (err error) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.9K bytes - Click Count (0) -
internal/cachevalue/cache.go
} // New allocates a new cached value instance. Tt must be initialized with // `.TnitOnce`. func New[T any]() *Cache[T] { return &Cache[T]{} } // NewFromFunc allocates a new cached value instance and initializes it with an // update function, making it ready for use. func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri May 24 12:50:46 GMT 2024 - 4.4K bytes - Click Count (0) -
schema/schema_test.go
} for i := range fields { checkSchemaField(t, user, &fields[i], func(f *schema.Field) { f.Creatable = true f.Updatable = true f.Readable = true }) } } type CustomizeTable struct{} func (CustomizeTable) TableName() string { return "customize" } func TestCustomizeTableName(t *testing.T) {Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Thu Aug 28 02:57:17 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/notification.go
// returns the slice of errors from all function calls. func (g *NotificationGroup) Wait() []NotificationPeerErr { g.workers.Wait() return g.errs } // Go calls the given function in a new goroutine. // // The first call to return a non-nil error will be // collected in errs slice and returned by Wait(). func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
migrator/index.go
} // Table return the table name of the index. func (idx Index) Table() string { return idx.TableName } // Name return the name of the index. func (idx Index) Name() string { return idx.NameValue } // Columns return the columns of the index func (idx Index) Columns() []string { return idx.ColumnList } // PrimaryKey returns the index is primary key or not. func (idx Index) PrimaryKey() (isPrimaryKey bool, ok bool) {
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Tue Apr 11 02:32:46 GMT 2023 - 1023 bytes - Click Count (0) -
cmd/bucket-replication-metrics_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgActiveWorkerStat(b *testing.B) { v := ActiveWorkerStat{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgActiveWorkerStat(b *testing.B) { v := ActiveWorkerStat{} bts := make([]byte, 0, v.Msgsize())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) { atomic.StorePointer(tracker.name, unsafe.Pointer(&path)) }, func() { p.currentPaths.Delete(disk) } }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
soft_delete.go
} type SoftDeleteQueryClause struct { ZeroValue sql.NullString Field *schema.Field } func (sd SoftDeleteQueryClause) Name() string { return "" } func (sd SoftDeleteQueryClause) Build(clause.Builder) { } func (sd SoftDeleteQueryClause) MergeClause(*clause.Clause) { } func (sd SoftDeleteQueryClause) ModifyStatement(stmt *Statement) {Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 4.5K bytes - Click Count (1) -
cmd/batch-job-common-types_gen.go
return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z BatchJobKV) Msgsize() (s int) { s = 1 + 4 + msgp.StringPrefixSize + len(z.Key) + 6 + msgp.StringPrefixSize + len(z.Value) return } // DecodeMsg implements msgp.Decodable func (z *BatchJobNotification) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 21.9K bytes - Click Count (0) -
cmd/bucket-replication-utils_gen_test.go
} if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBucketReplicationResyncStatus(b *testing.B) { v := BucketReplicationResyncStatus{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 23K bytes - Click Count (0)