- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for statusMap (0.19 sec)
-
pkg/kubelet/types/types.go
// in the order that they appear in its spec. func SortStatusesOfInitContainers(p *v1.Pod, statusMap map[string]*v1.ContainerStatus) []v1.ContainerStatus { containers := p.Spec.InitContainers statuses := []v1.ContainerStatus{} for _, container := range containers { if status, found := statusMap[container.Name]; found { statuses = append(statuses, *status) } } return statuses }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/bucket-replication.go
s.Lock() defer s.Unlock() m := s.statusMap[opts.bucket] st := m.TargetsMap[opts.arn] st.LastUpdate = UTCNow() st.ResyncStatus = status m.TargetsMap[opts.arn] = st m.LastUpdate = UTCNow() s.statusMap[opts.bucket] = m ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
func (v VersionPurgeStatusType) Pending() bool { return v == Pending || v == Failed } type replicationResyncer struct { // map of bucket to their resync status statusMap map[string]BucketReplicationResyncStatus workerSize int resyncCancelCh chan struct{} workerCh chan struct{} sync.RWMutex } const ( replicationDir = ".replication"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/site-replication.go
m, ok := globalReplicationPool.resyncer.statusMap[bucket] if !ok { m = newBucketResyncStatus(bucket) } if st, ok := m.TargetsMap[t.Arn]; ok { st.LastUpdate = UTCNow() st.ResyncStatus = ResyncCanceled m.TargetsMap[t.Arn] = st m.LastUpdate = UTCNow() } globalReplicationPool.resyncer.statusMap[bucket] = m globalReplicationPool.resyncer.Unlock() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/BuildStatusRendererTest.groovy
renderer.onOutput(event1) renderer.onOutput(updateNow()) then: statusBar.display == "<-------------> 0% INITIALIZING [0ms]" when: currentTimeMs += 1000 renderer.onOutput(event2) renderer.onOutput(updateNow()) then: statusBar.display == "<-------------> 0% INITIALIZING [1s]" } def "hides timer between build phases"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 10.3K bytes - Viewed (0) -
pkg/webhooks/validation/server/monitoring.go
ResourceTag = monitoring.CreateLabel(resourceTag) // ReasonTag holds the error reason for the context. ReasonTag = monitoring.CreateLabel(reason) // StatusTag holds the error code for the context. StatusTag = monitoring.CreateLabel(status) ) var ( metricValidationPassed = monitoring.NewSum( "galley_validation_passed", "Resource is valid", )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 16:50:34 UTC 2023 - 2.6K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
} func resourceClaimStatusesEqual(statusA, statusB []corev1.PodResourceClaimStatus) bool { if len(statusA) != len(statusB) { return false } // In most cases, status entries only get added once and not modified. // But this cannot be guaranteed, so for the sake of correctness in all // cases this code here has to check. for i := range statusA { if statusA[i].Name != statusB[i].Name { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
} } func resourceClaimStatusesEqual(statusA, statusB []api.PodResourceClaimStatus) bool { if len(statusA) != len(statusB) { return false } // In most cases, status entries only get added once and not modified. // But this cannot be guaranteed, so for the sake of correctness in all // cases this code here has to check. for i := range statusA { if statusA[i].Name != statusB[i].Name { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/DefaultColorMap.java
import static org.gradle.internal.logging.text.StyledTextOutput.Style.UserInput; public class DefaultColorMap implements ColorMap { private static final String STATUS_BAR = "statusbar"; private static final String BOLD = "bold"; private static final String COLOR_DIVIDER = "-"; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 9.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsyscall_solaris_amd64.go
} return } // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT func wait4(pid int32, statusp *_C_int, options int, rusage *Rusage) (wpid int32, err error) { r0, _, e1 := sysvicall6(uintptr(unsafe.Pointer(&procwait4)), 4, uintptr(pid), uintptr(unsafe.Pointer(statusp)), uintptr(options), uintptr(unsafe.Pointer(rusage)), 0, 0) wpid = int32(r0) if e1 != 0 { err = errnoErr(e1) } return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 59.7K bytes - Viewed (0)