application

Documentation

Index

• type Application
  • func New(options ...Option) *Application
  • func (a *Application) BuildItemMonitorPipelineCmsNs(appID int64, workspace string) string
  • func (a *Application) GetPublishItemRelationsMap(req apistructs.QueryAppPublishItemRelationRequest) (map[string]apistructs.AppPublishItemRelation, error)
  • func (a *Application) Init(initReq *apistructs.ApplicationInitRequest) (uint64, error)
  • func (a *Application) PipelineCmsConfigRequest(request *apistructs.UpdateAppPublishItemRelationRequest) error
  • func (a *Application) QueryPublishItemRelations(req apistructs.QueryAppPublishItemRelationRequest) ([]apistructs.AppPublishItemRelation, error)
  • func (a *Application) RemovePublishItemRelations(request *apistructs.RemoveAppPublishItemRelationsRequest) error
  • func (a *Application) UpdatePublishItemRelations(request *apistructs.UpdateAppPublishItemRelationRequest) error
• type Option
  • func WithBundle(bdl *bundle.Bundle) Option
  • func WithDBClient(db *dao.DBClient) Option
  • func WithOrg(org org.Interface) Option
  • func WithPipelineCms(cms cmspb.CmsServiceServer) Option
  • func WithPipelineSvc(svc pipelinepb.PipelineServiceServer) Option
  • func WithTokenSvc(tokenService tokenpb.TokenServiceServer) Option

Types

type Application

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

func New

func New(options ...Option) *Application

func (*Application) BuildItemMonitorPipelineCmsNs

func (a *Application) BuildItemMonitorPipelineCmsNs(appID int64, workspace string) string

BuildItemMonitorPipelineCmsNs 生成namespace

func (*Application) GetPublishItemRelationsMap

func (a *Application) GetPublishItemRelationsMap(req apistructs.QueryAppPublishItemRelationRequest) (map[string]apistructs.AppPublishItemRelation, error)

func (*Application) Init

func (a *Application) Init(initReq *apistructs.ApplicationInitRequest) (uint64, error)

func (*Application) PipelineCmsConfigRequest

func (a *Application) PipelineCmsConfigRequest(request *apistructs.UpdateAppPublishItemRelationRequest) error

PipelineCmsConfigRequest 请求pipeline cms，将publisherKey和publishItemKey设置进配置管理

func (*Application) QueryPublishItemRelations

func (a *Application) QueryPublishItemRelations(req apistructs.QueryAppPublishItemRelationRequest) ([]apistructs.AppPublishItemRelation, error)

QueryPublishItemRelations 查询应用发布内容关联关系

func (*Application) RemovePublishItemRelations

func (a *Application) RemovePublishItemRelations(request *apistructs.RemoveAppPublishItemRelationsRequest) error

func (*Application) UpdatePublishItemRelations

func (a *Application) UpdatePublishItemRelations(request *apistructs.UpdateAppPublishItemRelationRequest) error

UpdatePublishItemRelations 增量更新或创建publishItemRelations

type Option

type Option func(*Application)

func WithBundle

func WithBundle(bdl *bundle.Bundle) Option

func WithDBClient

func WithDBClient(db *dao.DBClient) Option

func WithOrg

func WithOrg(org org.Interface) Option

func WithPipelineCms

func WithPipelineCms(cms cmspb.CmsServiceServer) Option

func WithPipelineSvc

func WithPipelineSvc(svc pipelinepb.PipelineServiceServer) Option

func WithTokenSvc

func WithTokenSvc(tokenService tokenpb.TokenServiceServer) Option