- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for target01 (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)