const unableToDecodeCoreDNS … const coreDNSReplicas … // DeployedDNSAddon returns the image tag of the DNS addon currently deployed func DeployedDNSAddon(client clientset.Interface) (string, error) { … } // deployedDNSReplicas returns the replica count for the current DNS deployment func deployedDNSReplicas(client clientset.Interface, replicas int32) (*int32, error) { … } // EnsureDNSAddon creates the CoreDNS addon func EnsureDNSAddon(cfg *kubeadmapi.ClusterConfiguration, client clientset.Interface, patchesDir string, out io.Writer, printManifest bool) error { … } func coreDNSAddon(cfg *kubeadmapi.ClusterConfiguration, client clientset.Interface, replicas *int32, patchesDir string, out io.Writer, printManifest bool) error { … } func createCoreDNSAddon(deploymentBytes, serviceBytes, configBytes []byte, client clientset.Interface) error { … } func createDNSService(dnsService *v1.Service, serviceBytes []byte, client clientset.Interface) error { … } // isCoreDNSConfigMapMigrationRequired checks if a migration of the CoreDNS ConfigMap is required. func isCoreDNSConfigMapMigrationRequired(corefile, currentInstalledCoreDNSVersion string) (bool, error) { … } func migrateCoreDNSCorefile(client clientset.Interface, cm *v1.ConfigMap, corefile, currentInstalledCoreDNSVersion string) error { … } // GetCoreDNSInfo gets the current CoreDNS installed and the current Corefile Configuration of CoreDNS. func GetCoreDNSInfo(client clientset.Interface) (*v1.ConfigMap, string, string, error) { … } func setCorefile(client clientset.Interface, coreDNSCorefileName string) error { … } // applyCoreDNSDeploymentPatches reads patches from a directory and applies them over the input coreDNSDeploymentBytes func applyCoreDNSDeploymentPatches(coreDNSDeploymentBytes []byte, patchesDir string, output io.Writer) ([]byte, error) { … }
Codebase Browser
kubernetes