mirrors/k3d
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add k3s_url to worker nodes

Browse Source
This commit is contained in:
iwilltry42 2019-10-10 16:57:49 +02:00
parent d88c42208f
commit 87c36f124c
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/cluster/cluster.go
View File

@ -85,9 +85,12 @@ func CreateCluster(cluster *k3d.Cluster, runtime k3drt.Runtime) error {
// name suffix // name suffix
suffix = workerCount suffix = workerCount
workerCount++ workerCount++
// connection url
node.Env = append(node.Env, fmt.Sprintf("K3S_URL=https://%s:%d", generateNodeName(cluster.Name, k3d.MasterRole, 0), 6443)) // TODO: use actual configurable api-port
} }
node.Name = fmt.Sprintf("%s-%s-%s-%d", k3d.DefaultObjectNamePrefix, cluster.Name, node.Role, suffix) // TODO: move this somewhere else? node.Name = generateNodeName(cluster.Name, node.Role, suffix)
node.Network = cluster.Network node.Network = cluster.Network
// create node // create node
@ -122,3 +125,7 @@ func GetCluster(cluster *k3d.Cluster, runtime k3drt.Runtime) (*k3d.Cluster, erro
func GenerateClusterSecret() string { func GenerateClusterSecret() string {
return util.GenerateRandomString(20) return util.GenerateRandomString(20)
} }
func generateNodeName(cluster string, role k3d.Role, suffix int) string {
return fmt.Sprintf("%s-%s-%s-%d", k3d.DefaultObjectNamePrefix, cluster, role, suffix)
}