-
Notifications
You must be signed in to change notification settings - Fork 0
/
user_data_service.go
58 lines (46 loc) · 1.47 KB
/
user_data_service.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
package service
import (
"github.com/ayanamimcy/gopass/user/domain/model"
"github.com/ayanamimcy/gopass/user/domain/repository"
"k8s.io/api/apps/v1"
"k8s.io/client-go/kubernetes"
)
//这里是接口类型
type IUserDataService interface {
AddUser(*model.User) (int64 , error)
DeleteUser(int64) error
UpdateUser(*model.User) error
FindUserByID(int64) (*model.User, error)
FindAllUser() ([]model.User, error)
}
//创建
//注意:返回值 IUserDataService 接口类型
func NewUserDataService(userRepository repository.IUserRepository,clientSet *kubernetes.Clientset) IUserDataService{
return &UserDataService{ UserRepository:userRepository, K8sClientSet: clientSet,deployment:&v1.Deployment{}}
}
type UserDataService struct {
//注意:这里是 IUserRepository 类型
UserRepository repository.IUserRepository
K8sClientSet *kubernetes.Clientset
deployment *v1.Deployment
}
//插入
func (u *UserDataService) AddUser(user *model.User) (int64 ,error) {
return u.UserRepository.CreateUser(user)
}
//删除
func (u *UserDataService) DeleteUser(userID int64) error {
return u.UserRepository.DeleteUserByID(userID)
}
//更新
func (u *UserDataService) UpdateUser(user *model.User) error {
return u.UserRepository.UpdateUser(user)
}
//查找
func (u *UserDataService) FindUserByID(userID int64) (*model.User, error) {
return u.UserRepository.FindUserByID(userID)
}
//查找
func (u *UserDataService) FindAllUser() ([]model.User, error) {
return u.UserRepository.FindAll()
}