service

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Sep 9, 2021 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PERPAGE = 100
	PAGE    = 1
)
View Source 
const (
	CleanStatusUnStart  = "unStart"
	CleanStatusSuccess  = "success"
	CleanStatusCleaning = "cleaning"
	CleanStatusFailed   = "failed"
)

Variables

This section is empty.

Functions

func CleanCache added in v1.2.0 

func CleanCache() error

func CleanImageCache 

func CleanImageCache(logger *zap.SugaredLogger) error

CleanImageCache 清理镜像缓存

func CreateAnnouncement added in v1.4.0 

func CreateAnnouncement(creater string, ctx *systemmodel.Announcement, log *zap.SugaredLogger) error

func CreateBasicImage 

func CreateBasicImage(args *commonmodels.BasicImage, log *zap.SugaredLogger) error

func CreateHelmRepo added in v1.2.0 

func CreateHelmRepo(args *commonmodels.HelmRepo, log *zap.SugaredLogger) error

func CreateInstall 

func CreateInstall(args *commonmodels.Install, log *zap.SugaredLogger) error

func CreateJenkinsIntegration 

func CreateJenkinsIntegration(args *commonmodels.JenkinsIntegration, log *zap.SugaredLogger) error

func CreatePrivateKey added in v1.2.0 

func CreatePrivateKey(args *commonmodels.PrivateKey, log *zap.SugaredLogger) error

func CreateProxy 

func CreateProxy(args *commonmodels.Proxy, log *zap.SugaredLogger) error

func CreateRegistryNamespace 

func CreateRegistryNamespace(username string, args *commonmodels.RegistryNamespace, log *zap.SugaredLogger) error

func CreateS3Storage 

func CreateS3Storage(updateBy string, storage *commonmodels.S3Storage, logger *zap.SugaredLogger) error

func DeleteAnnouncement added in v1.4.0 

func DeleteAnnouncement(user, id string, log *zap.SugaredLogger) error

func DeleteBasicImage 

func DeleteBasicImage(id string, log *zap.SugaredLogger) error

func DeleteHelmRepo added in v1.2.0 

func DeleteHelmRepo(id string, log *zap.SugaredLogger) error

func DeleteInstall 

func DeleteInstall(name, version string, log *zap.SugaredLogger) error

func DeleteJenkinsIntegration 

func DeleteJenkinsIntegration(ID string, log *zap.SugaredLogger) error

func DeleteNotifies added in v1.2.0 

func DeleteNotifies(user string, notifyIDs []string, log *zap.SugaredLogger) error

func DeletePrivateKey added in v1.2.0 

func DeletePrivateKey(id string, log *zap.SugaredLogger) error

func DeleteProxy 

func DeleteProxy(id string, log *zap.SugaredLogger) error

func DeleteRegistryNamespace 

func DeleteRegistryNamespace(id string, log *zap.SugaredLogger) error

func DeleteS3Storage 

func DeleteS3Storage(deleteBy string, id string, logger *zap.SugaredLogger) error

func FindOperation added in v1.4.0 

func FindOperation(args *OperationLogArgs, log *zap.SugaredLogger) ([]*models.OperationLog, int, error)

func GetBasicImage 

func GetBasicImage(id string, log *zap.SugaredLogger) (*commonmodels.BasicImage, error)

func GetCapacityStrategy added in v1.2.0 

func GetCapacityStrategy(target commonmodels.CapacityTarget) (*commonmodels.CapacityStrategy, error)

func GetInstall 

func GetInstall(name, version string, log *zap.SugaredLogger) (*commonmodels.Install, error)

func GetOrCreateCleanCacheState 

func GetOrCreateCleanCacheState() (*commonmodels.DindClean, error)

GetOrCreateCleanCacheState 获取清理镜像缓存状态，如果数据库中没有数据返回一个临时对象

func GetPrivateKey added in v1.2.0 

func GetPrivateKey(id string, log *zap.SugaredLogger) (*commonmodels.PrivateKey, error)

func GetProxy 

func GetProxy(id string, log *zap.SugaredLogger) (*commonmodels.Proxy, error)

func GetRegistryNamespace 

func GetRegistryNamespace(regOps *commonrepo.FindRegOps, log *zap.SugaredLogger) (*commonmodels.RegistryNamespace, error)

func GetRegistryNamespaces 

func GetRegistryNamespaces(regOps *commonrepo.FindRegOps, log *zap.SugaredLogger) ([]*commonmodels.RegistryNamespace, error)

func GetRepoTags 

func GetRepoTags(registryInfo *commonmodels.RegistryNamespace, name string, log *zap.SugaredLogger) (*registry.ImagesResp, error)

func GetS3Storage 

func GetS3Storage(id string, logger *zap.SugaredLogger) (*commonmodels.S3Storage, error)

func GithubAppAdd 

func GithubAppAdd(args *commonmodels.GithubApp) error

func GithubAppDelete 

func GithubAppDelete(id string) error

func GithubAppList 

func GithubAppList() ([]*commonmodels.GithubApp, error)

func HandleSystemGC added in v1.2.0 

func HandleSystemGC(dryRun bool) error

func InitInstallMap 

func InitInstallMap() map[string]*commonmodels.Install

func InitbasicImageInfos 

func InitbasicImageInfos() []*commonmodels.BasicImage

func ListAvaiableInstalls 

func ListAvaiableInstalls(log *zap.SugaredLogger) ([]*commonmodels.Install, error)

func ListBasicImages 

func ListBasicImages(imageFrom string, log *zap.SugaredLogger) ([]*commonmodels.BasicImage, error)

func ListHelmRepos added in v1.2.0 

func ListHelmRepos(log *zap.SugaredLogger) ([]*commonmodels.HelmRepo, error)

func ListInstalls 

func ListInstalls(log *zap.SugaredLogger) ([]*commonmodels.Install, error)

func ListJenkinsIntegration 

func ListJenkinsIntegration(log *zap.SugaredLogger) ([]*commonmodels.JenkinsIntegration, error)

func ListJobNames 

func ListJobNames(log *zap.SugaredLogger) ([]string, error)

func ListPrivateKeys added in v1.2.0 

func ListPrivateKeys(log *zap.SugaredLogger) ([]*commonmodels.PrivateKey, error)

func ListProxies 

func ListProxies(log *zap.SugaredLogger) ([]*commonmodels.Proxy, error)

func ListRegistries 

func ListRegistries(log *zap.SugaredLogger) ([]*commonmodels.RegistryNamespace, error)

ListRegistries 为了抹掉ak和sk的数据

func ListS3Storage 

func ListS3Storage(logger *zap.SugaredLogger) ([]*commonmodels.S3Storage, error)

func ListSubscriptions added in v1.2.0 

func ListSubscriptions(user string, log *zap.SugaredLogger) ([]*commonmodels.Subscription, error)

func PullAllAnnouncement added in v1.4.0 

func PullAllAnnouncement(user string, log *zap.SugaredLogger) ([]*systemmodel.Announcement, error)

func PullNotify added in v1.2.0 

func PullNotify(user string, log *zap.SugaredLogger) ([]*commonmodels.Notify, error)

func PullNotifyAnnouncement added in v1.4.0 

func PullNotifyAnnouncement(user string, log *zap.SugaredLogger) ([]*systemmodel.Announcement, error)

func ReadNotify added in v1.2.0 

func ReadNotify(user string, notifyIDs []string, log *zap.SugaredLogger) error

func SetProxyConfig 

func SetProxyConfig()

func TestConnection 

func TestConnection(args *commonmodels.Proxy, log *zap.SugaredLogger) error

func TestJenkinsConnection 

func TestJenkinsConnection(args *JenkinsArgs, log *zap.SugaredLogger) error

func Unsubscribe added in v1.2.0 

func Unsubscribe(user string, notifyType int, log *zap.SugaredLogger) error

func UpdateAnnouncement added in v1.4.0 

func UpdateAnnouncement(user string, notifyID string, ctx *systemmodel.Announcement, log *zap.SugaredLogger) error

func UpdateBasicImage 

func UpdateBasicImage(id string, args *commonmodels.BasicImage, log *zap.SugaredLogger) error

func UpdateHelmRepo added in v1.2.0 

func UpdateHelmRepo(id string, args *commonmodels.HelmRepo, log *zap.SugaredLogger) error

func UpdateInstall 

func UpdateInstall(name, version string, args *commonmodels.Install, log *zap.SugaredLogger) error

func UpdateJenkinsIntegration 

func UpdateJenkinsIntegration(ID string, args *commonmodels.JenkinsIntegration, log *zap.SugaredLogger) error

func UpdateOperation added in v1.4.0 

func UpdateOperation(id string, status int, log *zap.SugaredLogger) error

func UpdatePrivateKey added in v1.2.0 

func UpdatePrivateKey(id string, args *commonmodels.PrivateKey, log *zap.SugaredLogger) error

func UpdateProxy 

func UpdateProxy(id string, args *commonmodels.Proxy, log *zap.SugaredLogger) error

func UpdateRegistryNamespace 

func UpdateRegistryNamespace(username, id string, args *commonmodels.RegistryNamespace, log *zap.SugaredLogger) error

func UpdateRegistryNamespaceDefault 

func UpdateRegistryNamespaceDefault(args *commonmodels.RegistryNamespace, log *zap.SugaredLogger) error

func UpdateS3Storage 

func UpdateS3Storage(updateBy, id string, storage *commonmodels.S3Storage, logger *zap.SugaredLogger) error

func UpdateSubscribe added in v1.2.0 

func UpdateSubscribe(user string, notifyType int, subscription *commonmodels.Subscription, log *zap.SugaredLogger) error

func UpdateSysCapStrategy added in v1.2.0 

func UpdateSysCapStrategy(strategy *commonmodels.CapacityStrategy) error

func UpsertSubscription added in v1.2.0 

func UpsertSubscription(user string, subscription *commonmodels.Subscription, log *zap.SugaredLogger) error

Types

type AddAuditLogResp added in v1.4.0 

type AddAuditLogResp struct {
	OperationLogID string `json:"id"`
}

func InsertOperation added in v1.4.0 

func InsertOperation(args *models.OperationLog, log *zap.SugaredLogger) (*AddAuditLogResp, error)

type JenkinsArgs 

type JenkinsArgs struct {
	URL      string `json:"url"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type JenkinsBuildArgs 

type JenkinsBuildArgs struct {
	Name  string      `json:"name"`
	Value interface{} `json:"value"`
}

func ListJobBuildArgs 

func ListJobBuildArgs(jobName string, log *zap.SugaredLogger) ([]*JenkinsBuildArgs, error)

type MessageCtx added in v1.2.0 

type MessageCtx struct {
	ReqID   string `bson:"req_id"                json:"req_id"`
	Title   string `bson:"title"                 json:"title"`   // 消息标题
	Content string `bson:"content"               json:"content"` // 消息内容
}

type OperationLogArgs added in v1.4.0 

type OperationLogArgs struct {
	Username    string `json:"username"`
	ProductName string `json:"product_name"`
	Function    string `json:"function"`
	Status      int    `json:"status"`
	PerPage     int    `json:"per_page"`
	Page        int    `json:"page"`
}

type RepoImgResp 

type RepoImgResp struct {
	Host  string `json:"host"`
	Owner string `json:"owner"`
	Name  string `json:"name"`
	Tag   string `json:"tag"`
}

func ListReposTags 

func ListReposTags(registryInfo *commonmodels.RegistryNamespace, names []string, logger *zap.SugaredLogger) ([]*RepoImgResp, error)

type RepoInfo 

type RepoInfo struct {
	RegType      string `json:"regType"`
	RegProvider  string `json:"regProvider"`
	RegNamespace string `json:"regNamespace"`
	RegAddr      string `json:"regAddr"`
	ID           string `json:"id"`
}

func ListAllRepos 

func ListAllRepos(log *zap.SugaredLogger) ([]*RepoInfo, error)

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.