- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for pushfw (0.09 sec)
-
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
return } for { response, err := stream.Recv() if err != nil { klog.ErrorS(err, "ListAndWatch ended unexpectedly for device plugin", "resource", c.resource) return } klog.V(2).InfoS("State pushed for device plugin", "resource", c.resource, "resourceCapacity", len(response.Devices)) c.handler.PluginListAndWatchReceiver(c.resource, response) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
releasenotes/notes/drop-legacy-partial-full-push.yaml
John Howard <******@****.***> 1682620609 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 27 18:36:49 UTC 2023 - 145 bytes - Viewed (0) -
pkg/config/schema/codegen/common.go
"istio.io/istio/pkg/config/schema/ast" "istio.io/istio/pkg/test/env" ) func Run() error { inp, err := buildInputs() if err != nil { return err } // Include synthetic types used for XDS pushes kindEntries := append([]colEntry{ { Resource: &ast.Resource{Identifier: "Address", Kind: "Address", Version: "internal", Group: "internal"}, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 4.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/optimize_op_order.cc
}; // If the op is the pass-through op with (3x) smaller output, the dequantize // op can be pushed down to the single result of this op. if (!llvm::dyn_cast<mlir::SameScalesOpInterface>(passthrough_op) || passthrough_op->getNumResults() != 1) { return failure(); } // Only push down the dequantize op when the output is smaller, so that it // can have smaller memory usage. auto input_type =
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 5.1K bytes - Viewed (0) -
hack/update-generated-docs.sh
genman "${dest}/docs/man/man1/" "kubectl" genman "${dest}/docs/man/man1/" "kubeadm" mkdir -p "${dest}/docs/yaml/kubectl/" genyaml "${dest}/docs/yaml/kubectl/" # create the list of generated files pushd "${dest}" > /dev/null || return 1 touch docs/.generated_docs find . -type f | cut -sd / -f 2- | LC_ALL=C sort > docs/.generated_docs popd > /dev/null || return 1 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:07:33 UTC 2024 - 3K bytes - Viewed (0) -
src/container/heap/heap.go
func Init(h Interface) { // heapify n := h.Len() for i := n/2 - 1; i >= 0; i-- { down(h, i, n) } } // Push pushes the element x onto the heap. // The complexity is O(log n) where n = h.Len(). func Push(h Interface, x any) { h.Push(x) up(h, h.Len()-1) } // Pop removes and returns the minimum element (according to Less) from the heap. // The complexity is O(log n) where n = h.Len().
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:10 UTC 2023 - 3.3K bytes - Viewed (0) -
releasenotes/notes/push-cds-on-auto-passthrough-gateway-change.yaml
Jacek Ewertowski <******@****.***> 1715273579 +0200
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:59 UTC 2024 - 181 bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen.go
store model.ConfigStore } func NewGenerator(store model.ConfigStore) *APIGenerator { return &APIGenerator{ store: store, } } // TODO: take 'updates' into account, don't send pushes for resources that haven't changed // TODO: support WorkloadEntry - to generate endpoints (equivalent with EDS) // TODO: based on lessons from MCP, we want to send 'chunked' responses, like apiserver does.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 05 19:01:38 UTC 2023 - 5K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
} w.MeshConfig.Store(meshConfig) handlers = append(handlers, w.handlers...) } // TODO hack: the first handler added is the ConfigPush, other handlers affect what will be pushed, so reversing iteration for i := len(handlers) - 1; i >= 0; i-- { handlers[i].handler() } } // Add to the FileWatcher the provided file and execute the provided function
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/queue/delay.go
if !push(task) { return } } else { // not ready yet, don't block enqueueing await := time.NewTimer(delay) select { case t := <-d.enqueue: d.mu.Lock() heap.Push(d.queue, t) // put the old "head" back on the queue, it may be scheduled to execute after the one // that was just pushed heap.Push(d.queue, task) d.mu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0)