state

Documentation

Index

• type CPUManagerCheckpoint
  • func NewCPUManagerCheckpoint() *CPUManagerCheckpoint
  • func (cp *CPUManagerCheckpoint) MarshalCheckpoint() ([]byte, error)
  • func (cp *CPUManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error
  • func (cp *CPUManagerCheckpoint) VerifyChecksum() error
• type ContainerCPUAssignments
  • func (as ContainerCPUAssignments) Clone() ContainerCPUAssignments
• type Reader
• type State
  • func NewCheckpointState(stateDir, checkpointName, policyName string) (State, error)
  • func NewFileState(filePath string, policyName string) State
  • func NewMemoryState() State

Types

type CPUManagerCheckpoint

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

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

func NewCPUManagerCheckpoint

func NewCPUManagerCheckpoint() *CPUManagerCheckpoint

NewCPUManagerCheckpoint returns an instance of Checkpoint

func (*CPUManagerCheckpoint) MarshalCheckpoint

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

MarshalCheckpoint returns marshalled checkpoint

func (*CPUManagerCheckpoint) UnmarshalCheckpoint

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

UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint

func (*CPUManagerCheckpoint) VerifyChecksum

func (cp *CPUManagerCheckpoint) VerifyChecksum() error

VerifyChecksum verifies that current checksum of checkpoint is valid

type ContainerCPUAssignments

type ContainerCPUAssignments map[string]cpuset.CPUSet

ContainerCPUAssignments type used in cpu manager state

func (ContainerCPUAssignments) Clone

func (as ContainerCPUAssignments) Clone() ContainerCPUAssignments

Clone returns a copy of ContainerCPUAssignments

type Reader

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

Reader interface used to read current cpu/pod assignment state

type State

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

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

func NewCheckpointState

func NewCheckpointState(stateDir, checkpointName, policyName string) (State, error)

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

func NewFileState

func NewFileState(filePath string, policyName string) State

NewFileState creates new State for keeping track of cpu/pod assignment with file backend

func NewMemoryState

func NewMemoryState() State

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