persistentvolumeclaim

Documentation

Index

• Variables
• func MakeHandler(svc Service, logger log.Logger) http.Handler
• type ResourceUnit
  • func (c ResourceUnit) String() string
• type Service
  • func NewLoggingService(logger log.Logger, s Service) Service
  • func NewService(logger log.Logger, client kubernetes.K8sClient, ...) Service

Variables

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

func MakeHandler

func MakeHandler(svc Service, logger log.Logger) http.Handler

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 NewLoggingService

func NewLoggingService(logger log.Logger, s Service) Service

func NewService

func NewService(logger log.Logger, client kubernetes.K8sClient,
	repository repository.Repository) Service