Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 979 for ntargets (0.15 sec)

  1. internal/config/lambda/event/targetlist.go

    }
    
    // TargetList - holds list of targets indexed by target ID.
    type TargetList struct {
    	sync.RWMutex
    	targets map[TargetID]Target
    }
    
    // Add - adds unique target to target list.
    func (list *TargetList) Add(targets ...Target) error {
    	list.Lock()
    	defer list.Unlock()
    
    	for _, target := range targets {
    		if _, ok := list.targets[target.ID()]; ok {
    			return fmt.Errorf("target %v already exists", target.ID())
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. internal/event/targetlist.go

    	targetSet TargetIDSet
    }
    
    // Add - adds unique target to target list.
    func (list *TargetList) Add(targets ...Target) error {
    	list.Lock()
    	defer list.Unlock()
    
    	for _, target := range targets {
    		if _, ok := list.targets[target.ID()]; ok {
    			return fmt.Errorf("target %v already exists", target.ID())
    		}
    		list.targets[target.ID()] = target
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    //	group2 contains the remaining targets
    func splitTargets(targets []Target, t types.TargetType) (group1 []Target, group2 []Target) {
    	for _, target := range targets {
    		if target.Type() == t {
    			group1 = append(group1, target)
    		} else {
    			group2 = append(group2, target)
    		}
    	}
    	return
    }
    
    func cancelTargets(targets []Target) {
    	for _, target := range targets {
    		go target.Cancel()
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K 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. 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)
  7. 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)
  8. 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)
  9. internal/config/lambda/config.go

    import "github.com/minio/minio/internal/event/target"
    
    // Config - lambda target configuration structure, holds
    // information about various lambda targets.
    type Config struct {
    	Webhook map[string]target.WebhookArgs `json:"webhook"`
    }
    
    const (
    	defaultTarget = "1"
    )
    
    // NewConfig - initialize lambda config.
    func NewConfig() Config {
    	// Make sure to initialize lambda targets
    	cfg := Config{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  10. architecture/runtimes.md

            daemon --> worker3
        
    ```
    
    These are all Java processes. Each process has a corresponding "runtime".
    All source code in Gradle is written to target one or more of these runtimes.
    Most source code targets the daemon and the remaining code either targets a single runtime, for example the Gradle client, or is shared across multiple runtimes.
    
    ## Composition by architecture modules
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu May 02 06:42:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top