- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 51 for HEvent (2.64 sec)
-
cmd/bucket-handlers.go
} scheduleReplicationDelete(ctx, dv, objectAPI) } eventName := event.ObjectRemovedDelete objInfo := ObjectInfo{ Name: dobj.ObjectName, VersionID: dobj.VersionID, DeleteMarker: dobj.DeleteMarker, } if objInfo.DeleteMarker { objInfo.VersionID = dobj.DeleteMarkerVersionID eventName = event.ObjectRemovedDeleteMarkerCreated } sendEvent(eventArgs{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
}, } clienttest.Wrap(t, controller.services).Create(service) if features.EnableExternalNameAlias { xdsEvents.MatchOrFail(t, xdsfake.Event{Type: "service"}) } else { xdsEvents.MatchOrFail(t, xdsfake.Event{Type: "service"}, xdsfake.Event{Type: "eds cache"}) } return service }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
// As a workaround, we add UpdateNodeTaint event to catch the case. // We can remove UpdateNodeTaint when we remove the preCheck feature. // See: https://github.com/kubernetes/kubernetes/issues/110175 {Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.UpdateNodeLabel | framework.UpdateNodeTaint}}, // A pod might be waiting for a class to get created or modified.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
src/runtime/mprof.go
return false } return true } // saveblockevent records a profile event of the type specified by which. // cycles is the quantity associated with this event and rate is the sampling rate, // used to adjust the cycles value in the manner determined by the profile type. // skip is the number of frames to omit from the traceback associated with the event.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
return } func (m *kubeGenericRuntimeManager) GeneratePodStatus(event *runtimeapi.ContainerEventResponse) (*kubecontainer.PodStatus, error) { podIPs := m.determinePodSandboxIPs(event.PodSandboxStatus.Metadata.Namespace, event.PodSandboxStatus.Metadata.Name, event.PodSandboxStatus) kubeContainerStatuses := []*kubecontainer.Status{} for _, status := range event.ContainersStatuses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
jm.recorder.Event(job, v1.EventTypeWarning, "TooManySucceededPods", "Too many succeeded pods running after completion count reached") } jm.recorder.Event(job, v1.EventTypeNormal, "Completed", "Job completed") metrics.JobFinishedNum.WithLabelValues(completionMode, "succeeded", "").Inc() } else { jm.recorder.Event(job, v1.EventTypeWarning, finishedCond.Reason, finishedCond.Message)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
if node.Name != proxier.hostname { proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node", "eventNode", node.Name, "currentNode", proxier.hostname) return } proxier.mu.Lock() proxier.nodeLabels = nil proxier.mu.Unlock() proxier.Sync() } // OnNodeSynced is called once all the initial event handlers were // called and the state is fully propagated to local cache.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
backendURL, err := url.Parse(backend.URL) if err != nil { t.Fatal(err) } var ( mu sync.Mutex log []string ) addLog := func(event string) { mu.Lock() defer mu.Unlock() log = append(log, event) } rp := NewSingleHostReverseProxy(backendURL) const size = 1234 rp.BufferPool = bufferPool{ get: func() []byte { addLog("getBuf") return make([]byte, size)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
proxier.logger.Error(nil, "Received a watch event for a node that doesn't match the current node", "eventNode", node.Name, "currentNode", proxier.hostname) return } proxier.mu.Lock() proxier.nodeLabels = nil proxier.needFullSync = true proxier.mu.Unlock() proxier.Sync() } // OnNodeSynced is called once all the initial event handlers were
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
store, kube, fx := setupTest(t) makeIstioObject(t, store, workloadEntry) // Other than proxy update, no event pushed when workload entry created as no service entry fx.WaitOrFail(t, "proxy") fx.AssertEmpty(t, 40*time.Millisecond) makeService(t, kube, service) fx.MatchOrFail(t, xdsfake.Event{Type: "eds cache", EndpointCount: 1}) instances := []EndpointResponse{{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0)