Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,754 for target (0.17 sec)

  1. 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 {
    		target.Cancel()
    	}
    }
    
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2023-12-22 18:25
    - 5.9K bytes
    - Viewed (0)
  2. cmd/bucket-targets.go

    		if target.SourceBucket == bucket &&
    			target.TargetBucket == bucket &&
    			target.Endpoint == ep.Host &&
    			target.Secure == (ep.Scheme == "https") &&
    			target.Type == madmin.ReplicationService {
    			return target.Arn
    		}
    	}
    	return ""
    }
    
    // generate ARN that is unique to this target type
    func generateARN(t *madmin.BucketTarget, deplID string) string {
    	uuid := deplID
    	if uuid == "" {
    		uuid = mustGetUUID()
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2024-01-11 22:56
    - 21K bytes
    - Viewed (0)
  3. internal/config/lambda/event/targetlist.go

    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    func (list *TargetList) Targets() []Target {
    	if list == nil {
    		return []Target{}
    	}
    
    	list.RLock()
    	defer list.RUnlock()
    
    	targets := make([]Target, 0, len(list.targets))
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2023-03-07 16:12
    - 4.3K bytes
    - Viewed (0)
  4. internal/event/targetlist.go

    	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
    }
    
    // Exists - checks whether target by target ID exists or not.
    func (list *TargetList) Exists(id TargetID) bool {
    	list.RLock()
    	defer list.RUnlock()
    
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2023-12-14 17:09
    - 9.2K bytes
    - Viewed (0)
  5. internal/config/notify/parse.go

    		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 {
    				err = ErrTargetsOffline
    			}
    			if err != nil {
    				return fmt.Errorf("error (%s): %w", target.ID(), err)
    			}
    		} else {
    			// Just for call init.
    			// Ignore target is online or offline
    			_, _ = target.IsActive()
    		}
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2024-02-22 06:26
    - 45.8K bytes
    - Viewed (0)
  6. Makefile.core.mk

    	TARGET_OUT=$(TARGET_OUT) ISTIO_BIN=$(ISTIO_BIN) GOOS_LOCAL=$(GOOS_LOCAL) bin/retry.sh SSL_ERROR_SYSCALL bin/init.sh
    	touch $(TARGET_OUT)/istio_is_init
    
    .PHONY: init-ztunnel-rs
    init-ztunnel-rs:
    	TARGET_OUT=$(TARGET_OUT) bin/build_ztunnel.sh
    
    # Pull dependencies such as envoy
    depend: init | $(TARGET_OUT)
    
    DIRS_TO_CLEAN := $(TARGET_OUT)
    DIRS_TO_CLEAN += $(TARGET_OUT_LINUX)
    
    Plain Text
    - Registered: 2024-02-28 22:53
    - Last Modified: 2024-02-16 20:34
    - 21.6K bytes
    - Viewed (0)
  7. 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{}
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2021-06-01 21:59
    - 2.8K bytes
    - Viewed (0)
  8. internal/config/lambda/parse.go

    	if err != nil {
    		return err
    	}
    
    	for _, target := range targetList {
    		defer target.Close()
    	}
    
    	for _, target := range targetList {
    		yes, err := target.IsActive()
    		if err == nil && !yes {
    			err = ErrTargetsOffline
    		}
    		if err != nil {
    			return fmt.Errorf("error (%s): %w", target.ID(), err)
    		}
    	}
    
    	return nil
    }
    
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2023-09-04 19:57
    - 5.8K bytes
    - Viewed (0)
  9. internal/event/target/nats.go

    }
    
    func (target *NATSTarget) isActive() (bool, error) {
    	var connErr error
    	if target.args.Streaming.Enable {
    		if target.stanConn == nil || target.stanConn.NatsConn() == nil {
    			target.stanConn, connErr = target.args.connectStan()
    		} else if !target.stanConn.NatsConn().IsConnected() {
    			return false, store.ErrNotConnected
    		}
    	} else {
    		if target.natsConn == nil {
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2023-10-07 15:07
    - 12.5K bytes
    - Viewed (0)
  10. internal/event/target/kafka.go

    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *KafkaTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *KafkaTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *KafkaTarget) Store() event.TargetStore {
    	return target.store
    }
    
    Go
    - Registered: 2024-02-25 19:28
    - Last Modified: 2024-02-20 08:16
    - 13K bytes
    - Viewed (0)
Back to top