mirror of
https://github.com/siderolabs/talos.git
synced 2025-08-19 13:41:13 +02:00
d4f103ffcb
In order to perform upgrades the way we would like, it is important that we avoid any bind mounts into containers. This change ensures that all system services get their config via stdin. Signed-off-by: Andrew Rynhard <andrew@rynhard.io>
80 lines
1.9 KiB
Go
80 lines
1.9 KiB
Go
// This Source Code Form is subject to the terms of the Mozilla Public
|
|
// License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
package main
|
|
|
|
import (
|
|
"flag"
|
|
"log"
|
|
|
|
"github.com/talos-systems/talos/internal/app/timed/pkg/ntp"
|
|
"github.com/talos-systems/talos/internal/app/timed/pkg/reg"
|
|
"github.com/talos-systems/talos/pkg/grpc/factory"
|
|
"github.com/talos-systems/talos/pkg/machinery/config/configloader"
|
|
"github.com/talos-systems/talos/pkg/machinery/constants"
|
|
"github.com/talos-systems/talos/pkg/startup"
|
|
)
|
|
|
|
// https://access.redhat.com/solutions/39194
|
|
// Using the above as reference for setting min/max.
|
|
const (
|
|
// TODO: Once we get naming sorted we need to apply
|
|
// for a project specific address
|
|
// https://manage.ntppool.org/manage/vendor
|
|
DefaultServer = "pool.ntp.org"
|
|
)
|
|
|
|
func init() {
|
|
log.SetFlags(log.Lshortfile | log.Ldate | log.Lmicroseconds | log.Ltime)
|
|
|
|
flag.Parse()
|
|
}
|
|
|
|
// New instantiates a new ntp instance against a given server
|
|
// If no servers are specified, the default will be used.
|
|
func main() {
|
|
if err := startup.RandSeed(); err != nil {
|
|
log.Fatalf("startup: %v", err)
|
|
}
|
|
|
|
server := DefaultServer
|
|
|
|
config, err := configloader.NewFromStdin()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
// Check if ntp servers are defined
|
|
// Support for only a single time server currently
|
|
if len(config.Machine().Time().Servers()) >= 1 {
|
|
server = config.Machine().Time().Servers()[0]
|
|
}
|
|
|
|
n, err := ntp.NewNTPClient(
|
|
ntp.WithServer(server),
|
|
)
|
|
if err != nil {
|
|
log.Fatalf("failed to create ntp client: %v", err)
|
|
}
|
|
|
|
log.Println("starting timed")
|
|
|
|
errch := make(chan error)
|
|
|
|
go func() {
|
|
errch <- n.Daemon()
|
|
}()
|
|
|
|
go func() {
|
|
errch <- factory.ListenAndServe(
|
|
reg.NewRegistrator(n),
|
|
factory.Network("unix"),
|
|
factory.SocketPath(constants.TimeSocketPath),
|
|
factory.WithDefaultLog(),
|
|
)
|
|
}()
|
|
|
|
log.Fatal(<-errch)
|
|
}
|