-
Notifications
You must be signed in to change notification settings - Fork 2
/
helper.go
63 lines (48 loc) · 1.68 KB
/
helper.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
/*
Copyright 2021 IBM Corp.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package helper
import (
"os"
"time"
"github.com/dgrijalva/jwt-go"
"k8s.io/client-go/dynamic"
"k8s.io/client-go/kubernetes"
)
type driverHelper struct{}
type DriverHelper interface {
GetValidator() Validator
GetClientSet() (kubernetes.Interface, dynamic.Interface, error)
GetMountCommand() string
ParseJWTclaims(token string) (jwt.MapClaims, error)
GetClaimValue(claims jwt.MapClaims, key string) (string, error)
MarshaljSON(v interface{}) ([]byte, error)
UnMarshaljSON(data []byte, v interface{}) error
GetDatasetDirectoryNames(targetPath string) []string
CheckMount(targetPath string) (bool, error)
CleanMountPoint(targetPath string) error
WaitForMount(path string, timeout time.Duration) error
MkdirAll(path string, perm os.FileMode) error
WriteFile(name, content string, flag int, perm os.FileMode) error
FileStat(path string) (os.FileInfo, error)
ReadDir(path string) ([]os.FileInfo, error)
RemoveFile(path string) error
}
func NewDriverHelper() DriverHelper {
return &driverHelper{}
}
func (dv *driverHelper) GetValidator() Validator {
return &validator{}
}
func (dv *driverHelper) GetMountCommand() string {
return "s3fs"
}