utils

package

v1.10.4-alpha Latest Latest Go to latest Published: Jul 15, 2018 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/platform9/nodeadm

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CreateSymLinks(sourceDir, targetDir string, overwriteSymlinks bool)
func Download(fileName string, url string, mode os.FileMode)
func EnableAndStartService(unitFile string) error
func GetImages() []string
func InitConfigurationFromFile(path string) (*apis.InitConfiguration, error)
func InstallMasterComponents(config *apis.InitConfiguration)
func InstallWorkerComponents(config *apis.JoinConfiguration)
func JoinConfigurationFromFile(path string) (*apis.JoinConfiguration, error)
func PlaceComponentsFromCache(netConfig apis.Networking)
func PopulateCache()
func ReplaceString(file string, from string, to string)
func ResetFailedService(unitFile string) error
func Run(rootDir string, cmdStr string, arg ...string)
func RunBestEffort(rootDir string, cmdStr string, arg ...string)
func StopAndDisableService(unitFile string) error
type Artifact

Constants ¶

This section is empty.

Variables ¶

View Source

var DOCKER_IMAGES = []string{
	constants.KEEPALIVED_IMG,
	fmt.Sprintf("k8s.gcr.io/kube-apiserver-amd64:%s", constants.KUBERNETES_VERSION),
	fmt.Sprintf("k8s.gcr.io/kube-controller-manager-amd64:%s", constants.KUBERNETES_VERSION),
	fmt.Sprintf("k8s.gcr.io/kube-scheduler-amd64:%s", constants.KUBERNETES_VERSION),
	fmt.Sprintf("k8s.gcr.io/kube-proxy-amd64:%s", constants.KUBERNETES_VERSION),
	fmt.Sprintf("k8s.gcr.io/k8s-dns-sidecar-amd64:%s", constants.KUBE_DNS_VERSION),
	fmt.Sprintf("k8s.gcr.io/k8s-dns-kube-dns-amd64:%s", constants.KUBE_DNS_VERSION),
	fmt.Sprintf("k8s.gcr.io/k8s-dns-dnsmasq-nanny-amd64:%s", constants.KUBE_DNS_VERSION),
	"quay.io/coreos/flannel:v0.10.0-amd64",
	"k8s.gcr.io/pause-amd64:3.1",
	"metallb/speaker:master",
	"metallb/controller:master",
}

View Source

var NodeArtifact = []Artifact{
	{
		Name:     constants.KubeadmFilename,
		Type:     "executable",
		Upstream: fmt.Sprintf("https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/", constants.KUBERNETES_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.KUBE_DIR_NAME),
	},
	{
		Name:     constants.KubectlFilename,
		Type:     "executable",
		Upstream: fmt.Sprintf("https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/", constants.KUBERNETES_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.KUBE_DIR_NAME),
	},
	{
		Name:     constants.KubeletFilename,
		Type:     "executable",
		Upstream: fmt.Sprintf("https://storage.googleapis.com/kubernetes-release/release/%s/bin/linux/amd64/", constants.KUBERNETES_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.KUBE_DIR_NAME),
	},
	{
		Name:     constants.KubeletSystemdUnitFilename,
		Type:     "regular",
		Upstream: fmt.Sprintf("https://raw.githubusercontent.com/kubernetes/kubernetes/%s/build/debs/", constants.KUBERNETES_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.KUBE_DIR_NAME),
	},
	{
		Name:     constants.KubeadmKubeletSystemdDropinFilename,
		Type:     "regular",
		Upstream: fmt.Sprintf("https://raw.githubusercontent.com/kubernetes/kubernetes/%s/build/debs/", constants.KUBERNETES_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.KUBE_DIR_NAME),
	},
	{
		Name:     constants.CNIPluginsFilename,
		Type:     "regular",
		Upstream: fmt.Sprintf("https://github.com/containernetworking/plugins/releases/download/%s/", constants.CNI_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.CNI_DIR_NAME),
	},
	{
		Name:     constants.FlannelManifestFilename,
		Type:     "regular",
		Upstream: fmt.Sprintf("https://raw.githubusercontent.com/coreos/flannel/%s/Documentation/", constants.FLANNEL_VERSION),
		Local:    filepath.Join(constants.CACHE_DIR, constants.FLANNEL_DIR_NAME),
	},
}

Functions ¶

func CreateSymLinks ¶

func CreateSymLinks(sourceDir, targetDir string, overwriteSymlinks bool)

Create symlinks of all the files inside sourceDir to targetDir

func Download ¶

func Download(fileName string, url string, mode os.FileMode)

func EnableAndStartService ¶

func EnableAndStartService(unitFile string) error

EnableAndStartService enables and starts the etcd service

func GetImages ¶

func GetImages() []string

func InitConfigurationFromFile ¶

func InitConfigurationFromFile(path string) (*apis.InitConfiguration, error)

func InstallMasterComponents ¶

func InstallMasterComponents(config *apis.InitConfiguration)

func InstallWorkerComponents ¶

func InstallWorkerComponents(config *apis.JoinConfiguration)

func JoinConfigurationFromFile ¶

func JoinConfigurationFromFile(path string) (*apis.JoinConfiguration, error)

func PlaceComponentsFromCache ¶

func PlaceComponentsFromCache(netConfig apis.Networking)

func PopulateCache ¶

func PopulateCache()

func ReplaceString ¶

func ReplaceString(file string, from string, to string)

func ResetFailedService ¶

func ResetFailedService(unitFile string) error

ResetFailedService invokes reset-failed on a service if the service satisfies the is-failed query, otherwise a noop

func Run ¶

func Run(rootDir string, cmdStr string, arg ...string)

func RunBestEffort ¶

func RunBestEffort(rootDir string, cmdStr string, arg ...string)

func StopAndDisableService ¶

func StopAndDisableService(unitFile string) error

StopAndDisableService stops and disables service

Types ¶

type Artifact ¶

type Artifact struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	Upstream string `json:"upstream"`
	Local    string `json:"local"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL