k8sdeployment

package
v0.0.0-...-663e6fc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 22, 2023 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateDeploymentLogic 

type CreateDeploymentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewCreateDeploymentLogic 

func NewCreateDeploymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateDeploymentLogic

func (*CreateDeploymentLogic) CreateDeployment 

func (l *CreateDeploymentLogic) CreateDeployment(in *core.CreateDeploymentReq) (*core.CreateDeploymentResp, error)

创建deployment,接收DeployCreate对象

type DataCell 

type DataCell interface {
	GetCreation() time.Time
	GetName() string
}

DataCell 接口,用于各种资源List的类型转换,转换后可以使用dataselector的排序,过滤,分页方法

type DataSelectQuery 

type DataSelectQuery struct {
	Filter   *FilterQuery
	Paginate *PaginateQuery
}

DataSelectQuery 定义过滤和分页的结构体,过滤:Name 分页:Limit和Page

type DeleteDeploymentLogic 

type DeleteDeploymentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeleteDeploymentLogic 

func NewDeleteDeploymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeleteDeploymentLogic

func (*DeleteDeploymentLogic) DeleteDeployment 

func (l *DeleteDeploymentLogic) DeleteDeployment(in *core.DeleteDeploymentReq) (*core.DeleteDeploymentResp, error)

删除deployment

type Deployment 

type Deployment struct{}

func (*Deployment) CreateDeployment 

func (d *Deployment) CreateDeployment(l *CreateDeploymentLogic, in *core.CreateDeploymentReq) (resp *core.CreateDeploymentResp, err error)

创建deployment,接收DeployCreate对象

func (*Deployment) DeleteDeployment 

func (d *Deployment) DeleteDeployment(l *DeleteDeploymentLogic, in *core.DeleteDeploymentReq) (resp *core.DeleteDeploymentResp, err error)

删除deployment

func (*Deployment) GetDeployNumPerNp 

func (d *Deployment) GetDeployNumPerNp(l *GetDeployNumPerNpLogic, in *core.GetDeployNumPerNpReq) (resp *core.GetDeployNumPerNpResp, err error)

获取每个namespace的deployment数量

func (*Deployment) GetDeploymentDetail 

func (d *Deployment) GetDeploymentDetail(l *GetDeploymentDetailLogic, in *core.GetDeploymentDetailReq) (resp *core.GetDeploymentDetailResp, err error)

获取deployment详情

func (*Deployment) GetDeployments 

func (d *Deployment) GetDeployments(l *GetDeploymentsLogic, in *core.GetDeploymentsReq) (resp *core.GetDeploymentsResp, err error)

GetDeployments 获取deployment列表，支持过滤、排序、分页

func (*Deployment) RestartDeployment 

func (d *Deployment) RestartDeployment(l *RestartDeploymentLogic, in *core.RestartDeploymentReq) (resp *core.RestartDeploymentResp, err error)

重启deployment

func (*Deployment) ScaleDeployment 

func (d *Deployment) ScaleDeployment(l *ScaleDeploymentLogic, in *core.ScaleDeploymentReq) (resp *core.ScaleDeploymentResp, err error)

设置deployment副本数

func (*Deployment) UpdateDeployment 

func (d *Deployment) UpdateDeployment(l *UpdateDeploymentLogic, in *core.UpdateDeploymentReq) (resp *core.UpdateDeploymentResp, err error)

更新deployment

type FilterQuery 

type FilterQuery struct {
	Name string
}

FilterQuery 用于查询 过滤:Name

type GetDeployNumPerNpLogic 

type GetDeployNumPerNpLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetDeployNumPerNpLogic 

func NewGetDeployNumPerNpLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetDeployNumPerNpLogic

func (*GetDeployNumPerNpLogic) GetDeployNumPerNp 

func (l *GetDeployNumPerNpLogic) GetDeployNumPerNp(in *core.GetDeployNumPerNpReq) (*core.GetDeployNumPerNpResp, error)

type GetDeploymentDetailLogic 

type GetDeploymentDetailLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetDeploymentDetailLogic 

func NewGetDeploymentDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetDeploymentDetailLogic

func (*GetDeploymentDetailLogic) GetDeploymentDetail 

func (l *GetDeploymentDetailLogic) GetDeploymentDetail(in *core.GetDeploymentDetailReq) (*core.GetDeploymentDetailResp, error)

GetDeploymentDetail 获取deployment详情

type GetDeploymentsLogic 

type GetDeploymentsLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetDeploymentsLogic 

func NewGetDeploymentsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetDeploymentsLogic

func (*GetDeploymentsLogic) GetDeployments 

func (l *GetDeploymentsLogic) GetDeployments(in *core.GetDeploymentsReq) (*core.GetDeploymentsResp, error)

K8sDeployment management

type PaginateQuery 

type PaginateQuery struct {
	Page  int
	Limit int
}

PaginateQuery 分页:Limit和Page Limit是单页的数据条数,Page是第几页

type RestartDeploymentLogic 

type RestartDeploymentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRestartDeploymentLogic 

func NewRestartDeploymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RestartDeploymentLogic

func (*RestartDeploymentLogic) RestartDeployment 

func (l *RestartDeploymentLogic) RestartDeployment(in *core.RestartDeploymentReq) (*core.RestartDeploymentResp, error)

type ScaleDeploymentLogic 

type ScaleDeploymentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewScaleDeploymentLogic 

func NewScaleDeploymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ScaleDeploymentLogic

func (*ScaleDeploymentLogic) ScaleDeployment 

func (l *ScaleDeploymentLogic) ScaleDeployment(in *core.ScaleDeploymentReq) (*core.ScaleDeploymentResp, error)

设置deployment副本数

type UpdateDeploymentLogic 

type UpdateDeploymentLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUpdateDeploymentLogic 

func NewUpdateDeploymentLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateDeploymentLogic

func (*UpdateDeploymentLogic) UpdateDeployment 

func (l *UpdateDeploymentLogic) UpdateDeployment(in *core.UpdateDeploymentReq) (*core.UpdateDeploymentResp, error)

更新deployment

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.