- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 119 for initialize (0.15 sec)
-
cmd/typed-errors.go
var errInvalidRangeSource = errors.New("Range specified exceeds source object size") // error returned by disks which are to be initialized are waiting for the // first server to initialize them in distributed set to initialize them. var errNotFirstDisk = errors.New("Not first drive") // error returned by first disk waiting to initialize other servers. var errFirstDiskWait = errors.New("Waiting on other drives") // error returned for a negative actual size.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cmd/config-current.go
configLogIf(ctx, fmt.Errorf("Unable to initialize remote webhook DNS config %w", err)) } if err == nil && dnsURL != "" { bootstrapTraceMsg("initialize remote bucket DNS store") globalDNSConfig, err = dns.NewOperatorDNS(dnsURL, dns.Authentication(dnsUser, dnsPass), dns.RootCAs(globalRootCAs)) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize remote webhook DNS config %w", err)) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/test-utils_test.go
return objLayer, formattedDisks, nil } // removeRoots - Cleans up initialized directories during tests. func removeRoots(roots []string) { for _, root := range roots { os.RemoveAll(root) } } // creates a bucket for the tests and returns the bucket name. // initializes the specified API endpoints for the tests. // initializes the root and returns its path. // return credentials.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/auth-handler_test.go
func mustNewRequest(method string, urlStr string, contentLength int64, body io.ReadSeeker, t *testing.T) *http.Request { req, err := newTestRequest(method, urlStr, contentLength, body) if err != nil { t.Fatalf("Unable to initialize new http request %s", err) } return req } // This is similar to mustNewRequest but additionally the request // is signed with AWS Signature V4, fails if not able to do so.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/cachevalue/cache.go
ttl time.Duration opts Opts // Once can be used to initialize values for lazy initialization. // Should be set before calling Get(). Once sync.Once // Managed values. valErr atomic.Pointer[struct { v T e error }] lastUpdateMs atomic.Int64 updating sync.Mutex } // New allocates a new cached value instance. Tt must be initialized with // `.TnitOnce`. func New[T any]() *Cache[T] {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
return types.TargetStats{ TotalMessages: atomic.LoadInt64(&h.totalMessages), FailedMessages: atomic.LoadInt64(&h.failedMessages), QueueLength: queueLength, } } // Init initialize kafka target func (h *Target) Init(ctx context.Context) error { if !h.kconfig.Enabled { return nil } if err := h.validate(); err != nil { return err } if h.kconfig.QueueDir != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/bucket-quota.go
cfg, _, err := globalBucketMetadataSys.GetQuotaConfig(ctx, bucketName) return cfg, err } // NewBucketQuotaSys returns initialized BucketQuotaSys func NewBucketQuotaSys() *BucketQuotaSys { return &BucketQuotaSys{} } var bucketStorageCache = cachevalue.New[DataUsageInfo]() // Init initialize bucket quota. func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) { bucketStorageCache.InitOnce(10*time.Second,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
cmd/format-erasure.go
// loadFormatErasureAll - load all format config from all input disks in parallel. func loadFormatErasureAll(storageDisks []StorageAPI, heal bool) ([]*formatErasureV3, []error) { // Initialize list of errors. g := errgroup.WithNErrs(len(storageDisks)) // Initialize format configs. formats := make([]*formatErasureV3, len(storageDisks)) // Load format from each disk in parallel for index := range storageDisks { index := index
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/post-policy_test.go
objectName := "config/x" // This exploit needs browser to be enabled. if !globalBrowserEnabled { globalBrowserEnabled = true defer func() { globalBrowserEnabled = false }() } // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
cmd/storage-rest-server.go
logger.Fatal(config.ErrUnableToWriteInBackend(err).Hint(hint), "Unable to initialize backend") } case errors.Is(err, errFaultyDisk): if !exit { storageLogOnceIf(GlobalContext, fmt.Errorf("Drive is faulty at %s, please replace the drive - drive will be offline", endpoint), "log-fatal-errs") } else { logger.Fatal(err, "Unable to initialize backend") } case errors.Is(err, errDiskFull): if !exit {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0)