org_resource

Documentation

Index

• type Option
  • func WithBundle(bdl *bundle.Bundle) Option
  • func WithDBClient(db *dbclient.DBClient) Option
  • func WithRedisClient(cli *redis.Client) Option
• type OrgResource
  • func New(options ...Option) *OrgResource
  • func (o *OrgResource) DealReceiveTaskEvent(req *apistructs.PipelineTaskEvent) (int64, error)
  • func (o *OrgResource) DealReceiveTaskRuntimeEvent(req *apistructs.PipelineTaskEvent) (int64, error)
  • func (o *OrgResource) ListOrgRunningTasks(param *apistructs.OrgRunningTasksListRequest, orgID int64) (int64, []apistructs.OrgRunningTasks, error)

Types

type Option

type Option func(*OrgResource)

func WithBundle

func WithBundle(bdl *bundle.Bundle) Option

WithBundle 配置 bundle

func WithDBClient

func WithDBClient(db *dbclient.DBClient) Option

WithDBClient 配置 db client

func WithRedisClient

func WithRedisClient(cli *redis.Client) Option

WithRedisClient 配置 redis client

type OrgResource

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

func New

func New(options ...Option) *OrgResource

func (*OrgResource) DealReceiveTaskEvent

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

DealReceiveTaskEvent 处理接收到 pipeline 的 task 事件

func (*OrgResource) DealReceiveTaskRuntimeEvent

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

DealReceiveTaskRuntimeEvent 处理接收到 pipeline 的 runtimeID 事件

func (*OrgResource) ListOrgRunningTasks

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

ListOrgRunningTasks impl: list running task or service by orgID