ecf1031dfc
Previously, multiple containers with the same mounted volume resulted in multiple FUSE processes. This behaviour was breaking parallel modifications from different containers, consumed extra resources, and after mounting via systemd was introduced, led to the total inability to mount the same volume into multiple containers on the same host. Now only one FUSE process is started per volume, per host.
62 lines
1.3 KiB
Go
62 lines
1.3 KiB
Go
package mounter
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/yandex-cloud/k8s-csi-s3/pkg/s3"
|
|
)
|
|
|
|
// Implements Mounter
|
|
type s3fsMounter struct {
|
|
meta *s3.FSMeta
|
|
url string
|
|
region string
|
|
pwFileContent string
|
|
}
|
|
|
|
const (
|
|
s3fsCmd = "s3fs"
|
|
)
|
|
|
|
func newS3fsMounter(meta *s3.FSMeta, cfg *s3.Config) (Mounter, error) {
|
|
return &s3fsMounter{
|
|
meta: meta,
|
|
url: cfg.Endpoint,
|
|
region: cfg.Region,
|
|
pwFileContent: cfg.AccessKeyID + ":" + cfg.SecretAccessKey,
|
|
}, nil
|
|
}
|
|
|
|
func (s3fs *s3fsMounter) Mount(target, volumeID string) error {
|
|
if err := writes3fsPass(s3fs.pwFileContent); err != nil {
|
|
return err
|
|
}
|
|
args := []string{
|
|
fmt.Sprintf("%s:/%s", s3fs.meta.BucketName, s3fs.meta.Prefix),
|
|
target,
|
|
"-o", "use_path_request_style",
|
|
"-o", fmt.Sprintf("url=%s", s3fs.url),
|
|
"-o", "allow_other",
|
|
"-o", "mp_umask=000",
|
|
}
|
|
if s3fs.region != "" {
|
|
args = append(args, "-o", fmt.Sprintf("endpoint=%s", s3fs.region))
|
|
}
|
|
args = append(args, s3fs.meta.MountOptions...)
|
|
return fuseMount(target, s3fsCmd, args)
|
|
}
|
|
|
|
func writes3fsPass(pwFileContent string) error {
|
|
pwFileName := fmt.Sprintf("%s/.passwd-s3fs", os.Getenv("HOME"))
|
|
pwFile, err := os.OpenFile(pwFileName, os.O_RDWR|os.O_CREATE, 0600)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = pwFile.WriteString(pwFileContent)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
pwFile.Close()
|
|
return nil
|
|
}
|