forked from LaconicNetwork/kompose
Merge branch 'refactor-convert', close #21
This commit is contained in:
commit
2e986b61e7
@ -596,7 +596,11 @@ func ProjectKuberConvert(p *project.Project, c *cli.Context) {
|
|||||||
f := createOutFile(outFile)
|
f := createOutFile(outFile)
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
|
|
||||||
var mServices map[string]api.Service = make(map[string]api.Service)
|
var mServices map[string][]byte = make(map[string][]byte)
|
||||||
|
var mReplicationControllers map[string][]byte = make(map[string][]byte)
|
||||||
|
var mDeployments map[string][]byte = make(map[string][]byte)
|
||||||
|
var mDaemonSets map[string][]byte = make(map[string][]byte)
|
||||||
|
var mReplicaSets map[string][]byte = make(map[string][]byte)
|
||||||
var serviceLinks []string
|
var serviceLinks []string
|
||||||
|
|
||||||
for name, service := range p.Configs {
|
for name, service := range p.Configs {
|
||||||
@ -740,52 +744,68 @@ func ProjectKuberConvert(p *project.Project, c *cli.Context) {
|
|||||||
logrus.Fatalf(err)
|
logrus.Fatalf(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
mServices[name] = *sc
|
// convert datasvc to json / yaml
|
||||||
|
datasvc, err := transformer(sc, "service controller", generateYaml)
|
||||||
|
if err != "" {
|
||||||
|
logrus.Fatalf(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
mServices[name] = datasvc
|
||||||
|
mReplicationControllers[name] = datarc
|
||||||
|
mDeployments[name] = datadc
|
||||||
|
mDaemonSets[name] = datads
|
||||||
|
mReplicaSets[name] = datars
|
||||||
|
exists := false
|
||||||
|
|
||||||
if len(service.Links.Slice()) > 0 {
|
if len(service.Links.Slice()) > 0 {
|
||||||
for i := 0; i < len(service.Links.Slice()); i++ {
|
for i := 0; i < len(service.Links.Slice()); i++ {
|
||||||
var data string = service.Links.Slice()[i]
|
var data string = service.Links.Slice()[i]
|
||||||
if len(serviceLinks) == 0 {
|
|
||||||
serviceLinks = append(serviceLinks, data)
|
|
||||||
} else {
|
|
||||||
for _, v := range serviceLinks {
|
for _, v := range serviceLinks {
|
||||||
if v != data {
|
if v == data {
|
||||||
|
exists = true
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if !exists {
|
||||||
serviceLinks = append(serviceLinks, data)
|
serviceLinks = append(serviceLinks, data)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
for _, serviceLink := range serviceLinks {
|
||||||
|
mServices[serviceLink] = nil
|
||||||
|
}
|
||||||
|
|
||||||
|
for k, v := range mServices {
|
||||||
|
if v != nil {
|
||||||
|
print(k, "svc", v, toStdout, generateYaml, f)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// If --out or --stdout is set, the validation should already prevent multiple controllers being generated
|
// If --out or --stdout is set, the validation should already prevent multiple controllers being generated
|
||||||
if createD {
|
if createD {
|
||||||
// Create the deployment
|
for k, v := range mDeployments {
|
||||||
print(name, "deployment", datadc, toStdout, generateYaml, f)
|
print(k, "deployment", v, toStdout, generateYaml, f)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if createDS {
|
if createDS {
|
||||||
// Create the daemonset
|
for k, v := range mDaemonSets {
|
||||||
print(name, "daemonset", datads, toStdout, generateYaml, f)
|
print(k, "daemonset", v, toStdout, generateYaml, f)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if createRS {
|
if createRS {
|
||||||
// Create the replicaset container
|
for k, v := range mReplicaSets {
|
||||||
print(name, "replicaset", datars, toStdout, generateYaml, f)
|
print(k, "replicaset", v, toStdout, generateYaml, f)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// We can create RC when we either don't print to --out or --stdout, or we don't create any other controllers
|
// We can create RC when we either don't print to --out or --stdout, or we don't create any other controllers
|
||||||
if !singleOutput || (!createD && !createDS && !createRS) {
|
if !singleOutput || (!createD && !createDS && !createRS) {
|
||||||
print(name, "rc", datarc, toStdout, generateYaml, f)
|
for k, v := range mReplicationControllers {
|
||||||
}
|
print(k, "rc", v, toStdout, generateYaml, f)
|
||||||
|
|
||||||
// Create the services
|
|
||||||
for k, v := range mServices {
|
|
||||||
for i := 0; i < len(serviceLinks); i++ {
|
|
||||||
// convert datasvc to json / yaml
|
|
||||||
datasvc, err := transformer(v, "service controller", generateYaml)
|
|
||||||
if err != "" {
|
|
||||||
logrus.Fatalf(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
print(k, "svc", datasvc, toStdout, generateYaml, f)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -14,8 +14,8 @@ gitlab:
|
|||||||
restart: always
|
restart: always
|
||||||
image: sameersbn/gitlab:8.6.4
|
image: sameersbn/gitlab:8.6.4
|
||||||
links:
|
links:
|
||||||
- redisio:redisio
|
- redisio
|
||||||
- postgresql:postgresql
|
- postgresql
|
||||||
ports:
|
ports:
|
||||||
- "10080:80"
|
- "10080:80"
|
||||||
- "10022:22"
|
- "10022:22"
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user