- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for ContainerMap (0.22 sec)
-
pkg/kubelet/cm/containermap/container_map.go
limitations under the License. */ package containermap import ( "fmt" ) // ContainerMap maps (containerID)->(*v1.Pod, *v1.Container) type ContainerMap map[string]struct { podUID string containerName string } // NewContainerMap creates a new ContainerMap struct func NewContainerMap() ContainerMap { return make(ContainerMap) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 30 15:25:05 UTC 2022 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cm/helpers.go
podSandboxMap := make(map[string]string) podSandboxList, _ := runtimeService.ListPodSandbox(ctx, nil) for _, p := range podSandboxList { podSandboxMap[p.Id] = p.Metadata.Uid } runningSet := sets.New[string]() containerMap := containermap.NewContainerMap() containerList, _ := runtimeService.ListContainers(ctx, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
state state.State } func (m *fakeManager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Start()") return nil } func (m *fakeManager) Policy() Policy { klog.InfoS("Policy()") pol, _ := NewNonePolicy(nil) return pol }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/containermap/container_map_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 02 13:40:55 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_pod.go
limitations under the License. */ package topologymanager import ( "k8s.io/api/core/v1" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/cm/admission" "k8s.io/kubernetes/pkg/kubelet/cm/containermap" "k8s.io/kubernetes/pkg/kubelet/lifecycle" "k8s.io/kubernetes/pkg/kubelet/metrics" ) type podScope struct { scope } // Ensure podScope implements Scope interface var _ Scope = &podScope{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_none.go
See the License for the specific language governing permissions and limitations under the License. */ package topologymanager import ( "k8s.io/api/core/v1" "k8s.io/kubernetes/pkg/kubelet/cm/containermap" "k8s.io/kubernetes/pkg/kubelet/lifecycle" ) type noneScope struct { scope } // Ensure noneScope implements Scope interface var _ Scope = &noneScope{} // NewNoneScope returns a none scope.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 1.2K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
state state.State } func (m *fakeManager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { klog.InfoS("Start()") return nil } func (m *fakeManager) Policy() Policy { klog.InfoS("Policy()") return NewPolicyNone() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/types.go
// Manager manages all the Device Plugins running on a node. type Manager interface { // Start starts device plugin registration service. Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, initialContainers containermap.ContainerMap, initialContainerRunningSet sets.Set[string]) error // Allocate configures and assigns devices to a container in a pod. From // the requested device resources, Allocate will communicate with the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
hintProviders []HintProvider // Topology Manager Policy policy Policy // Mapping of (PodUid, ContainerName) to ContainerID for Adding/Removing Pods from PodTopologyHints mapping podMap containermap.ContainerMap } func (s *scope) Name() string { return s.name } func (s *scope) getTopologyHints(podUID string, containerName string) TopologyHint { s.mutex.Lock() defer s.mutex.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_container.go
limitations under the License. */ package topologymanager import ( "k8s.io/api/core/v1" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/cm/admission" "k8s.io/kubernetes/pkg/kubelet/cm/containermap" "k8s.io/kubernetes/pkg/kubelet/lifecycle" "k8s.io/kubernetes/pkg/kubelet/metrics" ) type containerScope struct { scope } // Ensure containerScope implements Scope interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.9K bytes - Viewed (0)