A virtual jailed shell environment for Go apps backed by an io/fs#FS.
chore(s3fs): transform into importable package
Signed-off-by: Xe Iaso <me@xeiaso.net>
+19
-21
+1
-1
internal/s3fs/basic.go
+1
-1
internal/s3fs/basic.go
+1
-1
internal/s3fs/chroot.go
+1
-1
internal/s3fs/chroot.go
+1
-1
internal/s3fs/dir.go
+1
-1
internal/s3fs/dir.go
+11
-13
internal/s3fs/main.go
cmd/s3fs-test/main.go
+11
-13
internal/s3fs/main.go
cmd/s3fs-test/main.go
···
7
7
8
8
"github.com/aws/aws-sdk-go-v2/config"
9
9
"github.com/aws/aws-sdk-go-v2/service/s3"
10
-
"github.com/joho/godotenv"
11
-
)
10
+
"github.com/spf13/pflag"
11
+
"tangled.org/xeiaso.net/kefka/internal/s3fs"
12
12
13
-
var BucketName string
13
+
_ "github.com/joho/godotenv/autoload"
14
+
)
14
15
15
-
func init() {
16
-
err := godotenv.Load()
17
-
if err != nil {
18
-
panic(err)
19
-
}
20
-
BucketName = os.Getenv("BUCKET_NAME")
21
-
}
16
+
var (
17
+
bucket = pflag.String("bucket", os.Getenv("BUCKET_NAME"), "bucket to operate on")
18
+
)
22
19
23
20
func main() {
24
-
// fmt.Println(BucketName)
21
+
pflag.Parse()
22
+
23
+
fmt.Println(*bucket)
25
24
26
25
cfg, err := config.LoadDefaultConfig(context.Background())
27
26
if err != nil {
···
29
28
}
30
29
client := s3.NewFromConfig(cfg)
31
30
32
-
s3fs, err := NewS3FS(client, BucketName)
31
+
s3fs, err := s3fs.NewS3FS(client, *bucket)
33
32
if err != nil {
34
33
panic(err)
35
34
}
···
44
43
for _, file := range files {
45
44
fmt.Println(file.Name())
46
45
}
47
-
48
46
}
+1
-1
internal/s3fs/symlink.go
+1
-1
internal/s3fs/symlink.go