mirror of
https://github.com/kairos-io/immucore.git
synced 2025-09-17 23:49:13 +00:00
c5e686883e
It was nice when things break all over but its much more stable now. Lets add logging with head and with proper enrichment of the data being sent Signed-off-by: Itxaka <itxaka@spectrocloud.com>
39 lines
1.2 KiB
Go
39 lines
1.2 KiB
Go
package mount
|
|
|
|
import (
|
|
"github.com/containerd/containerd/mount"
|
|
"github.com/deniswernert/go-fstab"
|
|
"github.com/moby/sys/mountinfo"
|
|
"github.com/rs/zerolog"
|
|
"github.com/rs/zerolog/log"
|
|
"os"
|
|
)
|
|
|
|
type mountOperation struct {
|
|
FstabEntry fstab.Mount
|
|
MountOption mount.Mount
|
|
Target string
|
|
PrepareCallback func() error
|
|
}
|
|
|
|
func (m mountOperation) run() error {
|
|
log.Logger = log.Output(zerolog.ConsoleWriter{Out: os.Stderr}).With().Logger()
|
|
if m.PrepareCallback != nil {
|
|
if err := m.PrepareCallback(); err != nil {
|
|
log.Logger.Err(err).Str("what", m.MountOption.Source).Str("where", m.Target).Str("type", m.MountOption.Type).Msg("executing mount callback")
|
|
return err
|
|
}
|
|
}
|
|
//TODO: not only check if mounted but also if the type,options and source are the same?
|
|
mounted, err := mountinfo.Mounted(m.Target)
|
|
if err != nil {
|
|
log.Logger.Err(err).Str("what", m.MountOption.Source).Str("where", m.Target).Str("type", m.MountOption.Type).Msg("checking mount status")
|
|
return err
|
|
}
|
|
if mounted {
|
|
log.Logger.Debug().Str("what", m.MountOption.Source).Str("where", m.Target).Str("type", m.MountOption.Type).Msg("Already mounted")
|
|
return nil
|
|
}
|
|
return mount.All([]mount.Mount{m.MountOption}, m.Target)
|
|
}
|