- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for checkPoint (0.13 sec)
-
pkg/kubelet/cm/dra/state/checkpoint.go
} // List of claim info to store in checkpoint type ClaimInfoStateList []ClaimInfoState // List of claim info to store in checkpoint // TODO: remove in Beta type ClaimInfoStateListWithoutResourceHandles []ClaimInfoStateWithoutResourceHandles // NewDRAManagerCheckpoint returns an instance of Checkpoint func NewDRAManagerCheckpoint() *DRAManagerCheckpoint { return &DRAManagerCheckpoint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 15:23:10 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/checkpoint.go
"encoding/json" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/checksum" ) var _ checkpointmanager.Checkpoint = &MemoryManagerCheckpoint{} // MemoryManagerCheckpoint struct is used to store memory/pod assignments in a checkpoint type MemoryManagerCheckpoint struct { PolicyName string `json:"policyName"` MachineState NUMANodeMap `json:"machineState"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:53 UTC 2021 - 2.1K bytes - Viewed (0) -
pkg/kubelet/status/state/checkpoint.go
"k8s.io/kubernetes/pkg/kubelet/checkpointmanager" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/checksum" ) var _ checkpointmanager.Checkpoint = &PodResourceAllocationCheckpoint{} // PodResourceAllocationCheckpoint is used to store resources allocated to a pod in checkpoint type PodResourceAllocationCheckpoint struct { AllocationEntries map[string]map[string]v1.ResourceList `json:"allocationEntries,omitempty"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/checkpoint.go
"k8s.io/kubernetes/pkg/kubelet/checkpointmanager/errors" ) var _ checkpointmanager.Checkpoint = &CPUManagerCheckpointV1{} var _ checkpointmanager.Checkpoint = &CPUManagerCheckpointV2{} var _ checkpointmanager.Checkpoint = &CPUManagerCheckpoint{} // CPUManagerCheckpoint struct is used to store cpu/pod assignments in a checkpoint in v2 format type CPUManagerCheckpoint struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 27 01:24:22 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/checkpoint/checkpoint.go
} // checkpointData struct is used to store pod to device allocation information // in a checkpoint file. // TODO: add version control when we need to change checkpoint format. type checkpointData struct { PodDeviceEntries []PodDevicesEntry RegisteredDevices map[string][]string } // Data holds checkpoint data and its checksum type Data struct { Data checkpointData Checksum checksum.Checksum }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/kubelet/checkpointmanager/checkpoint_manager.go
// For file backed utilstore, checkpointKey is the file name to write the checkpoint data. CreateCheckpoint(checkpointKey string, checkpoint Checkpoint) error // GetCheckpoint retrieves checkpoint from CheckpointStore. GetCheckpoint(checkpointKey string, checkpoint Checkpoint) error // WARNING: RemoveCheckpoint will not return error if checkpoint does not exist. RemoveCheckpoint(checkpointKey string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 24 13:51:34 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/checkpointmanager/checkpoint_manager_test.go
}, { &proto, &port443, &port443, ip1234, }, } checkpoint1 := newFakeCheckpointV1("check1", portMappings, true) checkpoints := []struct { checkpointKey string checkpoint FakeCheckpoint expectHostNetwork bool }{ { "key1", checkpoint1, true, }, { "key2", newFakeCheckpointV1("check2", nil, false), false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 12 06:41:04 UTC 2018 - 6.6K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint_test.go
assert.NoError(t, err, "could not store checkpoint data") checkpoint := NewDRAManagerCheckpoint() err = cpm.GetCheckpoint(testingCheckpoint, checkpoint) assert.NoError(t, err, "could not restore checkpoint") checkpointData, err := checkpoint.MarshalCheckpoint() assert.NoError(t, err, "could not Marshal Checkpoint")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint.go
} // saves state to a checkpoint, caller is responsible for locking func (sc *stateCheckpoint) store(claimInfoStateList ClaimInfoStateList) error { checkpoint := NewDRAManagerCheckpoint() checkpoint.Entries = claimInfoStateList err := sc.checkpointManager.CreateCheckpoint(sc.checkpointName, checkpoint) if err != nil { return fmt.Errorf("could not save checkpoint %s: %v", sc.checkpointName, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_checkpoint.go
sc.cache.SetMemoryAssignments(checkpoint.Entries) klog.V(2).InfoS("State checkpoint: restored state from checkpoint") return nil } // saves state to a checkpoint, caller is responsible for locking func (sc *stateCheckpoint) storeState() error { checkpoint := NewMemoryManagerCheckpoint() checkpoint.PolicyName = sc.policyName checkpoint.MachineState = sc.cache.GetMachineState()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 5.3K bytes - Viewed (0)