- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for statusMap (0.34 sec)
-
pkg/kubelet/types/types_test.go
var tests = []struct { containers []v1.Container statusMap map[string]*v1.ContainerStatus expectStatuses []v1.ContainerStatus }{ { containers: []v1.Container{{Name: "first"}, {Name: "second"}, {Name: "third"}, {Name: "fourth"}}, expectStatuses: []v1.ContainerStatus{{Name: "first"}, {Name: "second"}, {Name: "third"}, {Name: "fourth"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 19 08:28:25 UTC 2022 - 6.2K bytes - Viewed (0) -
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)