org

package

v1.1.0-rc Latest Latest Go to latest Published: Jul 8, 2021 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

Package org 封装企业资源相关操作

This section is empty.

This section is empty.

This section is empty.

type Option func(*Org)

Option 定义 Org 对象的配置选项

func WithBundle(bdl *bundle.Bundle) Option

WithBundle 配置 bundle

func WithDBClient(db *dao.DBClient) Option

WithDBClient 配置 db client

func WithRedisClient(cli *redis.Client) Option

WithRedisClient 配置 redis client

func WithUCClient(uc *ucauth.UCClient) Option

WithUCClient 配置 uc client

type Org struct {
	// contains filtered or unexported fields
}

Org 资源对象操作封装

func New(options ...Option) *Org

New 新建 Org 实例，通过 Org 实例操作企业资源

func (o *Org) DealReceiveTaskEvent(req *apistructs.PipelineTaskEvent) (int64, error)

DealReceiveTaskEvent 处理接收到 pipeline 的 task 事件

func (o *Org) DealReceiveTaskRuntimeEvent(req *apistructs.PipelineTaskEvent) (int64, error)

DealReceiveTaskRuntimeEvent 处理接收到 pipeline 的 runtimeID 事件

func (o *Org) ListOrgRunningTasks(param *apistructs.OrgRunningTasksListRequest,
	orgID int64) (int64, []apistructs.OrgRunningTasks, error)

ListOrgRunningTasks 获取指定集群正在运行的job或者deployment列表