Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for tgts (0.09 sec)

  1. cmd/bucket-targets.go

    	if target == nil {
    		return
    	}
    	sys.RLock()
    	defer sys.RUnlock()
    	tgts := sys.targetsMap[bucket]
    	for _, tgt := range tgts {
    		if tgt.Type == target.Type &&
    			tgt.TargetBucket == target.TargetBucket &&
    			target.URL().String() == tgt.URL().String() &&
    			tgt.Credentials.AccessKey == target.Credentials.AccessKey {
    			return tgt.Arn, true
    		}
    	}
    	if !target.Type.IsValid() {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/admin-handlers-config-kv.go

    		return
    	}
    
    	result.SubSys, _, _, err = config.GetSubSys(string(kvBytes))
    	if err != nil {
    		return
    	}
    
    	tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    	ctx = context.WithValue(ctx, config.ContextKeyForTargetFromConfig, tgts)
    	if verr := validateConfig(ctx, result.Cfg, result.SubSys); verr != nil {
    		err = badConfigErr{Err: verr}
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    
    	tgts, ok := ctx.Value(config.ContextKeyForTargetFromConfig).(map[string]bool)
    	if !ok {
    		tgts = make(map[string]bool)
    	}
    	for _, target := range targetList {
    		if tgts[target.ID().ID] {
    			// When target set should be online
    			yes, err := target.IsActive()
    			if err == nil && !yes {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket)
    	replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket)
    	tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket)
    	o.Lifecycle = lc
    	o.Versioning = vc
    	o.Replication = replicationConfig{
    		Config:  replCfg,
    		remotes: tgts,
    	}
    	o.Retention = rcfg
    }
    
    // newMetacache constructs a new metacache from the options.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. src/test/java/jcifs/tests/FileOperationsTest.java

                  SmbResource tgt = new SmbFile(defaultShareRoot, makeRandomName()) ) {
                f.createNewFile();
                tgt.createNewFile();
                boolean renamed = false;
                try {
                    f.renameTo(tgt, true);
                    try {
                        assertTrue(tgt.exists());
                        renamed = true;
                    }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:17:59 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/DefaultProfileInjector.java

                List<Plugin> src = source.getPlugins();
                if (!src.isEmpty()) {
                    List<Plugin> tgt = target.getPlugins();
                    Map<Object, Plugin> master = new LinkedHashMap<>(tgt.size() * 2);
    
                    for (Plugin element : tgt) {
                        Object key = getPluginKey().apply(element);
                        master.put(key, element);
                    }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/inheritance/DefaultInheritanceAssembler.java

                    Map<Object, Object> context) {
                List<ReportPlugin> src = source.getPlugins();
                if (!src.isEmpty()) {
                    List<ReportPlugin> tgt = target.getPlugins();
                    Map<Object, ReportPlugin> merged = new LinkedHashMap<>((src.size() + tgt.size()) * 2);
    
                    for (ReportPlugin element : src) {
                        if (element.isInherited()) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. internal/config/config.go

    	newCfgKVS := make(map[string]KVS)
    	for _, e := range env.List(envname) {
    		tgt := strings.TrimPrefix(e, envname+Default)
    		if tgt == envname {
    			tgt = Default
    		}
    		newCfgKVS[tgt] = defaultKVS
    	}
    	for tgt, kv := range cfgKVS {
    		newCfgKVS[tgt] = kv
    	}
    	return newCfgKVS
    }
    
    // Set sets a value, if not sets a default value.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  9. cmd/admin-bucket-handlers.go

    					// know the site replicator creds.
    					tgt.Credentials = target.Credentials
    					tgt.TargetBucket = target.TargetBucket
    					tgt.Secure = target.Secure
    					tgt.Endpoint = target.Endpoint
    				}
    			case madmin.SyncUpdateType:
    				tgt.ReplicationSync = target.ReplicationSync
    			case madmin.ProxyUpdateType:
    				tgt.DisableProxy = target.DisableProxy
    			case madmin.PathUpdateType:
    				tgt.Path = target.Path
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/Kerb5Authenticator.java

            PREFERRED_MECHS.add(new ASN1ObjectIdentifier("1.2.840.48018.1.2.2"));
        }
    
    
        /**
         * Construct a <code>Kerb5Authenticator</code> object with <code>Subject</code>
         * which hold TGT retrieved from KDC. If multiple TGT are contained, the
         * first one will be used to retrieve user principal.
         * 
         * @param subject
         *            represents the user who perform Kerberos authentication.
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 13K bytes
    - Viewed (0)
Back to top