Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/metacache-walk.go

    				return nil
    			}
    			if contextCanceled(ctx) {
    				return ctx.Err()
    			}
    			pop := dirStack[len(dirStack)-1]
    			select {
    			case <-ctx.Done():
    				return ctx.Err()
    			case out <- metaCacheEntry{name: pop}:
    			}
    			if opts.Recursive {
    				// Scan folder we found. Should be in correct sort order where we are.
    				internalLogIf(ctx, scanDir(pop))
    			}
    			dirStack = dirStack[:len(dirStack)-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.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/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)
  5. 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)
  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. 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)
  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. 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)
  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