Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 1,612 for _targets (0.09 sec)

  1. cmd/bucket-replication-utils.go

    // ResyncDecision is a struct representing a map with target's individual resync decisions
    type ResyncDecision struct {
    	targets map[string]ResyncTargetDecision
    }
    
    // Empty returns true if no targets with resync decision present
    func (r ResyncDecision) Empty() bool {
    	return r.targets == nil
    }
    
    func (r ResyncDecision) mustResync() bool {
    	for _, v := range r.targets {
    		if v.Replicate {
    			return true
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    			Value: "2",
    		},
    	}
    )
    
    // GetNotifyMySQL - returns a map of registered notification 'mysql' targets
    func GetNotifyMySQL(mysqlKVS map[string]config.KVS) (map[string]target.MySQLArgs, error) {
    	mysqlTargets := make(map[string]target.MySQLArgs)
    	for k, kv := range config.Merge(mysqlKVS, target.EnvMySQLEnable, DefaultMySQLKVS) {
    		enableEnv := target.EnvMySQLEnable
    		if k != config.Default {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  3. internal/config/config.go

    		srvCfg[k][Default] = DefaultKVS[k]
    	}
    	return srvCfg
    }
    
    // Target signifies an individual target
    type Target struct {
    	SubSystem string
    	KVS       KVS
    }
    
    // Targets sub-system targets
    type Targets []Target
    
    // GetKVS - get kvs from specific subsystem.
    func (c Config) GetKVS(s string, defaultKVS map[string]KVS) (Targets, error) {
    	if len(s) == 0 {
    		return nil, Errorf("input cannot be empty")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  4. internal/config/lambda/parse.go

    // GetLambdaWebhook - returns a map of registered notification 'webhook' targets
    func GetLambdaWebhook(webhookKVS map[string]config.KVS, transport *http.Transport) (
    	map[string]target.WebhookArgs, error,
    ) {
    	webhookTargets := make(map[string]target.WebhookArgs)
    	for k, kv := range config.Merge(webhookKVS, target.EnvWebhookEnable, DefaultWebhookKVS) {
    		enableEnv := target.EnvWebhookEnable
    		if k != config.Default {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils_test.go

    	},
    	{ // 2. replication status for one target
    		name:      "replication status for one target",
    		rs:        ReplicationState{ReplicationStatusInternal: "arn1=PENDING;", Targets: map[string]replication.StatusType{"arn1": "PENDING"}},
    		expStatus: replication.Pending,
    	},
    	{ // 3. replication status for one target - incorrect format
    		name:      "replication status for one target",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 08 20:27:40 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  6. docs/bucket/replication/DESIGN.md

    important exceptions.
    
    Replication status on the source cluster will be marked as `COMPLETED` only after replication is completed on all targets. If one or more targets failed replication, the replication status is reflected as `PENDING`.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/RegularImmutableSortedSet.java

          return super.containsAll(targets);
        }
    
        /*
         * If targets is a sorted set with the same comparator, containsAll can run
         * in O(n) time stepping through the two collections.
         */
        Iterator<E> thisIterator = iterator();
    
        Iterator<?> thatIterator = targets.iterator();
        // known nonempty since we checked targets.size() > 1
    
        if (!thisIterator.hasNext()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/lang/StringUtil.java

            if (target1 == null || target2 == null) {
                return false;
            }
            final int length1 = target1.length();
            final int length2 = target2.length();
            if (length1 < length2) {
                return false;
            }
            final String s1 = target1.substring(0, target2.length());
            return s1.equalsIgnoreCase(target2);
        }
    
        /**
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  9. src/buildall.bash

    }
    
    # put linux first in the target list to get all the architectures up front.
    linux_targets() {
    	selectedtargets | grep 'linux' | sort
    }
    
    non_linux_targets() {
    	selectedtargets | grep -v 'linux' | sort
    }
    
    # Note words in $targets are separated by both newlines and spaces.
    targets="$(linux_targets) $(non_linux_targets)"
    
    failed=false
    for target in $targets
    do
    	echo ""
    	echo "### Building $target"
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Apr 23 17:45:23 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. internal/config/notify/config.go

    		PostgreSQL:    make(map[string]target.PostgreSQLArgs),
    		Elasticsearch: make(map[string]target.ElasticsearchArgs),
    	}
    	cfg.NSQ[defaultTarget] = target.NSQArgs{}
    	cfg.AMQP[defaultTarget] = target.AMQPArgs{}
    	cfg.MQTT[defaultTarget] = target.MQTTArgs{}
    	cfg.NATS[defaultTarget] = target.NATSArgs{}
    	cfg.Redis[defaultTarget] = target.RedisArgs{}
    	cfg.MySQL[defaultTarget] = target.MySQLArgs{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.8K bytes
    - Viewed (0)
Back to top