- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 101 for broadcast_or (0.33 sec)
-
docs/zh/docs/advanced/websockets.md
!!! tip 上面的应用程序是一个最小和简单的示例,用于演示如何处理和向多个 WebSocket 连接广播消息。 但请记住,由于所有内容都在内存中以单个列表的形式处理,因此它只能在进程运行时工作,并且只能使用单个进程。 如果您需要与 FastAPI 集成更简单但更强大的功能,支持 Redis、PostgreSQL 或其他功能,请查看 [encode/broadcaster](https://github.com/encode/broadcaster)。 ## 更多信息 要了解更多选项,请查看 Starlette 的文档: * [WebSocket 类](https://www.starlette.io/websockets/)
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Oct 17 05:59:11 UTC 2023 - 6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
defer runtime.HandleCrash() defer adc.pvcQueue.ShutDown() // Start events processing pipeline. adc.broadcaster.StartStructuredLogging(3) adc.broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: adc.kubeClient.CoreV1().Events("")}) defer adc.broadcaster.Shutdown() logger := klog.FromContext(ctx) logger.Info("Starting attach detach controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
docs/en/docs/advanced/websockets.md
If you need something easy to integrate with FastAPI but that is more robust, supported by Redis, PostgreSQL or others, check <a href="https://github.com/encode/broadcaster" class="external-link" target="_blank">encode/broadcaster</a>. ## More info To learn more about the options, check Starlette's documentation for:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 02 22:37:31 UTC 2024 - 6.2K bytes - Viewed (0) -
tensorflow/cc/framework/fuzzing/op_fuzzing.bzl
op_names = [ "BatchMatrixBandPart", "BatchMatrixDiag", "BatchMatrixDiagPart", "BatchMatrixSetDiag", "BatchToSpace", "BatchToSpaceND", "Bitcast", "BroadcastArgs", "BroadcastTo", "CheckNumerics", "ConcatV2", "ConjugateTranspose", "DebugGradientIdentity", "DeepCopy", "DepthToSpace", "Dequantize", "EditDistance", "Empty", "EnsureShape",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Nov 07 19:14:57 UTC 2022 - 4.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/transforms/unfuse_batch_norm_pass.cc
rewriter.getIndexType()), operand); } Value materializeEpsilon(Operation *op, FloatAttr epsilon_attr, FloatType fp_type, Value broadcast_to, RankedTensorType broadcast_to_type, PatternRewriter &rewriter) { ImplicitLocOpBuilder b(op->getLoc(), rewriter); if (epsilon_attr.getType() != fp_type) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 11.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/transforms/legalize_tf.cc
} // Broadcasts `input` to the shape of `broadcast_to` value following // TF::BroadcastTo semantics. // // Requires that input is a ranked tensor. // // TODO(hinsu): Utilize TF::ShapeOp followed by TF::BroadcastTo once ShapeOp // supports unranked inputs in the lowering. static Value BroadcastToShapeOf(Location loc, Value input, Value broadcast_to, OpBuilder &builder) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 20:00:43 UTC 2024 - 291.8K bytes - Viewed (1) -
pkg/scheduler/profile/profile.go
if err != nil { errs = append(errs, fmt.Errorf("framework %s failed to close: %w", name, err)) } } return errors.Join(errs...) } // NewRecorderFactory returns a RecorderFactory for the broadcaster. func NewRecorderFactory(b events.EventBroadcaster) RecorderFactory { return func(name string) events.EventRecorder { return b.NewRecorder(scheme.Scheme, name) } } type cfgValidator struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 06 01:11:19 UTC 2024 - 4K bytes - Viewed (0) -
docs/ja/docs/advanced/websockets.md
しかし、すべての接続がメモリ内の単一のリストで処理されるため、プロセスの実行中にのみ機能し、単一のプロセスでのみ機能することに注意してください。 もしFastAPIと簡単に統合できて、RedisやPostgreSQLなどでサポートされている、より堅牢なものが必要なら、<a href="https://github.com/encode/broadcaster" class="external-link" target="_blank">encode/broadcaster</a> を確認してください。 ## その他のドキュメント オプションの詳細については、Starletteのドキュメントを確認してください。 * <a href="https://www.starlette.io/websockets/" class="external-link" target="_blank"> `WebSocket` クラス</a>
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Nov 13 13:58:31 UTC 2022 - 7.2K bytes - Viewed (0) -
docs/em/docs/advanced/websockets.md
✋️ ✔️ 🤯 👈, 🌐 🍵 💾, 👁 📇, ⚫️ 🔜 🕴 👷 ⏪ 🛠️ 🏃, & 🔜 🕴 👷 ⏮️ 👁 🛠️. 🚥 👆 💪 🕳 ⏩ 🛠️ ⏮️ FastAPI ✋️ 👈 🌖 🏋️, 🐕🦺 ✳, ✳ ⚖️ 🎏, ✅ <a href="https://github.com/encode/broadcaster" class="external-link" target="_blank">🗜/📻</a>. ## 🌅 ℹ 💡 🌅 🔃 🎛, ✅ 💃 🧾: * <a href="https://www.starlette.io/websockets/" class="external-link" target="_blank"> `WebSocket` 🎓</a>.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Apr 01 09:26:04 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
serviceCIDRInformer networkinginformers.ServiceCIDRInformer, ipAddressInformer networkinginformers.IPAddressInformer, client clientset.Interface, ) *Controller { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: controllerName}) c := &Controller{ client: client, queue: workqueue.NewTypedRateLimitingQueueWithConfig(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0)