Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 453 for ctx_ (0.04 sec)

  1. cmd/bucket-metadata-sys.go

    	}
    
    	return updatedAt, sys.save(ctx, meta)
    }
    
    func (sys *BucketMetadataSys) save(ctx context.Context, meta BucketMetadata) error {
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	if isMinioMetaBucketName(meta.Name) {
    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    type peerS3Client interface {
    	ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error)
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. cmd/sts-handlers.go

    	// Set the newly generated credentials.
    	updatedAt, err := globalIAMSys.SetTempUser(ctx, cred.AccessKey, cred, "")
    	if err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInternalError, err)
    		return
    	}
    
    	// Call hook for site replication.
    	if cred.ParentUser != globalActiveCred.AccessKey {
    		replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    			Type: madmin.SRIAMItemSTSAcc,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    	})
    	return err
    }
    
    func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS"
    	workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets))
    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. istioctl/pkg/proxyconfig/proxyconfig.go

    	configCmd.AddCommand(clusterConfigCmd(ctx))
    	configCmd.AddCommand(allConfigCmd(ctx))
    	configCmd.AddCommand(listenerConfigCmd(ctx))
    	configCmd.AddCommand(logCmd(ctx))
    	configCmd.AddCommand(routeConfigCmd(ctx))
    	configCmd.AddCommand(bootstrapConfigCmd(ctx))
    	configCmd.AddCommand(endpointConfigCmd(ctx))
    	configCmd.AddCommand(edsConfigCmd(ctx))
    	configCmd.AddCommand(secretConfigCmd(ctx))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  6. istioctl/cmd/root.go

    	experimentalCmd.AddCommand(internaldebug.DebugCommand(ctx))
    	experimentalCmd.AddCommand(precheck.Cmd(ctx))
    	experimentalCmd.AddCommand(proxyconfig.StatsConfigCmd(ctx))
    	experimentalCmd.AddCommand(checkinject.Cmd(ctx))
    	rootCmd.AddCommand(waypoint.Cmd(ctx))
    	rootCmd.AddCommand(ztunnelconfig.ZtunnelConfig(ctx))
    
    	analyzeCmd := analyze.Analyze(ctx)
    	hideInheritedFlags(analyzeCmd, cli.FlagIstioNamespace)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Aug 05 02:08:47 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  7. cmd/ftp-server-driver.go

    func (driver *ftpDriver) Rename(ctx *ftp.Context, fromObjPath string, toObjPath string) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, fromObjPath, toObjPath)
    	defer stopFn(0, err)
    
    	return NotImplemented{}
    }
    
    // MakeDir implements ftpDriver
    func (driver *ftpDriver) MakeDir(ctx *ftp.Context, objPath string) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  8. 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)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 18 09:28:06 UTC 2022
    - 830 bytes
    - Viewed (0)
  9. internal/cachevalue/cache_test.go

    		},
    	)
    
    	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()
    
    	t1, err := cache.GetWithCtx(ctx)
    	if err != nil {
    		t.Fatalf("expected nil err, got %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/helper/LanguageHelperTest.java

            assertEquals("aaa;ctx._source.title_ja=ctx._source.title;ctx._source.content_ja=ctx._source.content",
                    languageHelper.createScript(doc, "aaa").getIdOrCode());
        }
    
        public void test_getReindexScriptSource() {
            assertEquals(
                    "if(ctx._source.lang!=null){ctx._source['title_'+ctx._source.lang]=ctx._source.title;ctx._source['content_'+ctx._source.lang]=ctx._source.content}",
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top