Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 1,021 for Func (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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. callbacks/update.go

    					called = true
    					db.AddError(i.BeforeUpdate(tx))
    				}
    			}
    
    			return called
    		})
    	}
    }
    
    // Update update hook
    func Update(config *Config) func(db *gorm.DB) {
    	supportReturning := utils.Contains(config.UpdateClauses, "RETURNING")
    
    	return func(db *gorm.DB) {
    		if db.Error != nil {
    			return
    		}
    
    		if db.Statement.Schema != nil {
    			for _, c := range db.Statement.Schema.UpdateClauses {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  3. cmd/utils_test.go

    			}
    		})
    	}
    }
    
    // Add tests for starting and stopping different profilers.
    func TestStartProfiler(t *testing.T) {
    	_, err := startProfiler("")
    	if err == nil {
    		t.Fatal("Expected a non nil error, but nil error returned for invalid profiler.")
    	}
    }
    
    // checkURL - checks if passed address correspond
    func checkURL(urlStr string) (*url.URL, error) {
    	if urlStr == "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  4. internal/config/lambda/event/targetlist.go

    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  5. cmd/event-notification.go

    func NewEventNotifier(ctx context.Context) *EventNotifier {
    	// targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets()
    	return &EventNotifier{
    		targetList:     event.NewTargetList(ctx),
    		bucketRulesMap: make(map[string]event.RulesMap),
    	}
    }
    
    // GetARNList - returns available ARNs.
    func (evnot *EventNotifier) GetARNList() []string {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 21 22:22:24 GMT 2024
    - 7.7K bytes
    - Click Count (0)
  6. tests/preload_test.go

    	sort.Slice(users2, func(i, j int) bool {
    		return users2[i].ID < users2[j].ID
    	})
    
    	for idx, user := range users2[1:2] {
    		if user.Account.Number != "" {
    			t.Errorf("No account should found for user %v but got %v", idx+2, user.Account.Number)
    		}
    	}
    
    	CheckUser(t, users2[0], users[0])
    
    	var users3 []User
    	if err := DB.Preload("Account", func(tx *gorm.DB) *gorm.DB {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Wed Jun 12 10:00:47 GMT 2024
    - 15.9K bytes
    - Click Count (0)
  7. cmd/xl-storage-errors.go

    	"errors"
    	"os"
    	"runtime"
    	"syscall"
    )
    
    // No space left on device error
    func isSysErrNoSpace(err error) bool {
    	return errors.Is(err, syscall.ENOSPC)
    }
    
    // Invalid argument, unsupported flags such as O_DIRECT
    func isSysErrInvalidArg(err error) bool {
    	return errors.Is(err, syscall.EINVAL)
    }
    
    // Input/output error
    func isSysErrIO(err error) bool {
    	return errors.Is(err, syscall.EIO)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Mar 06 16:56:29 GMT 2023
    - 3.8K bytes
    - Click Count (0)
  8. 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)
  9. internal/grid/benchmark_test.go

    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func BenchmarkRequests(b *testing.B) {
    	for n := 2; n <= 32; n *= 2 {
    		b.Run("servers="+strconv.Itoa(n), func(b *testing.B) {
    			benchmarkGridRequests(b, n)
    		})
    	}
    }
    
    func benchmarkGridRequests(b *testing.B, n int) {
    	defer testlogger.T.SetErrorTB(b)()
    	errFatal := func(err error) {
    		b.Helper()
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  10. internal/s3select/simdj/record.go

    type Record struct {
    	// object
    	object simdjson.Object
    }
    
    // Get - gets the value for a column name.
    func (r *Record) Get(name string) (*sql.Value, error) {
    	elem := r.object.FindKey(name, nil)
    	if elem == nil {
    		return nil, nil
    	}
    	return iterToValue(elem.Iter)
    }
    
    func iterToValue(iter simdjson.Iter) (*sql.Value, error) {
    	switch iter.Type() {
    	case simdjson.TypeString:
    		v, err := iter.String()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top