Compare commits
1 Commits
Author | SHA1 | Date |
---|---|---|
pcaseiro | 473ff8ea35 |
|
@ -1,49 +0,0 @@
|
||||||
{
|
|
||||||
"Globals": {
|
|
||||||
"Vars": {
|
|
||||||
"PrometheusPort": "9090"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"Name": "loki-stack",
|
|
||||||
"Services": {
|
|
||||||
"Loki-Stack": {
|
|
||||||
"ConfigFiles": [],
|
|
||||||
"Daemons": {},
|
|
||||||
"Users": {},
|
|
||||||
"Repositories": {
|
|
||||||
"Grafana": {
|
|
||||||
"enabled": true,
|
|
||||||
"name": "grafana",
|
|
||||||
"type": "helm",
|
|
||||||
"url": "https://grafana.github.io/helm-charts"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"Packages": {
|
|
||||||
"loki": {
|
|
||||||
"type" : "helm",
|
|
||||||
"action": "install",
|
|
||||||
"name": "loki",
|
|
||||||
"repository": "grafana"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"Vars": {
|
|
||||||
"AlertManagerURL": "http://localhost:9092",
|
|
||||||
"AuthEnabled": false,
|
|
||||||
"GRPCPort": "9095",
|
|
||||||
"Group": "grafana",
|
|
||||||
"HTTPPort": "3099",
|
|
||||||
"LogLevel": "error",
|
|
||||||
"ObjectStore": "filesystem",
|
|
||||||
"S2": {
|
|
||||||
"APIKey": "",
|
|
||||||
"APISecretKey": "",
|
|
||||||
"BucketName": "",
|
|
||||||
"URL": ""
|
|
||||||
},
|
|
||||||
"SharedStore": "filesystem",
|
|
||||||
"StorageRoot": "/var/loki",
|
|
||||||
"User": "loki"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -14,22 +14,9 @@ type SystemPackage struct {
|
||||||
Action string `json:"action"`
|
Action string `json:"action"`
|
||||||
OS string `json:"os"`
|
OS string `json:"os"`
|
||||||
Distribution string `json:"distribution"`
|
Distribution string `json:"distribution"`
|
||||||
NameSpace string `json:"namespace"`
|
|
||||||
Repository string `json:"repository"`
|
|
||||||
URL string `json:"url"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *SystemPackage) SetDistribution() error {
|
func (p *SystemPackage) SetDistribution() error {
|
||||||
|
|
||||||
// If the package type is helm or kubectl we set distribution to k8s
|
|
||||||
if p.Type == "helm" || p.Type == "kubectl" {
|
|
||||||
p.Distribution = p.Type
|
|
||||||
if len(p.NameSpace) == 0 {
|
|
||||||
p.NameSpace = p.Name
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
OSConfig, err := utils.ReadOSRelease()
|
OSConfig, err := utils.ReadOSRelease()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -69,12 +56,6 @@ func (p *SystemPackage) Manage() error {
|
||||||
_, stdErr, pkErr = utils.RunSystemCommand("yum", "install", "-y", p.Name)
|
_, stdErr, pkErr = utils.RunSystemCommand("yum", "install", "-y", p.Name)
|
||||||
case "arch":
|
case "arch":
|
||||||
_, stdErr, pkErr = utils.RunSystemCommand("pacman", "-Suy", p.Name)
|
_, stdErr, pkErr = utils.RunSystemCommand("pacman", "-Suy", p.Name)
|
||||||
case "helm":
|
|
||||||
toInstall := fmt.Sprintf("%s/%s", p.Repository, p.Name)
|
|
||||||
nameSpaceOPT := fmt.Sprintf("--namespace=%s", p.NameSpace)
|
|
||||||
_, stdErr, pkErr = utils.RunSystemCommand("helm", "upgrade", "--install", p.Name, nameSpaceOPT, toInstall)
|
|
||||||
case "kubectl":
|
|
||||||
_, stdErr, pkErr = utils.RunSystemCommand("kubectl", "apply", p.URL)
|
|
||||||
default:
|
default:
|
||||||
pkErr = fmt.Errorf("Unsupported OS %s [%s]", p.OS, stdErr)
|
pkErr = fmt.Errorf("Unsupported OS %s [%s]", p.OS, stdErr)
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,54 +1,11 @@
|
||||||
package templater
|
package templater
|
||||||
|
|
||||||
import (
|
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
|
||||||
|
|
||||||
"forge.cadoles.com/pcaseiro/templatefile/pkg/utils"
|
|
||||||
)
|
|
||||||
|
|
||||||
type HelmRepository struct {
|
type HelmRepository struct {
|
||||||
Repository
|
Repository
|
||||||
}
|
}
|
||||||
|
|
||||||
func (hr *HelmRepository) repoExists() (bool, error) {
|
|
||||||
var repos []HelmRepository
|
|
||||||
|
|
||||||
stdOut, stdErr, err := utils.RunSystemCommand("helm", "repo", "list", "-o", "json")
|
|
||||||
if err != nil {
|
|
||||||
return false, fmt.Errorf("%s %v", stdErr, err)
|
|
||||||
}
|
|
||||||
err = json.Unmarshal(stdOut, &repos)
|
|
||||||
if err != nil {
|
|
||||||
return false, err
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, repo := range repos {
|
|
||||||
if repo.Name == hr.Name {
|
|
||||||
return true, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (hr *HelmRepository) Add() error {
|
func (hr *HelmRepository) Add() error {
|
||||||
|
|
||||||
repoExists, err := hr.repoExists()
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
if repoExists {
|
|
||||||
return nil
|
|
||||||
} else {
|
|
||||||
_, stdErr, err := utils.RunSystemCommand("helm", "repo", "add", hr.Name, hr.URL)
|
|
||||||
if err != nil {
|
|
||||||
return fmt.Errorf("%s %v", stdErr, err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (hr *HelmRepository) Update() error {
|
func (hr *HelmRepository) Update() error {
|
||||||
|
|
Loading…
Reference in New Issue