kubernetes: k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state Index | Files | Directories

package state

import "k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state"

Index

Package Files

checkpoint.go state.go state_checkpoint.go state_mem.go

type CPUManagerCheckpoint Uses

type CPUManagerCheckpoint struct {
    PolicyName    string                       `json:"policyName"`
    DefaultCPUSet string                       `json:"defaultCpuSet"`
    Entries       map[string]map[string]string `json:"entries,omitempty"`
    Checksum      checksum.Checksum            `json:"checksum"`
}

CPUManagerCheckpoint struct is used to store cpu/pod assignments in a checkpoint in v2 format

func NewCPUManagerCheckpoint Uses

func NewCPUManagerCheckpoint() *CPUManagerCheckpoint

NewCPUManagerCheckpoint returns an instance of Checkpoint

type CPUManagerCheckpointV1 Uses

type CPUManagerCheckpointV1 struct {
    PolicyName    string            `json:"policyName"`
    DefaultCPUSet string            `json:"defaultCpuSet"`
    Entries       map[string]string `json:"entries,omitempty"`
    Checksum      checksum.Checksum `json:"checksum"`
}

CPUManagerCheckpointV1 struct is used to store cpu/pod assignments in a checkpoint in v1 format

func (*CPUManagerCheckpointV1) MarshalCheckpoint Uses

func (cp *CPUManagerCheckpointV1) MarshalCheckpoint() ([]byte, error)

MarshalCheckpoint returns marshalled checkpoint in v1 format

func (*CPUManagerCheckpointV1) UnmarshalCheckpoint Uses

func (cp *CPUManagerCheckpointV1) UnmarshalCheckpoint(blob []byte) error

UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint in v1 format

func (*CPUManagerCheckpointV1) VerifyChecksum Uses

func (cp *CPUManagerCheckpointV1) VerifyChecksum() error

VerifyChecksum verifies that current checksum of checkpoint is valid in v1 format

type CPUManagerCheckpointV2 Uses

type CPUManagerCheckpointV2 = CPUManagerCheckpoint

CPUManagerCheckpointV2 struct is used to store cpu/pod assignments in a checkpoint in v2 format

func (*CPUManagerCheckpointV2) MarshalCheckpoint Uses

func (cp *CPUManagerCheckpointV2) MarshalCheckpoint() ([]byte, error)

MarshalCheckpoint returns marshalled checkpoint in v2 format

func (*CPUManagerCheckpointV2) UnmarshalCheckpoint Uses

func (cp *CPUManagerCheckpointV2) UnmarshalCheckpoint(blob []byte) error

UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint in v2 format

func (*CPUManagerCheckpointV2) VerifyChecksum Uses

func (cp *CPUManagerCheckpointV2) VerifyChecksum() error

VerifyChecksum verifies that current checksum of checkpoint is valid in v2 format

type ContainerCPUAssignments Uses

type ContainerCPUAssignments map[string]map[string]cpuset.CPUSet

ContainerCPUAssignments type used in cpu manager state

func (ContainerCPUAssignments) Clone Uses

func (as ContainerCPUAssignments) Clone() ContainerCPUAssignments

Clone returns a copy of ContainerCPUAssignments

type Reader Uses

type Reader interface {
    GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool)
    GetDefaultCPUSet() cpuset.CPUSet
    GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet
    GetCPUAssignments() ContainerCPUAssignments
}

Reader interface used to read current cpu/pod assignment state

type State Uses

type State interface {
    Reader
    // contains filtered or unexported methods
}

State interface provides methods for tracking and setting cpu/pod assignment

func NewCheckpointState Uses

func NewCheckpointState(stateDir, checkpointName, policyName string, initialContainers containermap.ContainerMap) (State, error)

NewCheckpointState creates new State for keeping track of cpu/pod assignment with checkpoint backend

func NewMemoryState Uses

func NewMemoryState() State

NewMemoryState creates new State for keeping track of cpu/pod assignment

Directories

PathSynopsis
testing

Package state imports 13 packages (graph) and is imported by 35 packages. Updated 2020-09-21. Refresh now. Tools for package owners.