- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,561 for fanout (0.18 sec)
-
src/internal/trace/testdata/tests/go122-annotations-stress.test
String id=65 data="fanout region4" String id=66 data="fanout region0" String id=67 data="fanout region1" String id=68 data="fanout region2" String id=69 data="before do" String id=70 data="do" String id=71 data="fanout region3" String id=72 data="before do" String id=73 data="do" String id=74 data="fanout region3" String id=75 data="fanout region0" String id=76
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 38.3K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/annotations-stress.go
defer t.End() trace.Log(ctx, "log2", "do") // Create a region and spawn more tasks and more workers. trace.WithRegion(ctx, "fanout", func() { for i := 0; i < k; i++ { go func(i int) { trace.WithRegion(ctx, fmt.Sprintf("region%d", i), func() { trace.Logf(ctx, "log", "fanout region%d", i) if i == 2 { do(ctx, 0) return } }) }(i) } })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/internal/trace/summary_test.go
{Task: 12, Category: "log", Message: "fanout region4"}, {Task: 12, Category: "log", Message: "fanout region0"}, {Task: 12, Category: "log", Message: "fanout region1"}, {Task: 12, Category: "log", Message: "fanout region2"}, {Task: 12, Category: "log", Message: "before do"}, {Task: 12, Category: "log", Message: "fanout region3"}, }, goroutines: []trace.GoID{1, 5, 6, 7, 8, 9}, },
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 13.4K bytes - Viewed (0) -
docs/extensions/fan-out/README.md
## How to enable Fan-Out Uploads ? Fan-Out uploads are automatically enabled if `x-minio-fanout-list` form-field is provided with the PostUpload API, to keep things simple higher level APIs are provided in our SDKs for example in `minio-go` SDK: ```
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 25 05:51:07 UTC 2023 - 1.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/order_by_dialect.mlir
"z.a"(%arg0) : (f32) -> () func.return %arg0 : f32 } // CHECK: x.a // CHECK: y.a // CHECK: z.a // CHECK: return // CHECK-NOT: call // CHECK: } // ----- // CHECK-LABEL: @fanout func.func @fanout(%arg0: f32) -> (f32) attributes {ignore_side_effects_for_testing} { %0 = "x.a"(%arg0) : (f32) -> (f32) %1 = "y.a"(%0) : (f32) -> (f32) %2 = "y.b"(%0) : (f32) -> (f32) %3 = "y.c"(%0) : (f32) -> (f32)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 06 15:32:52 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/hash/reader.go
} // Options are optional arguments to NewReaderWithOpts, Options // simply converts positional arguments to NewReader() into a // more flexible way to provide optional inputs. This is currently // used by the FanOut API call mostly to disable expensive md5sum // calculation repeatedly under hash.Reader. type Options struct { MD5Hex string SHA256Hex string Size int64 ActualSize int64 DisableMD5 bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 10.8K bytes - Viewed (0) -
tensorflow/c/experimental/grappler/grappler.h
TF_CAPI_EXPORT extern void TF_DeleteGraphProperties( TF_GraphProperties* graph_properties); // Infer tensor shapes through abstract interpretation. // If assume_valid_feeds is true, it can help infer shapes in the fanout of fed // nodes. This may cause incorrectness in graph analyses, but is useful for // simulation or scheduling. // If aggressive_shape_inference is true, nodes are executed on the host to
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 03 18:08:43 UTC 2022 - 12.5K bytes - Viewed (0) -
docs/bucket/notifications/README.md
```sh mc admin config set myminio/ notify_amqp:1 exchange="bucketevents" exchange_type="fanout" mandatory="off" no_wait="off" url="amqp://myuser:mypassword@localhost:5672" auto_deleted="off" delivery_mode="0" durable="off" internal="off" routing_key="bucketlogs" ``` MinIO supports all the exchanges available in [RabbitMQ](https://www.rabbitmq.com/). For this setup, we are using `fanout` exchange.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 84K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
registry quota.Registry // TODO these are used together to bucket items by namespace and then batch them up for processing. // The technique is valuable for rollup activities to avoid fanout and reduce resource contention. // We could move this into a library if another component needed it. // queue is indexed by namespace, so that we bundle up on a per-namespace basis queue *workqueue.Typed[string]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeErrorResponse(ctx, w, apiErr, r.URL) return } var b bytes.Buffer if name != "file" { if http.CanonicalHeaderKey(name) == http.CanonicalHeaderKey("x-minio-fanout-list") { dec := json.NewDecoder(part) // while the array contains values for dec.More() { var m minio.PutObjectFanOutEntry if err := dec.Decode(&m); err != nil { part.Close()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0)