Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrPvcK8sList = errors.New("存储卷声明列表获取失败") ErrPvcGet = errors.New("存储卷声明获取错误") ErrPvcPost = errors.New("存储卷声明创建失败") ErrPvcDelete = errors.New("存储卷声明删除错误,或许已经删除了") ErrPvcTemplateGet = errors.New("存储卷声明模版获取错误") ErrPvcTemplateEncode = errors.New("存储卷声明模版解析错误") ErrPvGet = errors.New("存储卷获取错误") ErrStorageClassNotExists = errors.New("存储类不存在") ErrPvcListCount = errors.New("存储卷声明统计出错") ErrPvcList = errors.New("存储卷声明获取出错") )
Functions ¶
Types ¶
type ResourceUnit ¶
type ResourceUnit string
const ( ResourceMi ResourceUnit = "Mi" ResourceGi ResourceUnit = "Gi" )
func (ResourceUnit) String ¶
func (c ResourceUnit) String() string
type Service ¶
type Service interface { // 同步pvc Sync(ctx context.Context, ns string) (err error) // 获取pvc详情 Get(ctx context.Context, ns, name string) (rs interface{}, err error) // 删除存储卷声明 Delete(ctx context.Context, ns, name string) (err error) // 创建持久化存储卷 Post(ctx context.Context, ns, name, storage, storageClassName string, accessModes []string) (err error) // 持久化存储卷列表 List(ctx context.Context, ns string, page, limit int) (resp map[string]interface{}, err error) // 当前空间下所有的pvc All(ctx context.Context) (resp map[string]interface{}, err error) }
func NewService ¶
func NewService(logger log.Logger, client kubernetes.K8sClient, repository repository.Repository) Service
Click to show internal directories.
Click to hide internal directories.