Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for UnmarshalCheckpoint (0.23 sec)

  1. pkg/kubelet/status/state/checkpoint.go

    	prc.Checksum = 0
    	prc.Checksum = checksum.New(prc)
    	return json.Marshal(*prc)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint
    func (prc *PodResourceAllocationCheckpoint) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, prc)
    }
    
    // VerifyChecksum verifies that current checksum of checkpoint is valid
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  2. pkg/kubelet/checkpointmanager/testing/example_checkpoint_formats/v1/types.go

    func (cp *CheckpointData) MarshalCheckpoint() ([]byte, error) {
    	cp.Checksum = checksum.New(*cp.Data)
    	return json.Marshal(*cp)
    }
    
    // UnmarshalCheckpoint tries to unmarshal the passed JSON data into CheckpointData.
    func (cp *CheckpointData) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, cp)
    }
    
    // VerifyChecksum verifies that CheckpointData's checksum is same as the checksum calculated by its data.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 19 03:53:33 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/state/checkpoint.go

    	// make sure checksum wasn't set before so it doesn't affect output checksum
    	mp.Checksum = 0
    	mp.Checksum = checksum.New(mp)
    	return json.Marshal(*mp)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint
    func (mp *MemoryManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, mp)
    }
    
    // VerifyChecksum verifies that current checksum of checkpoint is valid
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 17 12:58:53 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/state/checkpoint.go

    	return json.Marshal(*cp)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint in v1 format
    func (cp *CPUManagerCheckpointV1) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, cp)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint in v2 format
    func (cp *CPUManagerCheckpointV2) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, cp)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 27 01:24:22 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/state/testing/util.go

    	Content string
    }
    
    // MarshalCheckpoint returns fake content
    func (mc *MockCheckpoint) MarshalCheckpoint() ([]byte, error) {
    	return []byte(mc.Content), nil
    }
    
    // UnmarshalCheckpoint fakes unmarshaling
    func (mc *MockCheckpoint) UnmarshalCheckpoint(blob []byte) error {
    	return nil
    }
    
    // VerifyChecksum fakes verifying checksum
    func (mc *MockCheckpoint) VerifyChecksum() error {
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 15 16:34:53 UTC 2018
    - 1.2K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/dra/state/checkpoint.go

    	// make sure checksum wasn't set before so it doesn't affect output checksum
    	dc.Checksum = 0
    	dc.Checksum = checksum.New(dc)
    	return json.Marshal(*dc)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint
    func (dc *DRAManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, dc)
    }
    
    // VerifyChecksum verifies that current checksum of checkpoint is valid
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 15:23:10 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  7. pkg/kubelet/checkpointmanager/checkpoint_manager.go

    	utilfs "k8s.io/kubernetes/pkg/util/filesystem"
    )
    
    // Checkpoint provides the process checkpoint data
    type Checkpoint interface {
    	MarshalCheckpoint() ([]byte, error)
    	UnmarshalCheckpoint(blob []byte) error
    	VerifyChecksum() error
    }
    
    // CheckpointManager provides the interface to manage checkpoint
    type CheckpointManager interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 24 13:51:34 UTC 2021
    - 3.5K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/devicemanager/checkpoint/checkpoint.go

    }
    
    // MarshalCheckpoint returns marshalled data
    func (cp *Data) MarshalCheckpoint() ([]byte, error) {
    	cp.Checksum = checksum.New(cp.Data)
    	return json.Marshal(*cp)
    }
    
    // UnmarshalCheckpoint returns unmarshalled data
    func (cp *Data) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, cp)
    }
    
    // VerifyChecksum verifies that passed checksum is same as calculated checksum
    func (cp *Data) VerifyChecksum() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. pkg/kubelet/checkpointmanager/checkpoint_manager_test.go

    			HostNetwork:  hostNetwork,
    		},
    	}
    }
    
    func (cp *CheckpointData) MarshalCheckpoint() ([]byte, error) {
    	cp.Checksum = checksum.New(*cp.Data)
    	return json.Marshal(*cp)
    }
    
    func (cp *CheckpointData) UnmarshalCheckpoint(blob []byte) error {
    	return json.Unmarshal(blob, cp)
    }
    
    func (cp *CheckpointData) VerifyChecksum() error {
    	return cp.Checksum.Verify(*cp.Data)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Nov 12 06:41:04 UTC 2018
    - 6.6K bytes
    - Viewed (0)
Back to top