Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 350 for ctx (0.02 seconds)

  1. internal/logger/targets.go

    func UpdateHTTPWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) {
    	return updateHTTPTargets(ctx, cfgs, systemTargets)
    }
    
    // UpdateAuditWebhooks swaps audit webhook targets with newly loaded ones from the cfg
    func UpdateAuditWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) {
    	return updateHTTPTargets(ctx, cfgs, auditTargets)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6K bytes
    - Click Count (0)
  2. cmd/config-current.go

    			}
    			loggerCfg.HTTP[n] = l
    		}
    		if errs := logger.UpdateHTTPWebhooks(ctx, loggerCfg.HTTP); len(errs) > 0 {
    			configLogIf(ctx, fmt.Errorf("Unable to update logger webhook config: %v", errs))
    		}
    	case config.AuditWebhookSubSys:
    		loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.AuditWebhookSubSys)
    		if err != nil {
    			configLogIf(ctx, fmt.Errorf("Unable to load audit webhook config: %w", err))
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  3. cmd/config.go

    	})
    	return err
    }
    
    func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) {
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix)
    	data, err := readConfig(ctx, objAPI, historyFile)
    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  4. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    
    		c.healBucket(ctx, objAPI, bucket, info)
    
    		if bi.Deleted.IsZero() || (!bi.Created.IsZero() && bi.Deleted.Before(bi.Created)) {
    			c.healVersioningMetadata(ctx, objAPI, bucket, info)
    			c.healOLockConfigMetadata(ctx, objAPI, bucket, info)
    			c.healSSEMetadata(ctx, objAPI, bucket, info)
    			c.healBucketReplicationConfig(ctx, objAPI, bucket, info, &opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  5. tests/tracer_test.go

    }
    
    func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Error(ctx, s, i...)
    }
    
    func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	S.Logger.Trace(ctx, begin, fc, err)
    	S.Test(ctx, begin, fc, err)
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Tue Oct 18 09:28:06 GMT 2022
    - 830 bytes
    - Click Count (0)
  6. cmd/erasure-multipart-conditional_test.go

    	ctx := context.Background()
    
    	obj, fsDirs, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(context.Background())
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    
    	bucket := "test-bucket"
    	object := "test-object"
    
    	err = obj.MakeBucket(ctx, bucket, MakeBucketOptions{})
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  7. cmd/config-common.go

    	}
    	return buf, r.ObjInfo, nil
    }
    
    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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Click Count (0)
  8. internal/cachevalue/cache_test.go

    		},
    	)
    
    	ctx, cancel := context.WithCancel(t.Context())
    	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(t.Context())
    	defer cancel()
    
    	t1, err := cache.GetWithCtx(ctx)
    	if err != nil {
    		t.Fatalf("expected nil err, got %v", err)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  9. cmd/erasure-object.go

    	}
    	return false
    }
    
    func readAllXL(ctx context.Context, disks []StorageAPI, bucket, object string, readData, inclFreeVers bool) ([]FileInfo, []error) {
    	rawFileInfos, errs := readAllRawFileInfo(ctx, disks, bucket, object, readData)
    	return pickLatestQuorumFilesInfo(ctx, rawFileInfos, errs, bucket, object, readData, inclFreeVers)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  10. schema/serializer.go

    // Scan implements serializer interface
    func (UnixSecondSerializer) Scan(ctx context.Context, field *Field, dst reflect.Value, dbValue interface{}) (err error) {
    	t := sql.NullTime{}
    	if err = t.Scan(dbValue); err == nil && t.Valid {
    		err = field.Set(ctx, dst, t.Time.Unix())
    	}
    
    	return
    }
    
    // Value implements serializer interface
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:29:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top