func getKubeletConfigFilePath() (string, error) { … } // GetCurrentKubeletConfigFromFile returns the current kubelet configuration under the filesystem. // This method should only run together with e2e node tests, meaning the test executor and the cluster nodes is the // same machine func GetCurrentKubeletConfigFromFile() (*kubeletconfig.KubeletConfiguration, error) { … } // WriteKubeletConfigFile updates the kubelet configuration under the filesystem // This method should only run together with e2e node tests, meaning the test executor and the cluster nodes is the // same machine func WriteKubeletConfigFile(kubeletConfig *kubeletconfig.KubeletConfiguration) error { … } // GetCurrentKubeletConfig fetches the current Kubelet Config for the given node func GetCurrentKubeletConfig(ctx context.Context, nodeName, namespace string, useProxy bool, standaloneMode bool) (*kubeletconfig.KubeletConfiguration, error) { … } // returns a status 200 response from the /configz endpoint or nil if fails func pollConfigz(ctx context.Context, timeout time.Duration, pollInterval time.Duration, nodeName, namespace string, useProxy bool, standaloneMode bool) []byte { … } // Decodes the http response from /configz and returns a kubeletconfig.KubeletConfiguration (internal type). func decodeConfigz(respBody []byte) (*kubeletconfig.KubeletConfiguration, error) { … }