kubeletconfig

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: config.go

Generated by this command:

mockgen -source=config.go -package=kubeletconfig -destination=capability_checker_mock.go

Package kubeletconfig is a generated GoMock package.

Index

• Constants
• func GetInteractiveInput(maxPidsLimit int, kubeletConfig *v1.KubeletConfig) interactive.Input
• func GetInteractiveMaxPidsLimitHelp(maxPidsLimit int) string
• func GetMaxPidsLimit(client CapabilityChecker) (int, error)
• func PrintKubeletConfigForClassic(config *cmv1.KubeletConfig) string
• func PrintKubeletConfigForHcp(config *cmv1.KubeletConfig, nodePools []*cmv1.NodePool) string
• func PrintKubeletConfigsForTabularOutput(configs []*cmv1.KubeletConfig) string
• func PromptForName(requestedName string, forceInteractive bool) (string, error)
• func PromptToAcceptNodePoolNodeRecreate(r *rosa.Runtime) bool
• func PromptUserToAcceptWorkerNodeReboot(operation KubeletOperation, r *rosa.Runtime) bool
• func ValidateOrPromptForRequestedPidsLimit(requestedPids int, clusterKey string, kubeletConfig *v1.KubeletConfig, ...) (int, error)
• type CapabilityChecker
• type KubeletConfigOptions
  • func NewKubeletConfigOptions() *KubeletConfigOptions
  • func (k *KubeletConfigOptions) AddAllFlags(cmd *cobra.Command)
  • func (k *KubeletConfigOptions) AddNameFlag(cmd *cobra.Command)
  • func (k *KubeletConfigOptions) BindFromArgs(args []string)
  • func (k *KubeletConfigOptions) ValidateForHypershift() error
• type KubeletOperation
• type MockCapabilityChecker
  • func NewMockCapabilityChecker(ctrl *gomock.Controller) *MockCapabilityChecker
  • func (m *MockCapabilityChecker) EXPECT() *MockCapabilityCheckerMockRecorder
  • func (m *MockCapabilityChecker) IsCapabilityEnabled(capability string) (bool, error)
• type MockCapabilityCheckerMockRecorder
  • func (mr *MockCapabilityCheckerMockRecorder) IsCapabilityEnabled(capability any) *gomock.Call

Constants

const (
	MinPodPidsLimit                = 4096
	MaxPodPidsLimit                = 16384
	MaxUnsafePodPidsLimit          = 3694303
	NameOption                     = "name"
	NameOptionDefaultValue         = ""
	NameOptionUsage                = "Name of the KubeletConfig (required for Hosted Control Plane clusters)"
	PodPidsLimitOption             = "pod-pids-limit"
	PodPidsLimitOptionUsage        = "Sets the requested pod_pids_limit for this KubeletConfig."
	PodPidsLimitOptionDefaultValue = 0
	InteractivePodPidsLimitPrompt  = "Pod Pids Limit?"
	InteractivePodPidsLimitHelp    = "Set the Pod Pids Limit field to a value between 4096 and %d"
	InteractiveNameHelpPrompt      = "Name?"
	InteractiveNameHelp            = "Name of the KubeletConfig"
	ByPassPidsLimitCapability      = "capability.organization.bypass_pids_limits"
)

Functions

func GetInteractiveInput

func GetInteractiveInput(maxPidsLimit int, kubeletConfig *v1.KubeletConfig) interactive.Input

func GetInteractiveMaxPidsLimitHelp

func GetInteractiveMaxPidsLimitHelp(maxPidsLimit int) string

func GetMaxPidsLimit

func GetMaxPidsLimit(client CapabilityChecker) (int, error)

GetMaxPidsLimit - returns the maximum pids limit for the current organization the maximum is varied depending on whether the current organizaton has the capability.organization.bypass_pids_limit capability

func PrintKubeletConfigForClassic

func PrintKubeletConfigForClassic(config *cmv1.KubeletConfig) string

func PrintKubeletConfigForHcp

func PrintKubeletConfigForHcp(config *cmv1.KubeletConfig, nodePools []*cmv1.NodePool) string

func PrintKubeletConfigsForTabularOutput

func PrintKubeletConfigsForTabularOutput(configs []*cmv1.KubeletConfig) string

func PromptForName

func PromptForName(requestedName string, forceInteractive bool) (string, error)

func PromptToAcceptNodePoolNodeRecreate

func PromptToAcceptNodePoolNodeRecreate(r *rosa.Runtime) bool

func PromptUserToAcceptWorkerNodeReboot

func PromptUserToAcceptWorkerNodeReboot(operation KubeletOperation, r *rosa.Runtime) bool

func ValidateOrPromptForRequestedPidsLimit

func ValidateOrPromptForRequestedPidsLimit(
	requestedPids int,
	clusterKey string,
	kubeletConfig *v1.KubeletConfig,
	r *rosa.Runtime) (int, error)

ValidateOrPromptForRequestedPidsLimit validates user provided limits or prompts via interactive mode if the user hasn't specified any limit on the command line.

Types

type CapabilityChecker

type CapabilityChecker interface {
	IsCapabilityEnabled(capability string) (bool, error)
}

type KubeletConfigOptions

type KubeletConfigOptions struct {
	Name         string
	PodPidsLimit int
}

func NewKubeletConfigOptions

func NewKubeletConfigOptions() *KubeletConfigOptions

func (*KubeletConfigOptions) AddAllFlags

func (k *KubeletConfigOptions) AddAllFlags(cmd *cobra.Command)

func (*KubeletConfigOptions) AddNameFlag

func (k *KubeletConfigOptions) AddNameFlag(cmd *cobra.Command)

func (*KubeletConfigOptions) BindFromArgs

func (k *KubeletConfigOptions) BindFromArgs(args []string)

BindFromArgs allows the user to use positional args for the name. The --name flag will take precedence

func (*KubeletConfigOptions) ValidateForHypershift

func (k *KubeletConfigOptions) ValidateForHypershift() error

type KubeletOperation

type KubeletOperation string

const (
	OperationDelete KubeletOperation = "delete"
	OperationEdit   KubeletOperation = "edit"
	OperationCreate KubeletOperation = "create"
)

type MockCapabilityChecker

type MockCapabilityChecker struct {
	// contains filtered or unexported fields
}

MockCapabilityChecker is a mock of CapabilityChecker interface.

func NewMockCapabilityChecker

func NewMockCapabilityChecker(ctrl *gomock.Controller) *MockCapabilityChecker

NewMockCapabilityChecker creates a new mock instance.

func (*MockCapabilityChecker) EXPECT

func (m *MockCapabilityChecker) EXPECT() *MockCapabilityCheckerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCapabilityChecker) IsCapabilityEnabled

func (m *MockCapabilityChecker) IsCapabilityEnabled(capability string) (bool, error)

IsCapabilityEnabled mocks base method.

type MockCapabilityCheckerMockRecorder

type MockCapabilityCheckerMockRecorder struct {
	// contains filtered or unexported fields
}

MockCapabilityCheckerMockRecorder is the mock recorder for MockCapabilityChecker.

func (*MockCapabilityCheckerMockRecorder) IsCapabilityEnabled

func (mr *MockCapabilityCheckerMockRecorder) IsCapabilityEnabled(capability any) *gomock.Call

IsCapabilityEnabled indicates an expected call of IsCapabilityEnabled.