Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for target01 (0.15 sec)

  1. cmd/event-notification.go

    	}
    	region := globalSite.Region()
    	for targetID, target := range evnot.targetList.TargetMap() {
    		// httpclient target is part of ListenNotification
    		// which doesn't need to be listed as part of the ARN list
    		// This list is only meant for external targets, filter
    		// this out pro-actively.
    		if !strings.HasPrefix(targetID.ID, "httpclient+") {
    			if onlyActive {
    				if _, err := target.IsActive(); err != nil {
    					continue
    				}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  2. 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()
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. internal/event/target/webhook.go

    }
    
    // ID - returns target ID.
    func (target *WebhookTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    func (target *WebhookTarget) Name() string {
    	return target.ID().String()
    }
    
    // IsActive - Return true if target is up and active
    func (target *WebhookTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.5K bytes
    - Viewed (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()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/types2/compiler_internal.go

    // and the object and new field name are returned.
    //
    // The intended use for RenameResult is to allow rangefunc to assign results within a closure.
    // This is a hack, as narrowly targeted as possible to discourage abuse.
    func (s *Signature) RenameResult(results []*syntax.Field, i int) (*Var, *syntax.Name) {
    	a := results[i]
    	obj := s.Results().At(i)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 21:08:03 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  6. platforms/jvm/plugins-application/src/main/java/org/gradle/api/tasks/application/CreateStartScripts.java

     * }
     * </pre>
     * <p>
     * Note: the Gradle {@code "application"} plugin adds a pre-configured task of this type named {@code "startScripts"}.
     * <p>
     * The task generates separate scripts targeted at Microsoft Windows environments and UNIX-like environments (e.g. Linux, macOS).
     * The actual generation is implemented by the {@link #getWindowsStartScriptGenerator()} and {@link #getUnixStartScriptGenerator()} properties, of type
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Feb 28 23:38:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/tf2xla/transforms/xla_legalize_tf_passes.td

                        "ops."}];
    
      let options = [
        Option<"device_type_", "device-type", "std::string",
            /*default=*/"\"INVALID_DEVICE_TYPE\"",
            "The device type being targeted.">,
      ];
    
      let constructor = "mlir::mhlo::CreateTFXLADeviceSpecificTransformsPass()";
    }
    
    def InfeedOpsXlaAdjustLayout : Pass<"infeed-ops-xla-adjust-layout",
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Mar 21 17:44:14 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. cmd/listen-notification-handlers.go

    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	setEventStreamHeaders(w)
    
    	// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. src/runtime/cpuprof.go

    	// by the fact that only one SIGPROF can be handled by the
    	// process at a time. If not, this lock will serialize those too.
    	// The use of timer_create(2) on Linux to request process-targeted
    	// signals may have changed this.)
    	for !prof.signalLock.CompareAndSwap(0, 1) {
    		// TODO: Is it safe to osyield here? https://go.dev/issue/52672
    		osyield()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top