- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 256 for fetches (0.13 sec)
-
pilot/pkg/model/telemetry.go
if hasDefaultProvider { // todo: what do we want to do with more than one default provider? // for now, use only the first provider. fetched := t.fetchProvider(providerNames[0]) clientSpec.Provider = fetched serverSpec.Provider = fetched } for _, m := range ct.Tracing { names := getProviderNames(m.Providers) specs := []*TracingSpec{&clientSpec, &serverSpec} if m.Match != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} // PopHealStatusJSON - Called by heal-status API. It fetches the heal // status results from global state and returns its JSON // representation. The clientToken helps ensure there aren't // conflicting clients fetching status. func (ahs *allHealState) PopHealStatusJSON(hpath string, clientToken string) ([]byte, APIErrorCode, ) { // fetch heal state for given path h, exists := ahs.getHealSequence(hpath)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
if _, err := kl.patchNodeStatus(originalNode, node); err != nil { // The originalNode is probably stale, but we know that the current state of kubelet would turn // the node to be ready. Retry using syncNodeStatus() which fetches from the apiserver. klog.ErrorS(err, "Error updating node status, will retry with syncNodeStatus") // The reversed kl.syncNodeStatusMux.Unlock/Lock() below to allow kl.syncNodeStatus() execution.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
cluster/gce/gci/configure.sh
- sudo systemctl status kube-node-installation - sudo systemctl status kube-node-configuration EOF } # A function that fetches a GCE metadata value and echoes it out. # Args: # $1 : URL path after /computeMetadata/v1/ (without heading slash). # $2 : An optional default value to echo out if the fetch fails. # # NOTE: this function is duplicated in configure-helper.sh, any changes here # should be duplicated there as well.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 04:14:02 UTC 2024 - 36.5K bytes - Viewed (0) -
cmd/notification.go
go func(index int) { defer wg.Done() errs[index] = sys.peerClients[index].ReloadSiteReplicationConfig(ctx) }(index) } wg.Wait() return errs } // GetLastDayTierStats fetches per-tier stats of the last 24hrs from all peers func (sys *NotificationSys) GetLastDayTierStats(ctx context.Context) DailyAllTierStats { errs := make([]error, len(sys.allPeerClients))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
src/syscall/syscall_linux.go
// Pull in entersyscall/exitsyscall for Syscall/Syscall6. // // Note that this can't be a push linkname because the runtime already has a // nameless linkname to export to assembly here and in x/sys. Additionally, // entersyscall fetches the caller PC and SP and thus can't have a wrapper // inbetween. //go:linkname runtime_entersyscall runtime.entersyscall func runtime_entersyscall() //go:linkname runtime_exitsyscall runtime.exitsyscall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:12:46 UTC 2024 - 35.7K bytes - Viewed (0) -
src/runtime/signal_unix.go
// issue #37741. // Only send a signal if there isn't already one pending. signalM(mp, sigPreempt) } if GOOS == "darwin" || GOOS == "ios" { execLock.runlock() } } // sigFetchG fetches the value of G safely when running in a signal handler. // On some architectures, the g value may be clobbered when running in a VDSO. // See issue #32912. // //go:nosplit func sigFetchG(c *sigctxt) *g {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td
data or control dependencies, connected to the associated `tf_executor.fetch` op. The order of ops will be preserved. Functions named `main` with no `tf.entry_function` attribute will not be pruned, as such graphs/functions may have been imported from a V1 TensorFlow graph, where feeds/fetches/targets are not provided at certain stages of IR transformation (e.g. pre-placement).
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 21:18:05 UTC 2024 - 99.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/optimize_patterns.td
(FloatValueEquals<"1"> $Cst_1), (FloatValueEquals<"0.707106769"> $Cst_sqrt_1_2), (HasOneUse $mul_out), (HasOneUse $add_out), (HasOneUse $erf_out), (HasOneUse $mul_out1), ]>; // Fetches the output of FC op, from the provided arguments. def GetFcOutput : NativeCodeCall< "GetFcOutput(&$_builder, $0, $1, $2, $3, $4, $5, $6, $7)">; // Verifies all values in the provided argument are zero.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 20:31:41 UTC 2024 - 66.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/patches/patches.go
} // patchSet defines a set of patches of a certain type that can patch a PatchTarget. type patchSet struct { targetName string patchType types.PatchType patches []string } // String() is used for unit-testing. func (ps *patchSet) String() string { return fmt.Sprintf( "{%q, %q, %#v}", ps.targetName, ps.patchType, ps.patches, ) } const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 10.2K bytes - Viewed (0)