- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 677 for Contexto (0.21 sec)
-
cmd/config-common.go
} func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) { buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{}) return buf, err } type objectDeleter interface { DeleteObject(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) } func deleteConfig(ctx context.Context, objAPI objectDeleter, configFile string) error {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints) } } // Test printing server common message. func TestPrintServerCommonMessage(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 3K bytes - Viewed (0) -
cmd/namespace-lock.go
type RWLocker interface { GetLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error) Unlock(lkCtx LockContext) GetRLock(ctx context.Context, timeout *dynamicTimeout) (lkCtx LockContext, timedOutErr error) RUnlock(lkCtx LockContext) } // LockContext lock context holds the lock backed context and canceler for the context. type LockContext struct { ctx context.Context cancel context.CancelFunc }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/iam-object-store.go
return p, nil } func (iamOS *IAMObjectStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error { p, err := iamOS.loadPolicy(ctx, policy) if err != nil { return err } m[policy] = p return nil } func (iamOS *IAMObjectStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error { ctx, cancel := context.WithCancel(ctx) defer cancel()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Oct 10 23:40:37 UTC 2024 - 26.6K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
health *diskHealthTracker healthCheck bool metricsCache *cachevalue.Cache[DiskMetrics] diskCtx context.Context diskCancel context.CancelFunc } func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics { p.metricsCache.InitOnce(5*time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskMetrics, error) { diskMetric := DiskMetrics{ LastMinute: make(map[string]AccElem, len(p.apiLatencies)),
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
api/next/36532.txt
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Aug 20 14:58:54 UTC 2024 - 239 bytes - Viewed (0) -
internal/cachevalue/cache_test.go
cache.InitOnce(2*time.Second, Opts{}, func(ctx context.Context) (time.Time, error) { return time.Now(), slowCaller(ctx) }, ) ctx, cancel := context.WithCancel(context.Background()) cancel() // cancel context to test. _, err := cache.GetWithCtx(ctx) if !errors.Is(err, context.Canceled) { t.Fatalf("expected context.Canceled err, got %v", err) } ctx, cancel = context.WithCancel(context.Background()) defer cancel()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 2.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// If the deadline/context passes before the function finishes executing, // the zero value and the context error is returned. func WithDeadline[V any](ctx context.Context, timeout time.Duration, work func(ctx context.Context) (result V, err error)) (result V, err error) { ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() c := make(chan ioret[V], 1)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 10.9K bytes - Viewed (0) -
schema/serializer.go
Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) } // JSONSerializer json serializer type JSONSerializer struct{} // Scan implements serializer interface func (JSONSerializer) Scan(ctx context.Context, field *Field, dst reflect.Value, dbValue interface{}) (err error) { fieldValue := reflect.New(field.FieldType) if dbValue != nil { var bytes []byte
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Thu Jun 20 08:45:38 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/kms/stub.go
func (s StubKMS) Version(ctx context.Context) (string, error) { return "stub", nil } // APIs returns supported APIs func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) { return []madmin.KMSAPI{ {Method: http.MethodGet, Path: "stub/path"}, }, nil } // Status returns a set of endpoints and their KMS status. func (s StubKMS) Status(context.Context) (map[string]madmin.ItemState, error) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 3.6K bytes - Viewed (0)