- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 114 for Statuses (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go
return rl } // StatusIsNot returns a StacktracePred which will cause stacktraces to be logged // for any status *not* in the given list. func StatusIsNot(statuses ...int) StacktracePred { statusesNoTrace := map[int]bool{} for _, s := range statuses { statusesNoTrace[s] = true } return func(status int) bool { _, ok := statusesNoTrace[status] return !ok } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 10:10:35 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
} status := resp.GetStatus() if status == nil { return nil, remote.ErrContainerStatusNil } cStatus := m.convertToKubeContainerStatus(status) statuses = append(statuses, cStatus) } sort.Sort(containerStatusByCreated(statuses)) return statuses, nil } func toKubeContainerStatus(status *runtimeapi.ContainerStatus, runtimeName string) *kubecontainer.Status {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/apis/core/fuzzer/fuzzer.go
func(s *core.PodStatus, c fuzz.Continue) { c.Fuzz(&s) s.HostIPs = []core.HostIP{{IP: s.HostIP}} }, func(j *core.PodPhase, c fuzz.Continue) { statuses := []core.PodPhase{core.PodPending, core.PodRunning, core.PodFailed, core.PodUnknown} *j = statuses[c.Rand.Intn(len(statuses))] }, func(j *core.Binding, c fuzz.Continue) { c.Fuzz(&j.ObjectMeta) j.Target.Name = c.RandString() },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 04:32:01 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
log.Debugf("enqueueing update for %s/%s", r.Namespace, r.Name) c.statusctl.EnqueueStatusUpdateResource(m, r) } } oldmsgs[a] = res.MappedMessages[a] } log.Debugf("finished enqueueing all statuses") } db.Run(chKind, stop, 1*time.Second, features.AnalysisInterval, pushFn)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
) // NodeStatusUpdater defines a set of operations for updating the // VolumesAttached field in the Node Status. type NodeStatusUpdater interface { // Gets a list of node statuses that should be updated from the actual state // of the world and updates them. UpdateNodeStatuses(logger klog.Logger) error // Update any pending status change for the given node
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
CPURequest: tc.Resources[i].Requests.Cpu(), } } } t.Logf("TestCase: %q", tdesc) cStatuses := kubelet.convertToAPIContainerStatuses(tPod, testPodStatus, tc.OldStatus, tPod.Spec.Containers, false, false) assert.Equal(t, tc.Expected, cStatuses) } } func TestConvertToAPIContainerStatusesForUser(t *testing.T) { nowTime := time.Now() testContainerName := "ctr0"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
verifyUpdates(t, m, 0) } // shuffle returns a new shuffled list of container statuses. func shuffle(statuses []v1.ContainerStatus) []v1.ContainerStatus { numStatuses := len(statuses) randIndexes := rand.Perm(numStatuses) shuffled := make([]v1.ContainerStatus, numStatuses) for i := 0; i < numStatuses; i++ { shuffled[i] = statuses[randIndexes[i]] } return shuffled } func TestStatusEquality(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
metricSpecs []autoscalingv2.MetricSpec) (replicas int32, metric string, statuses []autoscalingv2.MetricStatus, timestamp time.Time, err error) { selector, err := a.validateAndParseSelector(hpa, scale.Status.Selector) if err != nil { return -1, "", nil, time.Time{}, err } specReplicas := scale.Spec.Replicas statusReplicas := scale.Status.Replicas statuses = make([]autoscalingv2.MetricStatus, len(metricSpecs))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
statuses@2.0.1: version "2.0.1" resolved "https://registry.yarnpkg.com/statuses/-/statuses-2.0.1.tgz#55cb000ccf1d48728bd23c685a063998cf1a1b63" integrity sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ== statuses@~1.5.0: version "1.5.0" resolved "https://registry.yarnpkg.com/statuses/-/statuses-1.5.0.tgz#161c7dac177659fd9811f43771fa99381478628c"
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug.go
Writer io.Writer Namespace string InternalDebugAllIstiod bool } func (s *DebugWriter) PrintAll(drs map[string]*discovery.DiscoveryResponse) error { // Gather the statuses before printing so they may be sorted mappedResp := map[string]string{} for id, dr := range drs { for _, resource := range dr.Resources { if s.InternalDebugAllIstiod {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.9K bytes - Viewed (0)