- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 677 for Contexto (0.27 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) -
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/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) -
api/go1.7.txt
pkg compress/flate, const HuffmanOnly ideal-int pkg context, func Background() Context pkg context, func TODO() Context pkg context, func WithCancel(Context) (Context, CancelFunc) pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc) pkg context, func WithTimeout(Context, time.Duration) (Context, CancelFunc) pkg context, func WithValue(Context, interface{}, interface{}) Context pkg context, type CancelFunc func()
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Jun 28 15:08:11 UTC 2016 - 13.6K bytes - Viewed (0)