nexussvc

Documentation

Index

• type NexusSvc
  • func New(options ...Option) *NexusSvc
  • func (svc *NexusSvc) ConvertRepo(dbRepo *dao.NexusRepository) *apistructs.NexusRepository
  • func (svc *NexusSvc) ConvertRepos(dbRepos []*dao.NexusRepository) []*apistructs.NexusRepository
  • func (svc *NexusSvc) EnsureRepository(req apistructs.NexusRepositoryEnsureRequest) (*apistructs.NexusRepository, error)
  • func (svc *NexusSvc) EnsureUser(req apistructs.NexusUserEnsureRequest) (*apistructs.NexusUser, error)
  • func (svc *NexusSvc) GetRepositoryByName(name string) (*apistructs.NexusRepository, error)
  • func (svc *NexusSvc) GetUserByName(name string, decodePassword bool) (*apistructs.NexusUser, error)
  • func (svc *NexusSvc) ListRepositories(req apistructs.NexusRepositoryListRequest) ([]*apistructs.NexusRepository, error)
  • func (svc *NexusSvc) ListUsers(req apistructs.NexusUserListRequest) ([]apistructs.NexusUser, error)
  • func (svc *NexusSvc) SyncRepoConfigToPipelineCM(syncConfig apistructs.NexusSyncConfigToPipelineCM, ...) error
  • func (svc *NexusSvc) SyncUserConfigToPipelineCM(syncConfig apistructs.NexusSyncConfigToPipelineCM, user *apistructs.NexusUser, ...) error
• type Option
  • func WithBundle(bdl *bundle.Bundle) Option
  • func WithDBClient(db *dao.DBClient) Option
  • func WithPipelineCms(cms pb.CmsServiceServer) Option
  • func WithRsaCrypt(rsaCrypt *encryption.RsaCrypt) Option

Types

type NexusSvc

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

NexusSvc nexus 操作封装

func New

func New(options ...Option) *NexusSvc

func (*NexusSvc) ConvertRepo

func (svc *NexusSvc) ConvertRepo(dbRepo *dao.NexusRepository) *apistructs.NexusRepository

func (*NexusSvc) ConvertRepos

func (svc *NexusSvc) ConvertRepos(dbRepos []*dao.NexusRepository) []*apistructs.NexusRepository

func (*NexusSvc) EnsureRepository

func (svc *NexusSvc) EnsureRepository(req apistructs.NexusRepositoryEnsureRequest) (*apistructs.NexusRepository, error)

EnsureRepository 幂等保证 repository 存在

func (*NexusSvc) EnsureUser

func (svc *NexusSvc) EnsureUser(req apistructs.NexusUserEnsureRequest) (*apistructs.NexusUser, error)

func (*NexusSvc) GetRepositoryByName

func (svc *NexusSvc) GetRepositoryByName(name string) (*apistructs.NexusRepository, error)

func (*NexusSvc) GetUserByName

func (svc *NexusSvc) GetUserByName(name string, decodePassword bool) (*apistructs.NexusUser, error)

func (*NexusSvc) ListRepositories

func (svc *NexusSvc) ListRepositories(req apistructs.NexusRepositoryListRequest) ([]*apistructs.NexusRepository, error)

ListRepositories 查询 repositories 列表

func (*NexusSvc) ListUsers

func (svc *NexusSvc) ListUsers(req apistructs.NexusUserListRequest) ([]apistructs.NexusUser, error)

ListUsers 查询 user 列表

func (*NexusSvc) SyncRepoConfigToPipelineCM

func (svc *NexusSvc) SyncRepoConfigToPipelineCM(syncConfig apistructs.NexusSyncConfigToPipelineCM, repo *apistructs.NexusRepository) error

func (*NexusSvc) SyncUserConfigToPipelineCM

func (svc *NexusSvc) SyncUserConfigToPipelineCM(syncConfig apistructs.NexusSyncConfigToPipelineCM, user *apistructs.NexusUser, repoFormat nexus.RepositoryFormat) error

type Option

type Option func(*NexusSvc)

func WithBundle

func WithBundle(bdl *bundle.Bundle) Option

func WithDBClient

func WithDBClient(db *dao.DBClient) Option

func WithPipelineCms

func WithPipelineCms(cms pb.CmsServiceServer) Option

func WithRsaCrypt

func WithRsaCrypt(rsaCrypt *encryption.RsaCrypt) Option