Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 795 for target (0.05 seconds)

  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 group1, group2
    }
    
    func cancelTargets(targets []Target) {
    	for _, target := range targets {
    		go target.Cancel()
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6K bytes
    - Click Count (0)
  2. 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()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  3. internal/event/target/nsq.go

    func (target *NSQTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *NSQTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *NSQTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  4. internal/event/target/redis.go

    func (target *RedisTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *RedisTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *RedisTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  5. 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{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.8K bytes
    - Click Count (0)
  6. internal/config/lambda/parse.go

    		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
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  7. internal/rest/client_test.go

    			}
    			//nolint:gocritic
    			if tt.target == nil {
    				var netErrInterface net.Error
    				if errors.As(n, &netErrInterface) != tt.want {
    					t.Errorf("errors.As(n, &tt.target) != tt.want, n: %#v, target: %#v, want:%v, got: %v", n, tt.target, tt.want, !tt.want)
    				}
    			} else {
    				if errors.As(n, &tt.target) != tt.want {
    					t.Errorf("errors.As(n, &tt.target) != tt.want, n: %#v, target: %#v, want:%v, got: %v", n, tt.target, tt.want, !tt.want)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  8. impl/maven-core/src/main/java/org/apache/maven/model/plugin/DefaultLifecycleBindingsInjector.java

            public void merge(Model target, Model source) {
                if (target.getBuild() == null) {
                    target.setBuild(new Build());
                }
    
                Map<Object, Object> context = Collections.singletonMap(
                        PLUGIN_MANAGEMENT, target.getBuild().getPluginManagement());
    
                mergePluginContainer_Plugins(target.getBuild(), source.getBuild(), false, context);
            }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  9. internal/event/target/mqtt.go

    func (target *MQTTTarget) Name() string {
    	return target.ID().String()
    }
    
    // Store returns any underlying store if set.
    func (target *MQTTTarget) Store() event.TargetStore {
    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *MQTTTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  10. docs/ja/docs/help-fastapi.md

    ## 開発者とつながる
    
    以下で、<a href="https://tiangolo.com" class="external-link" target="_blank">開発者 (Sebastián Ramírez / `tiangolo`)</a> とコンタクトをとれます:
    
    * <a href="https://github.com/tiangolo" class="external-link" target="_blank">**GitHub** でフォロー</a>。
        * 他のオープンソースプロジェクトを確認できます。何かの助けになるものが見つかるかもしれません。
        * 新たなオープンソースプロジェクトを作成したときに通知されます。
    * <a href="https://x.com/tiangolo" class="external-link" target="_blank">**X (Twitter)** でフォロー</a>。
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 10:49:48 GMT 2025
    - 5.9K bytes
    - Click Count (0)
Back to Top