ready for great things!
This commit is contained in:
parent
c2d111a928
commit
6c41ae2fd5
37
README.md
37
README.md
@ -1,3 +1,40 @@
|
|||||||
# Overlord
|
# Overlord
|
||||||
|
|
||||||
Full management suite for libvirt and kubernetes clusters!
|
Full management suite for libvirt and kubernetes clusters!
|
||||||
|
|
||||||
|
## Running it for yourself
|
||||||
|
Remember to go get dependencies.
|
||||||
|
|
||||||
|
### Config
|
||||||
|
Create a file in the working directory of Overlord named lord.json.
|
||||||
|
You may also specify a config file with -c command line argument.
|
||||||
|
This file may look like this.
|
||||||
|
Everything is optional!
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"LibVirtHosts": [
|
||||||
|
"qemu:///system"
|
||||||
|
],
|
||||||
|
"MongoDbStr": "mongodb://localhost:27017",
|
||||||
|
"LogLevel": 0,
|
||||||
|
"LogFilePath": "lord.log"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
No log file means stdout only!
|
||||||
|
The loglevels are;
|
||||||
|
```go
|
||||||
|
type LogLevel int
|
||||||
|
const (
|
||||||
|
TRACE LogLevel = iota
|
||||||
|
DEBUG
|
||||||
|
INFO
|
||||||
|
WARN
|
||||||
|
ERROR
|
||||||
|
FATAL
|
||||||
|
)
|
||||||
|
```
|
||||||
|
Use the corresponding integer starting at 0 for TRACE up to 4 for FATAL.
|
||||||
|
|
||||||
|
### Docker
|
||||||
|
Docker compose based development environment in the workings.
|
||||||
|
There will also be a Overlord docker image.
|
||||||
|
|||||||
4
TODO.md
Normal file
4
TODO.md
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
# TODO
|
||||||
|
|
||||||
|
* Add support for libvirt connection auth.
|
||||||
|
* Fix docker development environment.
|
||||||
19
go.mod
19
go.mod
@ -2,4 +2,21 @@ module bitsnthings.dev/overlord
|
|||||||
|
|
||||||
go 1.17
|
go 1.17
|
||||||
|
|
||||||
require libvirt.org/go/libvirt v1.7007.0 // indirect
|
require (
|
||||||
|
go.mongodb.org/mongo-driver v1.7.2
|
||||||
|
libvirt.org/go/libvirt v1.7007.0
|
||||||
|
)
|
||||||
|
|
||||||
|
require (
|
||||||
|
github.com/go-stack/stack v1.8.0 // indirect
|
||||||
|
github.com/golang/snappy v0.0.3 // indirect
|
||||||
|
github.com/klauspost/compress v1.13.4 // indirect
|
||||||
|
github.com/pkg/errors v0.9.1 // indirect
|
||||||
|
github.com/xdg-go/pbkdf2 v1.0.0 // indirect
|
||||||
|
github.com/xdg-go/scram v1.0.2 // indirect
|
||||||
|
github.com/xdg-go/stringprep v1.0.2 // indirect
|
||||||
|
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
|
||||||
|
golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a // indirect
|
||||||
|
golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e // indirect
|
||||||
|
golang.org/x/text v0.3.6 // indirect
|
||||||
|
)
|
||||||
|
|||||||
126
go.sum
126
go.sum
@ -1,4 +1,126 @@
|
|||||||
|
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
|
||||||
|
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
|
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||||
|
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
|
github.com/go-stack/stack v1.8.0 h1:5SgMzNM5HxrEjV0ww2lTmX6E2Izsfxas4+YHWRs3Lsk=
|
||||||
|
github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
|
||||||
|
github.com/gobuffalo/attrs v0.0.0-20190224210810-a9411de4debd/go.mod h1:4duuawTqi2wkkpB4ePgWMaai6/Kc6WEz83bhFwpHzj0=
|
||||||
|
github.com/gobuffalo/depgen v0.0.0-20190329151759-d478694a28d3/go.mod h1:3STtPUQYuzV0gBVOY3vy6CfMm/ljR4pABfrTeHNLHUY=
|
||||||
|
github.com/gobuffalo/depgen v0.1.0/go.mod h1:+ifsuy7fhi15RWncXQQKjWS9JPkdah5sZvtHc2RXGlg=
|
||||||
|
github.com/gobuffalo/envy v1.6.15/go.mod h1:n7DRkBerg/aorDM8kbduw5dN3oXGswK5liaSCx4T5NI=
|
||||||
|
github.com/gobuffalo/envy v1.7.0/go.mod h1:n7DRkBerg/aorDM8kbduw5dN3oXGswK5liaSCx4T5NI=
|
||||||
|
github.com/gobuffalo/flect v0.1.0/go.mod h1:d2ehjJqGOH/Kjqcoz+F7jHTBbmDb38yXA598Hb50EGs=
|
||||||
|
github.com/gobuffalo/flect v0.1.1/go.mod h1:8JCgGVbRjJhVgD6399mQr4fx5rRfGKVzFjbj6RE/9UI=
|
||||||
|
github.com/gobuffalo/flect v0.1.3/go.mod h1:8JCgGVbRjJhVgD6399mQr4fx5rRfGKVzFjbj6RE/9UI=
|
||||||
|
github.com/gobuffalo/genny v0.0.0-20190329151137-27723ad26ef9/go.mod h1:rWs4Z12d1Zbf19rlsn0nurr75KqhYp52EAGGxTbBhNk=
|
||||||
|
github.com/gobuffalo/genny v0.0.0-20190403191548-3ca520ef0d9e/go.mod h1:80lIj3kVJWwOrXWWMRzzdhW3DsrdjILVil/SFKBzF28=
|
||||||
|
github.com/gobuffalo/genny v0.1.0/go.mod h1:XidbUqzak3lHdS//TPu2OgiFB+51Ur5f7CSnXZ/JDvo=
|
||||||
|
github.com/gobuffalo/genny v0.1.1/go.mod h1:5TExbEyY48pfunL4QSXxlDOmdsD44RRq4mVZ0Ex28Xk=
|
||||||
|
github.com/gobuffalo/gitgen v0.0.0-20190315122116-cc086187d211/go.mod h1:vEHJk/E9DmhejeLeNt7UVvlSGv3ziL+djtTr3yyzcOw=
|
||||||
|
github.com/gobuffalo/gogen v0.0.0-20190315121717-8f38393713f5/go.mod h1:V9QVDIxsgKNZs6L2IYiGR8datgMhB577vzTDqypH360=
|
||||||
|
github.com/gobuffalo/gogen v0.1.0/go.mod h1:8NTelM5qd8RZ15VjQTFkAW6qOMx5wBbW4dSCS3BY8gg=
|
||||||
|
github.com/gobuffalo/gogen v0.1.1/go.mod h1:y8iBtmHmGc4qa3urIyo1shvOD8JftTtfcKi+71xfDNE=
|
||||||
|
github.com/gobuffalo/logger v0.0.0-20190315122211-86e12af44bc2/go.mod h1:QdxcLw541hSGtBnhUc4gaNIXRjiDppFGaDqzbrBd3v8=
|
||||||
|
github.com/gobuffalo/mapi v1.0.1/go.mod h1:4VAGh89y6rVOvm5A8fKFxYG+wIW6LO1FMTG9hnKStFc=
|
||||||
|
github.com/gobuffalo/mapi v1.0.2/go.mod h1:4VAGh89y6rVOvm5A8fKFxYG+wIW6LO1FMTG9hnKStFc=
|
||||||
|
github.com/gobuffalo/packd v0.0.0-20190315124812-a385830c7fc0/go.mod h1:M2Juc+hhDXf/PnmBANFCqx4DM3wRbgDvnVWeG2RIxq4=
|
||||||
|
github.com/gobuffalo/packd v0.1.0/go.mod h1:M2Juc+hhDXf/PnmBANFCqx4DM3wRbgDvnVWeG2RIxq4=
|
||||||
|
github.com/gobuffalo/packr/v2 v2.0.9/go.mod h1:emmyGweYTm6Kdper+iywB6YK5YzuKchGtJQZ0Odn4pQ=
|
||||||
|
github.com/gobuffalo/packr/v2 v2.2.0/go.mod h1:CaAwI0GPIAv+5wKLtv8Afwl+Cm78K/I/VCm/3ptBN+0=
|
||||||
|
github.com/gobuffalo/syncx v0.0.0-20190224160051-33c29581e754/go.mod h1:HhnNqWY95UYwwW3uSASeV7vtgYkT2t16hJgV3AEPUpw=
|
||||||
|
github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
|
||||||
|
github.com/golang/snappy v0.0.3 h1:fHPg5GQYlCeLIPB9BZqMVR5nR9A+IM5zcgeTdjMYmLA=
|
||||||
|
github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
|
||||||
|
github.com/google/go-cmp v0.5.2 h1:X2ev0eStA3AbceY54o37/0PQ/UWqKEiiO2dKL5OPaFM=
|
||||||
|
github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
|
||||||
|
github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
|
||||||
|
github.com/joho/godotenv v1.3.0/go.mod h1:7hK45KPybAkOC6peb+G5yklZfMxEjkZhHbwpqxOKXbg=
|
||||||
|
github.com/karrick/godirwalk v1.8.0/go.mod h1:H5KPZjojv4lE+QYImBI8xVtrBRgYrIVsaRPx4tDPEn4=
|
||||||
|
github.com/karrick/godirwalk v1.10.3/go.mod h1:RoGL9dQei4vP9ilrpETWE8CLOZ1kiN0LhBygSwrAsHA=
|
||||||
|
github.com/klauspost/compress v1.9.5/go.mod h1:RyIbtBH6LamlWaDj8nUwkbUhJ87Yi3uG0guNDohfE1A=
|
||||||
|
github.com/klauspost/compress v1.13.4 h1:0zhec2I8zGnjWcKyLl6i3gPqKANCCn5e9xmviEEeX6s=
|
||||||
|
github.com/klauspost/compress v1.13.4/go.mod h1:8dP1Hq4DHOhN9w426knH3Rhby4rFm6D8eO+e+Dq5Gzg=
|
||||||
|
github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
|
||||||
|
github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
|
||||||
|
github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
|
||||||
|
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
|
||||||
|
github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
|
||||||
|
github.com/markbates/oncer v0.0.0-20181203154359-bf2de49a0be2/go.mod h1:Ld9puTsIW75CHf65OeIOkyKbteujpZVXDpWK6YGZbxE=
|
||||||
|
github.com/markbates/safe v1.0.1/go.mod h1:nAqgmRi7cY2nqMc92/bSEeQA+R4OheNU2T1kNSCBdG0=
|
||||||
|
github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe/go.mod h1:wL8QJuTMNUDYhXwkmfOly8iTdp5TEcJFWZD2D7SIkUc=
|
||||||
|
github.com/pelletier/go-toml v1.7.0/go.mod h1:vwGMzjaWMwyfHwgIBhI2YUM4fB6nL6lVAvS1LBMMhTE=
|
||||||
|
github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||||
|
github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||||
|
github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
|
||||||
|
github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
|
||||||
|
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||||
|
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||||
|
github.com/rogpeppe/go-internal v1.1.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
|
||||||
|
github.com/rogpeppe/go-internal v1.2.2/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
|
||||||
|
github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
|
||||||
|
github.com/sirupsen/logrus v1.4.0/go.mod h1:LxeOpSwHxABJmUn/MG1IvRgCAasNZTLOkJPxbbu5VWo=
|
||||||
|
github.com/sirupsen/logrus v1.4.1/go.mod h1:ni0Sbl8bgC9z8RoU9G6nDWqqs/fq4eDPysMBDgk/93Q=
|
||||||
|
github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
|
||||||
|
github.com/spf13/cobra v0.0.3/go.mod h1:1l0Ry5zgKvJasoi3XT1TypsSe7PqH0Sj9dhYf7v3XqQ=
|
||||||
|
github.com/spf13/pflag v1.0.3/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4=
|
||||||
|
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||||
|
github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||||
|
github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
|
||||||
|
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
|
||||||
|
github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
|
||||||
|
github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
|
||||||
|
github.com/tidwall/pretty v1.0.0 h1:HsD+QiTn7sK6flMKIvNmpqz1qrpP3Ps6jOKIKMooyg4=
|
||||||
|
github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=
|
||||||
|
github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
|
||||||
|
github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
|
||||||
|
github.com/xdg-go/scram v1.0.2 h1:akYIkZ28e6A96dkWNJQu3nmCzH3YfwMPQExUYDaRv7w=
|
||||||
|
github.com/xdg-go/scram v1.0.2/go.mod h1:1WAq6h33pAW+iRreB34OORO2Nf7qel3VV3fjBj+hCSs=
|
||||||
|
github.com/xdg-go/stringprep v1.0.2 h1:6iq84/ryjjeRmMJwxutI51F2GIPlP5BfTvXHeYjyhBc=
|
||||||
|
github.com/xdg-go/stringprep v1.0.2/go.mod h1:8F9zXuvzgwmyT5DUm4GUfZGDdT3W+LCvS6+da4O5kxM=
|
||||||
|
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA=
|
||||||
|
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
|
||||||
|
go.mongodb.org/mongo-driver v1.7.2 h1:pFttQyIiJUHEn50YfZgC9ECjITMT44oiN36uArf/OFg=
|
||||||
|
go.mongodb.org/mongo-driver v1.7.2/go.mod h1:Q4oFMbo1+MSNqICAdYMlC/zSTrwCogR4R8NzkI+yfU8=
|
||||||
|
golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4=
|
||||||
|
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||||
|
golang.org/x/crypto v0.0.0-20190422162423-af44ce270edf/go.mod h1:WFFai1msRO1wXaEeE5yQxYXgSfI8pQAWXbQop6sCtWE=
|
||||||
|
golang.org/x/crypto v0.0.0-20200302210943-78000ba7a073/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
|
||||||
|
golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a h1:kr2P4QFmQr29mSLA43kwrOcgcReGTfbE9N577tCTuBc=
|
||||||
|
golang.org/x/crypto v0.0.0-20210513164829-c07d793c2f9a/go.mod h1:P+XmwS30IXTQdn5tA2iutPOUgjI07+tq3H3K9MVA1s8=
|
||||||
|
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||||
|
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||||
|
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
|
||||||
|
golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||||
|
golang.org/x/sync v0.0.0-20190412183630-56d357773e84/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||||
|
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||||
|
golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e h1:vcxGaoTs7kV8m5Np9uUNQin4BrLOthgV7252N8V+FwY=
|
||||||
|
golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
|
||||||
|
golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||||
|
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||||
|
golang.org/x/sys v0.0.0-20190403152447-81d4e9dc473e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20190419153524-e8e3143a4f4a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20190531175056-4c3a928424d2/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
|
||||||
|
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||||
|
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||||
|
golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||||
|
golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M=
|
||||||
|
golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||||
|
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
|
||||||
|
golang.org/x/tools v0.0.0-20190329151228-23e29df326fe/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
|
||||||
|
golang.org/x/tools v0.0.0-20190416151739-9c9e1878f421/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
|
||||||
|
golang.org/x/tools v0.0.0-20190420181800-aa740d480789/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
|
||||||
|
golang.org/x/tools v0.0.0-20190531172133-b3315ee88b7d/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=
|
||||||
|
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
|
||||||
|
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
|
||||||
|
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||||
|
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||||
|
gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
|
||||||
|
gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
|
||||||
|
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
|
||||||
|
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||||
libvirt.org/go/libvirt v1.7007.0 h1:pTe6uRhxDpWzGS06SXvgeQXqWcG1aTKRfL+gS5xI9Kw=
|
libvirt.org/go/libvirt v1.7007.0 h1:pTe6uRhxDpWzGS06SXvgeQXqWcG1aTKRfL+gS5xI9Kw=
|
||||||
libvirt.org/go/libvirt v1.7007.0/go.mod h1:1WiFE8EjZfq+FCVog+rvr1yatKbKZ9FaFMZgEqxEJqQ=
|
libvirt.org/go/libvirt v1.7007.0/go.mod h1:1WiFE8EjZfq+FCVog+rvr1yatKbKZ9FaFMZgEqxEJqQ=
|
||||||
libvirt.org/libvirt-go v7.4.0+incompatible h1:1gFJevSrEoxx/5nZPB6GaTDdoc902NP2KyVPwQ07Ji4=
|
|
||||||
libvirt.org/libvirt-go v7.4.0+incompatible/go.mod h1:CPoljLoiC2aEw+62g1rZXl2oXAJaNsrq4YCSmJOELek=
|
|
||||||
|
|||||||
10
overlord.go
10
overlord.go
@ -1,15 +1,15 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"log"
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
|
overlord "bitsnthings.dev/overlord/src/state"
|
||||||
overlord "bitsnthings.dev/overlord/src"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
log.Println("Starting Overlord.")
|
log.PrintLog(log.INFO, "Starting Overlord.")
|
||||||
state := overlord.NewState()
|
state := overlord.NewState()
|
||||||
state.Setup()
|
state.Setup()
|
||||||
log.Println("Stopping Overlord.")
|
//state.MainLoop()
|
||||||
state.Stop()
|
state.Stop()
|
||||||
|
log.PrintLog(log.TRACE, "Done.")
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,27 +0,0 @@
|
|||||||
package overlord
|
|
||||||
|
|
||||||
import (
|
|
||||||
"log"
|
|
||||||
|
|
||||||
libvirt "libvirt.org/go/libvirt"
|
|
||||||
)
|
|
||||||
|
|
||||||
type Libvirt struct {
|
|
||||||
Hosts []*libvirt.Connect
|
|
||||||
Auth libvirt.ConnectAuth
|
|
||||||
Flags libvirt.ConnectFlags
|
|
||||||
}
|
|
||||||
|
|
||||||
func (virt *Libvirt) Connect(cstr string) (*libvirt.Connect, error) {
|
|
||||||
conn, err := libvirt.NewConnect(cstr) //, &virt.Auth, virt.Flags)
|
|
||||||
if err != nil {
|
|
||||||
log.Printf("Error connecting to libvirt host! %s", err)
|
|
||||||
}
|
|
||||||
return conn, err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (virt *Libvirt) ConnectMany(cstrs []string) {
|
|
||||||
for _, cstr := range cstrs {
|
|
||||||
virt.Connect(cstr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
33
src/libvirt/guests.go
Normal file
33
src/libvirt/guests.go
Normal file
@ -0,0 +1,33 @@
|
|||||||
|
package libvirt
|
||||||
|
|
||||||
|
import (
|
||||||
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
|
"libvirt.org/go/libvirt"
|
||||||
|
)
|
||||||
|
|
||||||
|
func (virt *Libvirt) getAllDomains() {
|
||||||
|
virt.getDomainsByFlag(libvirt.CONNECT_LIST_DOMAINS_ACTIVE)
|
||||||
|
virt.getDomainsByFlag(libvirt.CONNECT_LIST_DOMAINS_INACTIVE)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (virt *Libvirt) getDomainsByFlag(flag libvirt.ConnectListAllDomainsFlags) {
|
||||||
|
for _, conn := range virt.Hosts {
|
||||||
|
doms, err := conn.ListAllDomains(flag)
|
||||||
|
uri, _ := conn.GetURI()
|
||||||
|
if err != nil {
|
||||||
|
log.PrintLog(
|
||||||
|
log.ERROR,
|
||||||
|
"Error fetching domain list from node with connection uri: \"%s\"! %s",
|
||||||
|
uri, err)
|
||||||
|
}
|
||||||
|
virt.Guests[uri] = make(map[string]libvirt.Domain)
|
||||||
|
for _, dom := range doms {
|
||||||
|
name, err := dom.GetName()
|
||||||
|
if err != nil {
|
||||||
|
log.PrintLog(log.ERROR, "Error getting name of domain on node with connection string \"%s\"! %s",
|
||||||
|
uri, err)
|
||||||
|
}
|
||||||
|
virt.Guests[uri][name] = dom
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
50
src/libvirt/libvirt.go
Normal file
50
src/libvirt/libvirt.go
Normal file
@ -0,0 +1,50 @@
|
|||||||
|
package libvirt
|
||||||
|
|
||||||
|
import (
|
||||||
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
|
libvirt "libvirt.org/go/libvirt"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Libvirt struct {
|
||||||
|
Hosts map[string]*libvirt.Connect
|
||||||
|
Guests map[string]map[string]libvirt.Domain
|
||||||
|
// Auth libvirt.ConnectAuth
|
||||||
|
// Flags libvirt.ConnectFlags
|
||||||
|
}
|
||||||
|
|
||||||
|
func New() Libvirt {
|
||||||
|
return Libvirt{
|
||||||
|
map[string]*libvirt.Connect{},
|
||||||
|
map[string]map[string]libvirt.Domain{},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (virt *Libvirt) GetStatus() {
|
||||||
|
log.PrintLog(log.TRACE, "Getting libvirt cluster status.")
|
||||||
|
virt.getAllDomains()
|
||||||
|
log.PrintLog(log.INFO, "All domains in the cluster:")
|
||||||
|
for uri, doms := range virt.Guests {
|
||||||
|
log.PrintLog(log.INFO, "With uri: %s", uri)
|
||||||
|
for name, dom := range doms {
|
||||||
|
os, _ := dom.GetOSType()
|
||||||
|
log.PrintLog(log.INFO, "%s (%s)", name, os)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (virt *Libvirt) Connect(cstr string) (*libvirt.Connect, error) {
|
||||||
|
conn, err := libvirt.NewConnect(cstr) //, &virt.Auth, virt.Flags)
|
||||||
|
if err != nil {
|
||||||
|
log.PrintLog(log.WARN, "Error connecting to libvirt host with uri: \"%s\"! %s",
|
||||||
|
cstr, err)
|
||||||
|
return conn, err
|
||||||
|
}
|
||||||
|
virt.Hosts[cstr] = conn
|
||||||
|
return conn, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (virt *Libvirt) ConnectMany(cstrs []string) {
|
||||||
|
for _, cstr := range cstrs {
|
||||||
|
virt.Connect(cstr)
|
||||||
|
}
|
||||||
|
}
|
||||||
43
src/log/log.go
Normal file
43
src/log/log.go
Normal file
@ -0,0 +1,43 @@
|
|||||||
|
package log
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
|
)
|
||||||
|
|
||||||
|
var CurrentLogLevel LogLevel
|
||||||
|
|
||||||
|
type LogLevel int
|
||||||
|
|
||||||
|
const (
|
||||||
|
TRACE LogLevel = iota
|
||||||
|
DEBUG
|
||||||
|
INFO
|
||||||
|
WARN
|
||||||
|
ERROR
|
||||||
|
FATAL
|
||||||
|
)
|
||||||
|
|
||||||
|
func (lvl LogLevel) String() string {
|
||||||
|
return [...]string{"TRACE", "DEBUG",
|
||||||
|
"INFO", "WARN", "ERROR", "FATAL"}[lvl]
|
||||||
|
}
|
||||||
|
|
||||||
|
func (lvl LogLevel) Integer() int {
|
||||||
|
return [...]int{0, 1, 2, 3, 4, 5}[lvl]
|
||||||
|
}
|
||||||
|
|
||||||
|
func PrintLog(lvl LogLevel, str string, a ...interface{}) {
|
||||||
|
if CurrentLogLevel.Integer() > lvl.Integer() {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
str = fmt.Sprintf(
|
||||||
|
"%s %s",
|
||||||
|
lvl.String(),
|
||||||
|
str)
|
||||||
|
if lvl == FATAL {
|
||||||
|
log.Fatalf(str, a...)
|
||||||
|
} else {
|
||||||
|
log.Printf(str, a...)
|
||||||
|
}
|
||||||
|
}
|
||||||
37
src/state.go
37
src/state.go
@ -1,37 +0,0 @@
|
|||||||
package overlord
|
|
||||||
|
|
||||||
import (
|
|
||||||
"log"
|
|
||||||
"os"
|
|
||||||
)
|
|
||||||
|
|
||||||
type State struct {
|
|
||||||
Libvirt Libvirt
|
|
||||||
Config Config
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewState() State {
|
|
||||||
return State{
|
|
||||||
Libvirt{},
|
|
||||||
Config{},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (state *State) Setup() {
|
|
||||||
state.Config.ReadConfig()
|
|
||||||
if state.Config.LogFilePath != "" {
|
|
||||||
file, err := os.OpenFile(state.Config.LogFilePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
|
|
||||||
if err != nil {
|
|
||||||
log.Printf("Could not open log file! %s", state.Config.LogFilePath)
|
|
||||||
} else {
|
|
||||||
log.SetOutput(file)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
state.Libvirt.ConnectMany(state.Config.LibvirtHosts)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (state *State) Stop() {
|
|
||||||
for _, conn := range state.Libvirt.Hosts {
|
|
||||||
conn.Close()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,16 +1,18 @@
|
|||||||
package overlord
|
package state
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"flag"
|
"flag"
|
||||||
"log"
|
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
)
|
)
|
||||||
|
|
||||||
type Config struct {
|
type Config struct {
|
||||||
LibvirtHosts []string
|
LibvirtHosts []string
|
||||||
PrivateKey string
|
MongoDbStr string
|
||||||
ConfFilePath string
|
ConfFilePath string
|
||||||
|
LogLevel log.LogLevel
|
||||||
LogFilePath string
|
LogFilePath string
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -20,9 +22,11 @@ func (conf *Config) ReadConfig() {
|
|||||||
flag.Parse()
|
flag.Parse()
|
||||||
file, err := os.Open(conf.ConfFilePath)
|
file, err := os.Open(conf.ConfFilePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("Error opening config file! %s", err)
|
log.PrintLog(log.ERROR, "Error opening config file! %s", err)
|
||||||
} else {
|
} else {
|
||||||
defer file.Close()
|
defer file.Close()
|
||||||
json.NewDecoder(file).Decode(&conf)
|
json.NewDecoder(file).Decode(&conf)
|
||||||
}
|
}
|
||||||
|
log.CurrentLogLevel = conf.LogLevel
|
||||||
|
log.PrintLog(log.DEBUG, "Log level: %s", log.CurrentLogLevel.String())
|
||||||
}
|
}
|
||||||
69
src/state/setup.go
Normal file
69
src/state/setup.go
Normal file
@ -0,0 +1,69 @@
|
|||||||
|
package state
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"fmt"
|
||||||
|
logger "log"
|
||||||
|
"os"
|
||||||
|
"os/signal"
|
||||||
|
"syscall"
|
||||||
|
|
||||||
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
|
"go.mongodb.org/mongo-driver/mongo"
|
||||||
|
"go.mongodb.org/mongo-driver/mongo/options"
|
||||||
|
)
|
||||||
|
|
||||||
|
func (state *State) Setup() {
|
||||||
|
log.PrintLog(log.TRACE, "Staring setup.")
|
||||||
|
state.setupCloseSignalHandlers()
|
||||||
|
state.Config.ReadConfig()
|
||||||
|
state.setLogOutput()
|
||||||
|
log.PrintLog(log.TRACE, "Config and logfile ready.")
|
||||||
|
state.setupDB()
|
||||||
|
log.PrintLog(log.TRACE, "Connected to database.")
|
||||||
|
state.Libvirt.ConnectMany(state.Config.LibvirtHosts)
|
||||||
|
log.PrintLog(log.TRACE, "Done with inital connections.")
|
||||||
|
state.Libvirt.GetStatus()
|
||||||
|
log.PrintLog(log.TRACE, "Fetched cluster status and prepared internal state.")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (state *State) setupDB() {
|
||||||
|
clientOptions := options.Client().ApplyURI(state.Config.MongoDbStr)
|
||||||
|
client, _ := mongo.Connect(context.TODO(), clientOptions)
|
||||||
|
err := client.Ping(context.TODO(), nil)
|
||||||
|
// No idea why, but error only gets returned with ping, not connect
|
||||||
|
// if the server refuses the connection.
|
||||||
|
if err != nil {
|
||||||
|
log.PrintLog(log.FATAL, "Error connecting to database wtih connection string \"%s\"! %s",
|
||||||
|
state.Config.MongoDbStr, err)
|
||||||
|
}
|
||||||
|
state.Mongo = client
|
||||||
|
}
|
||||||
|
|
||||||
|
func (state *State) setupCloseSignalHandlers() {
|
||||||
|
s := make(chan os.Signal)
|
||||||
|
signal.Notify(s, os.Interrupt, syscall.SIGTERM)
|
||||||
|
signal.Notify(s, os.Interrupt, syscall.SIGINT)
|
||||||
|
go func() {
|
||||||
|
<-s
|
||||||
|
fmt.Println()
|
||||||
|
log.PrintLog(log.DEBUG, "Got interrupt!")
|
||||||
|
state.Stop()
|
||||||
|
os.Exit(0)
|
||||||
|
}()
|
||||||
|
log.PrintLog(log.TRACE, "Signal handlers ready.")
|
||||||
|
}
|
||||||
|
|
||||||
|
func (state *State) setLogOutput() {
|
||||||
|
if state.Config.LogFilePath != "" {
|
||||||
|
file, err := os.OpenFile(state.Config.LogFilePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
|
||||||
|
if err != nil {
|
||||||
|
log.PrintLog(log.ERROR, "Could not open log file with path \"%s\"! %s",
|
||||||
|
state.Config.LogFilePath, err)
|
||||||
|
} else {
|
||||||
|
logger.SetOutput(file)
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
logger.SetOutput(os.Stdout)
|
||||||
|
}
|
||||||
|
}
|
||||||
35
src/state/state.go
Normal file
35
src/state/state.go
Normal file
@ -0,0 +1,35 @@
|
|||||||
|
package state
|
||||||
|
|
||||||
|
import (
|
||||||
|
virt "bitsnthings.dev/overlord/src/libvirt"
|
||||||
|
log "bitsnthings.dev/overlord/src/log"
|
||||||
|
"go.mongodb.org/mongo-driver/mongo"
|
||||||
|
)
|
||||||
|
|
||||||
|
const Version = "0.0.69"
|
||||||
|
|
||||||
|
type State struct {
|
||||||
|
Libvirt virt.Libvirt
|
||||||
|
Config Config
|
||||||
|
Mongo *mongo.Client
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewState() State {
|
||||||
|
return State{
|
||||||
|
virt.New(),
|
||||||
|
Config{},
|
||||||
|
&mongo.Client{},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (state *State) MainLoop() {
|
||||||
|
state.Libvirt.GetStatus()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (state *State) Stop() {
|
||||||
|
log.PrintLog(log.INFO, "Stopping Overlord.")
|
||||||
|
for _, conn := range state.Libvirt.Hosts {
|
||||||
|
conn.Close()
|
||||||
|
}
|
||||||
|
log.PrintLog(log.TRACE, "All libvirt connections closed.")
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user