Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 1,208 for funcs (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. cmd/data-scanner-metric.go

    func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) {
    	initialPtr := unsafe.Pointer(&initial)
    	tracker := &currentPathTracker{
    		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)
  8. 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)
  9. 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)
  10. 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)
Back to Top