handler

package
v0.0.0-...-a3a5c94 Latest Latest
Warning

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

Go to latest
Published: Aug 21, 2021 License: MIT Imports: 77 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrTenantStillHasServices -
	ErrTenantStillHasServices = errors.New("tenant still has services")
	// ErrTenantStillHasPlugins -
	ErrTenantStillHasPlugins = errors.New("tenant still has plugins")
)
View Source
var ErrServiceNotClosed = errors.New("Service has not been closed")

ErrServiceNotClosed -

Functions

func BasePack

func BasePack(text []byte) (string, error)

BasePack base pack

func CheckTenantResource

func CheckTenantResource(ctx context.Context, tenant *dbmodel.Tenants, needMemory int) error

CheckTenantResource check tenant's resource is support action or not

func ClusterAllocMemory

func ClusterAllocMemory(ctx context.Context) (int64, error)

ClusterAllocMemory returns the allocatable memory of the cluster.

func CreateDefaultTokenMap

func CreateDefaultTokenMap(conf option.Config)

CreateDefaultTokenMap

func CreateLicenseManger

func CreateLicenseManger() error

CreateLicenseManger create service manager

func CreateLicensesInfoManager

func CreateLicensesInfoManager() error

CreateLicensesInfoManager CreateLicensesInfoManager

func CreateRootFuncHandler

func CreateRootFuncHandler(conf option.Config) error

CreateRootFuncHandler create root func handler

func CreateTokenIdenHandler

func CreateTokenIdenHandler(conf option.Config) error

CreateTokenIdenHandler create token identification handler

func GetAPPBackupHandler

func GetAPPBackupHandler() *group.BackupHandle

GetAPPBackupHandler GetAPPBackupHandler

func GetBuilderProxy

func GetBuilderProxy() proxy.Proxy

GetBuilderProxy

func GetDefaultSourceURI

func GetDefaultSourceURI() map[string][]*dbmodel.RegionAPIClass

GetDefaultSourceURI

func GetDefaultTokenMap

func GetDefaultTokenMap() map[string]*dbmodel.RegionUserInfo

GetDefaultTokenMap

func GetKubernetesDashboardProxy

func GetKubernetesDashboardProxy() proxy.Proxy

GetKubernetesDashboardProxy returns the kubernetes dashboard proxy.

func GetMonitorProxy

func GetMonitorProxy() proxy.Proxy

GetMonitorProxy

func GetNodeProxy

func GetNodeProxy() proxy.Proxy

GetNodeProxy

func GetPluginShareHandle

func GetPluginShareHandle() *share.PluginShareHandle

GetPluginShareHandle get plugin share handle

func GetPrometheusProxy

func GetPrometheusProxy() proxy.Proxy

GetPrometheusProxy

func GetServicesDiskDeprecated

func GetServicesDiskDeprecated(ids []string, prometheusCli prometheus.Interface) map[string]float64

GetServicesDiskDeprecated get service disk

Deprecated

func GetShareHandle

func GetShareHandle() *share.ServiceShareHandle

GetShareHandle get share handle

func InitHandle

func InitHandle(conf option.Config,
	etcdClientArgs *etcdutil.ClientArgs,
	statusCli *client.AppRuntimeSyncClient,
	etcdcli *clientv3.Client,
	kubeClient *kubernetes.Clientset,
	katoClient versioned.Interface,
	k8sClient k8sclient.Client,
) error

InitHandle Initialize the handle

func InitProxy

func InitProxy(conf option.Config)

InitProxy

func ListLicense

func ListLicense() (map[string]*api_model.LicenseInfo, error)

ListLicense list license

func SetTokenCache

func SetTokenCache(info *dbmodel.RegionUserInfo)

SetTokenCache

func TransStatus

func TransStatus(eStatus string) string

TransStatus trans service status

Types

type AllocMemory

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

AllocMemory represents a allocatable memory.

func NewAllocMemory

func NewAllocMemory(ctx context.Context, statusCli *client.AppRuntimeSyncClient, tenant *dbmodel.Tenants, batchOpReqs model.BatchOpRequesters) (*AllocMemory, error)

NewAllocMemory creates a new AllocMemory.

func (*AllocMemory) BadOpRequests

func (a *AllocMemory) BadOpRequests() model.BatchOpRequesters

BadOpRequests returns the badOpRequests.

func (*AllocMemory) BatchOpRequests

func (a *AllocMemory) BatchOpRequests() model.BatchOpRequesters

BatchOpRequests returns the batchOpRequests.

func (*AllocMemory) BatchOpResult

func (a *AllocMemory) BatchOpResult() model.BatchOpResult

BatchOpResult returns the batchOpResult.

type AppAction

type AppAction struct {
	MQClient client.MQClient
	// contains filtered or unexported fields
}

AppAction app action

func CreateAppManager

func CreateAppManager(mqClient client.MQClient) *AppAction

CreateAppManager create app manager

func GetAppHandler

func GetAppHandler() *AppAction

GetAppHandler GetAppHandler

func (*AppAction) Complete

func (a *AppAction) Complete(tr *model.ExportAppStruct) error

Complete Complete

func (*AppAction) ExportApp

func (a *AppAction) ExportApp(tr *model.ExportAppStruct) error

ExportApp ExportApp

func (*AppAction) GetStaticDir

func (a *AppAction) GetStaticDir() string

GetStaticDir get static dir

func (*AppAction) ImportApp

func (a *AppAction) ImportApp(importApp *model.ImportAppStruct) error

ImportApp import app

type AppRestoreAction

type AppRestoreAction struct {
}

AppRestoreAction is an implementation of AppRestoreHandler

func (*AppRestoreAction) RestoreDepVols

func (a *AppRestoreAction) RestoreDepVols(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error

RestoreDepVols restores service dependent volumes.

func (*AppRestoreAction) RestoreDeps

func (a *AppRestoreAction) RestoreDeps(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error

RestoreDeps restores service dependencies.

func (*AppRestoreAction) RestoreEnvs

func (a *AppRestoreAction) RestoreEnvs(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error

RestoreEnvs restores environment variables.

func (*AppRestoreAction) RestorePlugins

func (a *AppRestoreAction) RestorePlugins(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error

RestorePlugins restores service plugins.

func (*AppRestoreAction) RestorePorts

func (a *AppRestoreAction) RestorePorts(tenantID, serviceID string, req *apimodel.RestorePortsReq) error

RestorePorts restores service ports.

func (*AppRestoreAction) RestoreProbe

func (a *AppRestoreAction) RestoreProbe(serviceID string, req *apimodel.ServiceProbe) error

RestoreProbe restores service probe.

func (*AppRestoreAction) RestoreVolumes

func (a *AppRestoreAction) RestoreVolumes(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error

RestoreVolumes restores service volumes.

type AppRestoreHandler

type AppRestoreHandler interface {
	RestoreEnvs(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error
	RestorePorts(tenantID, serviceID string, req *apimodel.RestorePortsReq) error
	RestoreVolumes(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error
	RestoreProbe(serviceID string, req *apimodel.ServiceProbe) error
	RestoreDeps(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error
	RestoreDepVols(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error
	RestorePlugins(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error
}

AppRestoreHandler defines handler methods to restore app. app means market service.

func GetAppRestoreHandler

func GetAppRestoreHandler() AppRestoreHandler

GetAppRestoreHandler returns a default AppRestoreHandler

func NewAppRestoreHandler

func NewAppRestoreHandler() AppRestoreHandler

NewAppRestoreHandler creates a new AppRestoreHandler.

type ApplicationAction

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

ApplicationAction -

func (*ApplicationAction) AddConfigGroup

AddConfigGroup -

func (*ApplicationAction) BatchBindService

func (a *ApplicationAction) BatchBindService(appID string, req model.BindServiceRequest) error

BatchBindService -

func (*ApplicationAction) BatchCreateApp

func (a *ApplicationAction) BatchCreateApp(ctx context.Context, apps *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error)

BatchCreateApp -

func (*ApplicationAction) BatchUpdateComponentPorts

func (a *ApplicationAction) BatchUpdateComponentPorts(appID string, ports []*model.AppPort) error

BatchUpdateComponentPorts -

func (*ApplicationAction) CreateApp

CreateApp -

func (*ApplicationAction) DeleteApp

func (a *ApplicationAction) DeleteApp(ctx context.Context, app *dbmodel.Application) error

DeleteApp -

func (*ApplicationAction) DeleteConfigGroup

func (a *ApplicationAction) DeleteConfigGroup(appID, configGroupName string) error

DeleteConfigGroup -

func (*ApplicationAction) GetAppByID

func (a *ApplicationAction) GetAppByID(appID string) (*dbmodel.Application, error)

GetAppByID -

func (*ApplicationAction) GetStatus

GetStatus -

func (*ApplicationAction) Install

func (a *ApplicationAction) Install(ctx context.Context, app *dbmodel.Application, overrides []string) error

Install installs the application.

func (*ApplicationAction) ListAppStatuses

func (a *ApplicationAction) ListAppStatuses(ctx context.Context, appIDs []string) ([]*model.AppStatus, error)

ListAppStatuses -

func (*ApplicationAction) ListApps

func (a *ApplicationAction) ListApps(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error)

ListApps -

func (*ApplicationAction) ListConfigGroups

func (a *ApplicationAction) ListConfigGroups(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error)

ListConfigGroups -

func (*ApplicationAction) ListHelmAppReleases

func (a *ApplicationAction) ListHelmAppReleases(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error)

ListHelmAppReleases returns the list of the helm app.

func (*ApplicationAction) ListServices

func (a *ApplicationAction) ListServices(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error)

ListServices returns the list of the application.

func (*ApplicationAction) SyncAppConfigGroups

func (a *ApplicationAction) SyncAppConfigGroups(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error

SyncAppConfigGroups -

func (*ApplicationAction) SyncComponentConfigGroupRels

func (a *ApplicationAction) SyncComponentConfigGroupRels(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error

SyncComponentConfigGroupRels -

func (*ApplicationAction) SyncComponents

func (a *ApplicationAction) SyncComponents(app *dbmodel.Application, components []*model.Component, deleteComponentIDs []string) error

SyncComponents -

func (*ApplicationAction) UpdateApp

UpdateApp -

func (*ApplicationAction) UpdateConfigGroup

func (a *ApplicationAction) UpdateConfigGroup(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error)

UpdateConfigGroup -

type ApplicationHandler

type ApplicationHandler interface {
	CreateApp(ctx context.Context, req *model.Application) (*model.Application, error)
	BatchCreateApp(ctx context.Context, req *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error)
	UpdateApp(ctx context.Context, app *dbmodel.Application, req model.UpdateAppRequest) (*dbmodel.Application, error)
	ListApps(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error)
	GetAppByID(appID string) (*dbmodel.Application, error)
	BatchBindService(appID string, req model.BindServiceRequest) error
	DeleteApp(ctx context.Context, app *dbmodel.Application) error

	AddConfigGroup(appID string, req *model.ApplicationConfigGroup) (*model.ApplicationConfigGroupResp, error)
	UpdateConfigGroup(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error)

	BatchUpdateComponentPorts(appID string, ports []*model.AppPort) error
	GetStatus(ctx context.Context, app *dbmodel.Application) (*model.AppStatus, error)
	Install(ctx context.Context, app *dbmodel.Application, overrides []string) error
	ListServices(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error)
	ListHelmAppReleases(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error)

	DeleteConfigGroup(appID, configGroupName string) error
	ListConfigGroups(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error)
	SyncComponents(app *dbmodel.Application, components []*model.Component, deleteComponentIDs []string) error
	SyncComponentConfigGroupRels(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error
	SyncAppConfigGroups(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error
	ListAppStatuses(ctx context.Context, appIDs []string) ([]*model.AppStatus, error)
}

ApplicationHandler defines handler methods to TenantApplication.

func GetApplicationHandler

func GetApplicationHandler() ApplicationHandler

GetApplicationHandler returns the default tenant application handler.

func NewApplicationHandler

func NewApplicationHandler(statusCli *client.AppRuntimeSyncClient, promClient prometheus.Interface, katoClient versioned.Interface, kubeClient clientset.Interface) ApplicationHandler

NewApplicationHandler creates a new Tenant Application Handler.

type BatchOperationHandler

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

BatchOperationHandler batch operation handler

func CreateBatchOperationHandler

func CreateBatchOperationHandler(mqCli gclient.MQClient, statusCli *client.AppRuntimeSyncClient, operationHandler *OperationHandler) *BatchOperationHandler

CreateBatchOperationHandler create batch operation handler

func GetBatchOperationHandler

func GetBatchOperationHandler() *BatchOperationHandler

GetBatchOperationHandler get handler

func (*BatchOperationHandler) Build

func (b *BatchOperationHandler) Build(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)

Build build

func (*BatchOperationHandler) Start

func (b *BatchOperationHandler) Start(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)

Start batch start

func (*BatchOperationHandler) Stop

func (b *BatchOperationHandler) Stop(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)

Stop batch stop

func (*BatchOperationHandler) Upgrade

func (b *BatchOperationHandler) Upgrade(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)

Upgrade batch upgrade

type BatchOperationResult

type BatchOperationResult struct {
	BatchResult []OperationResult `json:"batche_result"`
}

BatchOperationResult batch operation result

type CloudAction

type CloudAction struct {
	RegionTag string
	APISSL    bool
	CAPath    string
	KeyPath   string
}

CloudAction cloud action struct

func CreateCloudManager

func CreateCloudManager(conf option.Config) *CloudAction

CreateCloudManager get cloud manager

func (*CloudAction) CertDispatcher

func (c *CloudAction) CertDispatcher(gt *api_model.GetUserToken) ([]byte, []byte, error)

CertDispatcher Cert

func (*CloudAction) GetTokenInfo

func (c *CloudAction) GetTokenInfo(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError)

GetTokenInfo GetTokenInfo

func (*CloudAction) TokenDispatcher

TokenDispatcher token

func (*CloudAction) UpdateTokenTime

func (c *CloudAction) UpdateTokenTime(eid string, vd int) *util.APIHandleError

UpdateTokenTime UpdateTokenTime

type CloudHandler

type CloudHandler interface {
	TokenDispatcher(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError)
	GetTokenInfo(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError)
	UpdateTokenTime(eid string, vd int) *util.APIHandleError
}

CloudHandler define source handler

func GetCloudManager

func GetCloudManager() CloudHandler

GetCloudManager get manager

type ClusterHandler

type ClusterHandler interface {
	GetClusterInfo(ctx context.Context) (*model.ClusterResource, error)
	MavenSettingAdd(ctx context.Context, ms *MavenSetting) *util.APIHandleError
	MavenSettingList(ctx context.Context) (re []MavenSetting)
	MavenSettingUpdate(ctx context.Context, ms *MavenSetting) *util.APIHandleError
	MavenSettingDelete(ctx context.Context, name string) *util.APIHandleError
	MavenSettingDetail(ctx context.Context, name string) (*MavenSetting, *util.APIHandleError)
}

ClusterHandler -

func GetClusterHandler

func GetClusterHandler() ClusterHandler

GetClusterHandler returns the default cluster handler.

func NewClusterHandler

func NewClusterHandler(clientset *kubernetes.Clientset, RbdNamespace string) ClusterHandler

NewClusterHandler -

type ClusterResourceStats

type ClusterResourceStats struct {
	AllCPU        int64
	AllMemory     int64
	RequestCPU    int64
	RequestMemory int64
}

ClusterResourceStats cluster resource stats

type ComponentIngressTask

type ComponentIngressTask struct {
	ComponentID string `json:"service_id"`
	Action      string `json:"action"`
	Port        int    `json:"port"`
	IsInner     bool   `json:"is_inner"`
}

ComponentIngressTask -

type EtcdHandler

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

EtcdHandler defines handler methods about k8s pods.

func GetEtcdHandler

func GetEtcdHandler() *EtcdHandler

GetEtcdHandler returns the default etcd handler.

func NewEtcdHandler

func NewEtcdHandler(etcdCli *clientv3.Client) *EtcdHandler

NewEtcdHandler creates a new PodHandler.

func (*EtcdHandler) CleanAllServiceData

func (h *EtcdHandler) CleanAllServiceData(keys []string)

func (*EtcdHandler) CleanServiceCheckData

func (h *EtcdHandler) CleanServiceCheckData(key string)

CleanServiceCheckData clean service check etcd data

type EtcdKeyType

type EtcdKeyType int

EtcdKeyType etcd key type

const (
	// ServiceCheckEtcdKey source check etcd key
	ServiceCheckEtcdKey EtcdKeyType = iota
	// ShareResultEtcdKey share result etcd key
	ShareResultEtcdKey
	//BackupRestoreEtcdKey backup restore etcd key
	BackupRestoreEtcdKey
)

type EventHandler

type EventHandler interface {
	GetLogList(serviceAlias string) ([]*model.HistoryLogFile, error)
	GetLogInstance(serviceID string) (string, error)
	GetLevelLog(eventID string, level string) (*api_model.DataLog, error)
	GetLogFile(serviceAlias, fileName string) (string, string, error)
	GetEvents(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error)
}

EventHandler event handler interface

func GetEventHandler

func GetEventHandler() EventHandler

GetEventHandler get event handler

type GatewayAction

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

GatewayAction -

func CreateGatewayManager

func CreateGatewayManager(dbmanager db.Manager, mqclient client.MQClient, etcdCli *clientv3.Client) *GatewayAction

CreateGatewayManager creates gateway manager.

func (*GatewayAction) AddCertificate

func (g *GatewayAction) AddCertificate(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error

AddCertificate adds certificate to db if it doesn't exists

func (*GatewayAction) AddHTTPRule

func (g *GatewayAction) AddHTTPRule(req *apimodel.AddHTTPRuleStruct) error

AddHTTPRule adds http rule to db if it doesn't exists.

func (*GatewayAction) AddRuleExtensions

func (g *GatewayAction) AddRuleExtensions(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct,
	tx *gorm.DB) error

AddRuleExtensions adds rule extensions to db if any of they doesn't exists

func (*GatewayAction) AddTCPRule

func (g *GatewayAction) AddTCPRule(req *apimodel.AddTCPRuleStruct) error

AddTCPRule adds tcp rule.

func (*GatewayAction) CreateHTTPRule

func (g *GatewayAction) CreateHTTPRule(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error

CreateHTTPRule Create http rules through transactions

func (*GatewayAction) CreateTCPRule

func (g *GatewayAction) CreateTCPRule(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error

CreateTCPRule Create tcp rules through transactions

func (*GatewayAction) DeleteHTTPRule

func (g *GatewayAction) DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) error

DeleteHTTPRule deletes http rule, including certificate and rule extensions

func (*GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction

func (g *GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

DeleteHTTPRuleByServiceIDWithTransaction deletes http rule, including certificate and rule extensions

func (*GatewayAction) DeleteIngressRulesByComponentPort

func (g *GatewayAction) DeleteIngressRulesByComponentPort(tx *gorm.DB, componentID string, port int) error

DeleteIngressRulesByComponentPort deletes ingress rules, including http rules and tcp rules, based on the given componentID and port.

func (*GatewayAction) DeleteTCPRule

func (g *GatewayAction) DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) error

DeleteTCPRule deletes a tcp rule

func (*GatewayAction) DeleteTCPRuleByServiceIDWithTransaction

func (g *GatewayAction) DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

DeleteTCPRuleByServiceIDWithTransaction deletes a tcp rule

func (*GatewayAction) GetAvailablePort

func (g *GatewayAction) GetAvailablePort(ip string, lock bool) (int, error)

GetAvailablePort returns a available port

func (*GatewayAction) GetGatewayIPs

func (g *GatewayAction) GetGatewayIPs() []IPAndAvailablePort

GetGatewayIPs get all gateway node ips

func (*GatewayAction) ListHTTPRulesByCertID

func (g *GatewayAction) ListHTTPRulesByCertID(certID string) ([]*model.HTTPRule, error)

ListHTTPRulesByCertID -

func (*GatewayAction) RuleConfig

func (g *GatewayAction) RuleConfig(req *apimodel.RuleConfigReq) error

RuleConfig -

func (*GatewayAction) SendTask

func (g *GatewayAction) SendTask(task *ComponentIngressTask) error

SendTask sends apply rules task

func (*GatewayAction) SendTaskDeprecated

func (g *GatewayAction) SendTaskDeprecated(in map[string]interface{}) error

SendTaskDeprecated sends apply rules task

func (*GatewayAction) SyncHTTPRules

func (g *GatewayAction) SyncHTTPRules(tx *gorm.DB, components []*apimodel.Component) error

SyncHTTPRules -

func (*GatewayAction) SyncRuleConfigs

func (g *GatewayAction) SyncRuleConfigs(tx *gorm.DB, components []*apimodel.Component) error

SyncRuleConfigs -

func (*GatewayAction) SyncTCPRules

func (g *GatewayAction) SyncTCPRules(tx *gorm.DB, components []*apimodel.Component) error

SyncTCPRules -

func (*GatewayAction) TCPIPPortExists

func (g *GatewayAction) TCPIPPortExists(host string, port int) bool

TCPIPPortExists returns if the port exists

func (*GatewayAction) UpdCertificate

func (g *GatewayAction) UpdCertificate(req *apimodel.UpdCertificateReq) error

UpdCertificate -

func (*GatewayAction) UpdateCertificate

func (g *GatewayAction) UpdateCertificate(req apimodel.AddHTTPRuleStruct, httpRule *model.HTTPRule,
	tx *gorm.DB) error

UpdateCertificate updates certificate for http rule

func (*GatewayAction) UpdateHTTPRule

func (g *GatewayAction) UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) error

UpdateHTTPRule updates http rule

func (*GatewayAction) UpdateTCPRule

func (g *GatewayAction) UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) error

UpdateTCPRule updates a tcp rule

type GatewayHandler

type GatewayHandler interface {
	AddHTTPRule(req *apimodel.AddHTTPRuleStruct) error
	CreateHTTPRule(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error
	UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) error
	DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) error
	DeleteHTTPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

	AddCertificate(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error
	UpdateCertificate(req apimodel.AddHTTPRuleStruct, httpRule *dbmodel.HTTPRule, tx *gorm.DB) error

	AddTCPRule(req *apimodel.AddTCPRuleStruct) error
	CreateTCPRule(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error
	UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) error
	DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) error
	DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error
	AddRuleExtensions(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct, tx *gorm.DB) error
	GetAvailablePort(ip string, lock bool) (int, error)
	TCPIPPortExists(ip string, port int) bool
	// Deprecated.
	SendTaskDeprecated(in map[string]interface{}) error
	SendTask(task *ComponentIngressTask) error
	RuleConfig(req *apimodel.RuleConfigReq) error
	UpdCertificate(req *apimodel.UpdCertificateReq) error
	GetGatewayIPs() []IPAndAvailablePort
	ListHTTPRulesByCertID(certID string) ([]*dbmodel.HTTPRule, error)
	DeleteIngressRulesByComponentPort(tx *gorm.DB, componentID string, port int) error
	SyncHTTPRules(tx *gorm.DB, components []*apimodel.Component) error
	SyncTCPRules(tx *gorm.DB, components []*apimodel.Component) error
}

GatewayHandler gateway api handler

func GetGatewayHandler

func GetGatewayHandler() GatewayHandler

GetGatewayHandler returns a default GatewayHandler

type IPAndAvailablePort

type IPAndAvailablePort struct {
	IP            string `json:"ip"`
	AvailablePort int    `json:"available_port"`
}

IPAndAvailablePort ip and advice available port

type Info

type Info struct {
	Code       string   `json:"code"`
	Company    string   `json:"company"`
	Node       int64    `json:"node"`
	CPU        int64    `json:"cpu"`
	Memory     int64    `json:"memory"`
	Tenant     int64    `json:"tenant"`
	EndTime    string   `json:"end_time"`
	StartTime  string   `json:"start_time"`
	DataCenter int64    `json:"data_center"`
	ModuleList []string `json:"module_list"`
}

Info license information

func ReadLicenseFromFile

func ReadLicenseFromFile(licenseFile string) (Info, error)

ReadLicenseFromFile

type K8sPodInfo

type K8sPodInfo struct {
	PodName   string                       `json:"pod_name"`
	PodIP     string                       `json:"pod_ip"`
	PodStatus string                       `json:"pod_status"`
	ServiceID string                       `json:"service_id"`
	Container map[string]map[string]string `json:"container"`
}

K8sPodInfo for api

type K8sPodInfos

type K8sPodInfos struct {
	NewPods []*K8sPodInfo `json:"new_pods"`
	OldPods []*K8sPodInfo `json:"old_pods"`
}

K8sPodInfos -

type LangInfo

type LangInfo struct {
	Lang  string `json:"lang"`
	Major []*MajorInfo
}

LangInfo LangInfo

type LicenseAction

type LicenseAction struct{}

LicenseAction LicenseAction

func (*LicenseAction) PackLicense

func (l *LicenseAction) PackLicense(encrypted string) ([]byte, error)

PackLicense PackLicense

func (*LicenseAction) StoreLicense

func (l *LicenseAction) StoreLicense(license, token string) error

StoreLicense StoreLicense

type LicenseHandler

type LicenseHandler interface {
	PackLicense(encrypted string) ([]byte, error)
	StoreLicense(license, token string) error
}

LicenseHandler LicenseAction

func GetLicenseHandler

func GetLicenseHandler() LicenseHandler

GetLicenseHandler get license handler

type LicenseInfoHandler

type LicenseInfoHandler interface {
	ShowInfos() (map[string]*api_model.LicenseInfo, error)
}

LicenseInfoHandler LicenseInfoHandler

func GetLicensesInfosHandler

func GetLicensesInfosHandler() LicenseInfoHandler

GetLicensesInfosHandler GetLicensesInfosHandler

type LicensesInfos

type LicensesInfos struct {
	Infos map[string]*api_model.LicenseInfo
}

LicensesInfos verification

func (*LicensesInfos) ShowInfos

func (l *LicensesInfos) ShowInfos() (map[string]*api_model.LicenseInfo, error)

ShowInfos ShowInfos

type LogAction

type LogAction struct {
	EtcdCli *clientv3.Client
	// contains filtered or unexported fields
}

LogAction log action struct

func CreateLogManager

func CreateLogManager(cli *clientv3.Client) *LogAction

CreateLogManager get log manager

func (*LogAction) GetEvents

func (l *LogAction) GetEvents(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error)

GetEvents get target logs

func (*LogAction) GetLevelLog

func (l *LogAction) GetLevelLog(eventID string, level string) (*api_model.DataLog, error)

GetLevelLog get event log

func (*LogAction) GetLogFile

func (l *LogAction) GetLogFile(serviceAlias, fileName string) (string, string, error)

GetLogFile GetLogFile

func (*LogAction) GetLogInstance

func (l *LogAction) GetLogInstance(serviceID string) (string, error)

GetLogInstance get log web socket instance

func (*LogAction) GetLogList

func (l *LogAction) GetLogList(serviceAlias string) ([]*model.HistoryLogFile, error)

GetLogList get log list

type MajorInfo

type MajorInfo struct {
	Major int `json:"major"`
	Minor []*MinorInfo
}

MajorInfo MajorInfo

type MavenSetting

type MavenSetting struct {
	Name       string `json:"name" validate:"required"`
	CreateTime string `json:"create_time"`
	UpdateTime string `json:"update_time"`
	Content    string `json:"content" validate:"required"`
	IsDefault  bool   `json:"is_default"`
}

MavenSetting maven setting

type MinorInfo

type MinorInfo struct {
	Minor int   `json:"minor"`
	Patch []int `json:"patch"`
}

MinorInfo MinorInfo

type MonitorHandler

type MonitorHandler interface {
	GetTenantMonitorMetrics(tenantID string) []prometheus.Metadata
	GetAppMonitorMetrics(tenantID, appID string) []prometheus.Metadata
	GetComponentMonitorMetrics(tenantID, componentID string) []prometheus.Metadata
}

MonitorHandler monitor api handler

func GetMonitorHandle

func GetMonitorHandle() MonitorHandler

GetMonitorHandle get monitor handler

func NewMonitorHandler

func NewMonitorHandler(cli prometheus.Interface) MonitorHandler

NewMonitorHandler new monitor handler

type NetRulesAction

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

NetRulesAction rules action struct

func CreateNetRulesManager

func CreateNetRulesManager(etcdCli *clientv3.Client) *NetRulesAction

CreateNetRulesManager get net rules manager

func (*NetRulesAction) CreateDownStreamNetRules

func (n *NetRulesAction) CreateDownStreamNetRules(
	tenantID string,
	rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError

CreateDownStreamNetRules CreateDownStreamNetRules

func (*NetRulesAction) GetDownStreamNetRule

func (n *NetRulesAction) GetDownStreamNetRule(
	tenantID,
	serviceAlias,
	destServiceAlias,
	port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError)

GetDownStreamNetRule GetDownStreamNetRule

func (*NetRulesAction) UpdateDownStreamNetRule

func (n *NetRulesAction) UpdateDownStreamNetRule(
	tenantID string,
	urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError

UpdateDownStreamNetRule UpdateDownStreamNetRule

type NetRulesHandler

type NetRulesHandler interface {
	CreateDownStreamNetRules(
		tenantID string,
		rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError
	GetDownStreamNetRule(
		tenantID,
		serviceAlias,
		destServiceAlias,
		port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError)
	UpdateDownStreamNetRule(
		tenantID string,
		urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError
}

NetRulesHandler net rules handler

func GetRulesManager

func GetRulesManager() NetRulesHandler

GetRulesManager get manager

type OperationHandler

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

OperationHandler operation handler

func CreateOperationHandler

func CreateOperationHandler(mqCli gclient.MQClient) *OperationHandler

CreateOperationHandler create operation handler

func GetOperationHandler

func GetOperationHandler() *OperationHandler

GetOperationHandler get handler

func (*OperationHandler) Build

Build service build,will create new version if deploy version not define, will create by time

func (*OperationHandler) RollBack

RollBack service rollback

func (*OperationHandler) Start

func (o *OperationHandler) Start(batchOpReq model.ComponentOpReq) error

Start service start

func (*OperationHandler) Stop

func (o *OperationHandler) Stop(batchOpReq model.ComponentOpReq) error

Stop service stop

func (*OperationHandler) Upgrade

Upgrade service upgrade

type OperationResult

type OperationResult struct {
	ServiceID     string `json:"service_id"`
	Operation     string `json:"operation"`
	EventID       string `json:"event_id"`
	Status        string `json:"status"`
	ErrMsg        string `json:"err_message"`
	DeployVersion string `json:"deploy_version"`
}

OperationResult batch operation result

type PluginAction

type PluginAction struct {
	MQClient client.MQClient
}

PluginAction plugin action struct

func CreatePluginManager

func CreatePluginManager(mqClient client.MQClient) *PluginAction

CreatePluginManager get plugin manager

func (*PluginAction) AddDefaultEnv

func (p *PluginAction) AddDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError

AddDefaultEnv AddDefaultEnv

func (*PluginAction) BatchBuildPlugins

func (p *PluginAction) BatchBuildPlugins(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError

BatchBuildPlugins -

func (*PluginAction) BatchCreatePlugins

func (p *PluginAction) BatchCreatePlugins(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError

BatchCreatePlugins -

func (*PluginAction) BuildPluginManual

BuildPluginManual BuildPluginManual

func (*PluginAction) CreatePluginAct

func (p *PluginAction) CreatePluginAct(cps *api_model.CreatePluginStruct) *util.APIHandleError

CreatePluginAct PluginAct

func (*PluginAction) DeleteDefaultEnv

func (p *PluginAction) DeleteDefaultEnv(pluginID, versionID, name string) *util.APIHandleError

DeleteDefaultEnv DeleteDefaultEnv

func (*PluginAction) DeletePluginAct

func (p *PluginAction) DeletePluginAct(pluginID, tenantID string) *util.APIHandleError

DeletePluginAct DeletePluginAct

func (*PluginAction) DeletePluginBuildVersion

func (p *PluginAction) DeletePluginBuildVersion(pluginID, versionID string) *util.APIHandleError

DeletePluginBuildVersion DeletePluginBuildVersion

func (*PluginAction) GetAllPluginBuildVersions

func (p *PluginAction) GetAllPluginBuildVersions(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

GetAllPluginBuildVersions GetAllPluginBuildVersions

func (*PluginAction) GetDefaultEnv

func (p *PluginAction) GetDefaultEnv(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError)

GetDefaultEnv GetDefaultEnv

func (*PluginAction) GetEnvsWhichCanBeSet

func (p *PluginAction) GetEnvsWhichCanBeSet(serviceID, pluginID string) (interface{}, *util.APIHandleError)

GetEnvsWhichCanBeSet GetEnvsWhichCanBeSet

func (*PluginAction) GetPluginBuildVersion

func (p *PluginAction) GetPluginBuildVersion(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

GetPluginBuildVersion GetPluginBuildVersion

func (*PluginAction) GetPlugins

func (p *PluginAction) GetPlugins(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError)

GetPlugins get all plugins by tenantID

func (*PluginAction) UpdateDefaultEnv

func (p *PluginAction) UpdateDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError

UpdateDefaultEnv UpdateDefaultEnv

func (*PluginAction) UpdatePluginAct

func (p *PluginAction) UpdatePluginAct(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError

UpdatePluginAct UpdatePluginAct

type PluginHandler

type PluginHandler interface {
	CreatePluginAct(cps *api_model.CreatePluginStruct) *util.APIHandleError
	UpdatePluginAct(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError
	DeletePluginAct(pluginID, tenantID string) *util.APIHandleError
	GetPlugins(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError)
	AddDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError
	UpdateDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError
	DeleteDefaultEnv(pluginID, versionID, envName string) *util.APIHandleError
	BuildPluginManual(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
	GetAllPluginBuildVersions(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
	GetPluginBuildVersion(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
	DeletePluginBuildVersion(pluginID, versionID string) *util.APIHandleError
	GetDefaultEnv(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError)
	GetEnvsWhichCanBeSet(serviceID, pluginID string) (interface{}, *util.APIHandleError)
	BatchCreatePlugins(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError
	BatchBuildPlugins(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError
}

PluginHandler plugin handler

func GetPluginManager

func GetPluginManager() PluginHandler

GetPluginManager get manager

type PodAction

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

PodAction is an implementation of PodHandler

func (*PodAction) PodDetail

func (p *PodAction) PodDetail(serviceID, podName string) (*pb.PodDetail, error)

PodDetail -

type PodHandler

type PodHandler interface {
	PodDetail(serviceID, podName string) (*pb.PodDetail, error)
}

PodHandler defines handler methods about k8s pods.

func GetPodHandler

func GetPodHandler() PodHandler

GetPodHandler returns the defalut PodHandler

func NewPodHandler

func NewPodHandler(statusCli *client.AppRuntimeSyncClient) PodHandler

NewPodHandler creates a new PodHandler.

type QueryResult

type QueryResult struct {
	Data struct {
		Type   string                   `json:"resultType"`
		Result []map[string]interface{} `json:"result"`
	} `json:"data"`
	Status string `json:"status"`
}

QueryResult contains result data for a query.

type RootAction

type RootAction struct{}

RootAction root function action struct

func CreateRootFuncManager

func CreateRootFuncManager(conf option.Config) *RootAction

CreateRootFuncManager get root func manager

func (*RootAction) ResolvePHP

func (r *RootAction) ResolvePHP(cs *api_model.ComposerStruct) (string, error)

ResolvePHP php - application build

type RootFuncHandler

type RootFuncHandler interface {
}

RootFuncHandler root function handler interface

func GetRootFuncHandler

func GetRootFuncHandler() RootFuncHandler

GetRootFuncHandler get root handler

type ServiceAction

type ServiceAction struct {
	MQClient gclient.MQClient
	EtcdCli  *clientv3.Client
	// contains filtered or unexported fields
}

ServiceAction service act

func CreateManager

func CreateManager(conf option.Config,
	mqClient gclient.MQClient,
	etcdCli *clientv3.Client,
	statusCli *client.AppRuntimeSyncClient,
	prometheusCli prometheus.Interface,
	katoClient versioned.Interface,
	kubeClient kubernetes.Interface) *ServiceAction

CreateManager create Manger

func (*ServiceAction) AddAutoscalerRule

func (s *ServiceAction) AddAutoscalerRule(req *api_model.AutoscalerRuleReq) error

AddAutoscalerRule -

func (*ServiceAction) AddLabel

func (s *ServiceAction) AddLabel(l *api_model.LabelsStruct, serviceID string) error

AddLabel add labels

func (*ServiceAction) AddServiceMonitor

func (s *ServiceAction) AddServiceMonitor(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)

AddServiceMonitor add service monitor

func (*ServiceAction) CodeCheck

func (s *ServiceAction) CodeCheck(c *api_model.CheckCodeStruct) error

CodeCheck code check

func (*ServiceAction) CreatePorts

func (s *ServiceAction) CreatePorts(tenantID, serviceID string, vps *api_model.ServicePorts) error

CreatePorts -

func (*ServiceAction) CreateTenandIDAndName

func (s *ServiceAction) CreateTenandIDAndName(eid string) (string, string, error)

CreateTenandIDAndName create tenant_id and tenant_name

func (*ServiceAction) CreateTenant

func (s *ServiceAction) CreateTenant(t *dbmodel.Tenants) error

CreateTenant create tenant

func (*ServiceAction) DeleteLabel

func (s *ServiceAction) DeleteLabel(l *api_model.LabelsStruct, serviceID string) error

DeleteLabel deletes label

func (*ServiceAction) DeletePluginConfig

func (s *ServiceAction) DeletePluginConfig(serviceID, pluginID string) *util.APIHandleError

DeletePluginConfig delete service plugin dynamic discovery config

func (*ServiceAction) DeleteServiceMonitor

func (s *ServiceAction) DeleteServiceMonitor(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error)

DeleteServiceMonitor delete

func (*ServiceAction) EnvAttr

func (s *ServiceAction) EnvAttr(action string, at *dbmodel.TenantServiceEnvVar) error

EnvAttr env attr

func (*ServiceAction) GetComponentPodNums

func (s *ServiceAction) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)

GetComponentPodNums get pods

func (*ServiceAction) GetDepVolumes

func (s *ServiceAction) GetDepVolumes(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError)

GetDepVolumes Get dependent storage

func (*ServiceAction) GetEnterpriseRunningServices

func (s *ServiceAction) GetEnterpriseRunningServices(enterpriseID string) ([]string, *util.APIHandleError)

GetEnterpriseRunningServices get running services

func (*ServiceAction) GetMultiServicePods

func (s *ServiceAction) GetMultiServicePods(serviceIDs []string) (*K8sPodInfos, error)

GetMultiServicePods get pods

func (*ServiceAction) GetPagedTenantRes

func (s *ServiceAction) GetPagedTenantRes(offset, len int) ([]*api_model.TenantResource, int, error)

GetPagedTenantRes get pagedTenantServiceRes(s)

func (*ServiceAction) GetPodContainerMemory

func (s *ServiceAction) GetPodContainerMemory(podNames []string) (map[string]map[string]string, error)

GetPodContainerMemory Use Prometheus to query memory resources

func (*ServiceAction) GetPods

func (s *ServiceAction) GetPods(serviceID string) (*K8sPodInfos, error)

GetPods get pods

func (*ServiceAction) GetService

func (s *ServiceAction) GetService(tenantID string) ([]*dbmodel.TenantServices, error)

GetService get service(s)

func (*ServiceAction) GetServiceCheckInfo

func (s *ServiceAction) GetServiceCheckInfo(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError)

GetServiceCheckInfo get application source detection information

func (*ServiceAction) GetServiceDeployInfo

func (s *ServiceAction) GetServiceDeployInfo(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError)

GetServiceDeployInfo get service deploy info

func (*ServiceAction) GetServicesByAppID

func (s *ServiceAction) GetServicesByAppID(appID string, page, pageSize int) (*api_model.ListServiceResponse, error)

GetServicesByAppID get service(s) by appID

func (*ServiceAction) GetServicesStatus

func (s *ServiceAction) GetServicesStatus(tenantID string, serviceIDs []string) []map[string]interface{}

GetServicesStatus Get a set of application status, if serviceIDs is empty, get all application status of the tenant

func (*ServiceAction) GetStatus

func (s *ServiceAction) GetStatus(serviceID string) (*api_model.StatusList, error)

GetStatus GetStatus

func (*ServiceAction) GetTenantRes

func (s *ServiceAction) GetTenantRes(uuid string) (*api_model.TenantResource, error)

GetTenantRes get pagedTenantServiceRes(s)

func (*ServiceAction) GetTenantServicePluginRelation

func (s *ServiceAction) GetTenantServicePluginRelation(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

GetTenantServicePluginRelation

func (*ServiceAction) GetVolumes

func (s *ServiceAction) GetVolumes(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError)

GetVolumes Get all application storage

func (*ServiceAction) LanguageSet

func (s *ServiceAction) LanguageSet(langS *api_model.LanguageSet) error

LanguageSet language set

func (*ServiceAction) ListScalingRecords

func (s *ServiceAction) ListScalingRecords(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error)

ListScalingRecords -

func (*ServiceAction) ListVersionInfo

func (s *ServiceAction) ListVersionInfo(serviceID string) (*api_model.BuildListRespVO, error)

ListVersionInfo lists version info

func (*ServiceAction) Log

func (s *ServiceAction) Log(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, podName, containerName string, follow bool) error

Log returns the logs reader for a container in a pod, a pod or a component.

func (*ServiceAction) PortInner

func (s *ServiceAction) PortInner(tenantName, serviceID, operation string, port int) error

PortInner Port internal service operation TODO: send task to worker

func (*ServiceAction) PortOuter

func (s *ServiceAction) PortOuter(tenantName, serviceID string, containerPort int,
	servicePort *api_model.ServicePortInnerOrOuter) (*dbmodel.TenantServiceLBMappingPort, string, error)

PortOuter Port external service operation

func (*ServiceAction) PortVar

func (s *ServiceAction) PortVar(action, tenantID, serviceID string, vps *api_model.ServicePorts, oldPort int) error

PortVar port var

func (*ServiceAction) RollBack

func (s *ServiceAction) RollBack(rs *api_model.RollbackStruct) error

RollBack RollBack

func (*ServiceAction) SavePluginConfig

func (s *ServiceAction) SavePluginConfig(serviceID, pluginID string, config *api_model.ResourceSpec) *util.APIHandleError

SavePluginConfig save plugin dynamic discovery config

func (*ServiceAction) ServiceBuild

func (s *ServiceAction) ServiceBuild(tenantID, serviceID string, r *api_model.BuildServiceStruct) error

ServiceBuild service build

func (*ServiceAction) ServiceCheck

ServiceCheck check service build source

func (*ServiceAction) ServiceCreate

func (s *ServiceAction) ServiceCreate(sc *api_model.ServiceStruct) error

ServiceCreate create service

func (*ServiceAction) ServiceDepend

func (s *ServiceAction) ServiceDepend(action string, ds *api_model.DependService) error

ServiceDepend service depend

func (*ServiceAction) ServiceHorizontal

func (s *ServiceAction) ServiceHorizontal(hs *model.HorizontalScalingTaskBody) error

ServiceHorizontal Service Horizontal

func (*ServiceAction) ServiceProbe

func (s *ServiceAction) ServiceProbe(tsp *dbmodel.TenantServiceProbe, action string) error

ServiceProbe ServiceProbe

func (*ServiceAction) ServiceUpdate

func (s *ServiceAction) ServiceUpdate(sc map[string]interface{}) error

ServiceUpdate update service

func (*ServiceAction) ServiceUpgrade

func (s *ServiceAction) ServiceUpgrade(ru *model.RollingUpgradeTaskBody) error

ServiceUpgrade service upgrade

func (*ServiceAction) ServiceVertical

func (s *ServiceAction) ServiceVertical(ctx context.Context, vs *model.VerticalScalingTaskBody) error

ServiceVertical vertical service

func (*ServiceAction) SetTenantServicePluginRelation

func (s *ServiceAction) SetTenantServicePluginRelation(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

SetTenantServicePluginRelation

func (*ServiceAction) StartStopService

func (s *ServiceAction) StartStopService(sss *api_model.StartStopStruct) error

StartStopService start service

func (*ServiceAction) SyncComponentBase

func (s *ServiceAction) SyncComponentBase(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentBase -

func (*ServiceAction) SyncComponentConfigFiles

func (s *ServiceAction) SyncComponentConfigFiles(tx *gorm.DB, components []*api_model.Component) error

SyncComponentConfigFiles -

func (*ServiceAction) SyncComponentEndpoints

func (s *ServiceAction) SyncComponentEndpoints(tx *gorm.DB, components []*api_model.Component) error

SyncComponentEndpoints -

func (*ServiceAction) SyncComponentEnvs

func (s *ServiceAction) SyncComponentEnvs(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentEnvs -

func (*ServiceAction) SyncComponentLabels

func (s *ServiceAction) SyncComponentLabels(tx *gorm.DB, components []*api_model.Component) error

SyncComponentLabels -

func (*ServiceAction) SyncComponentMonitors

func (s *ServiceAction) SyncComponentMonitors(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentMonitors -

func (*ServiceAction) SyncComponentPlugins

func (s *ServiceAction) SyncComponentPlugins(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentPlugins -

func (*ServiceAction) SyncComponentPorts

func (s *ServiceAction) SyncComponentPorts(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentPorts -

func (*ServiceAction) SyncComponentProbes

func (s *ServiceAction) SyncComponentProbes(tx *gorm.DB, components []*api_model.Component) error

SyncComponentProbes -

func (*ServiceAction) SyncComponentRelations

func (s *ServiceAction) SyncComponentRelations(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentRelations -

func (*ServiceAction) SyncComponentScaleRules

func (s *ServiceAction) SyncComponentScaleRules(tx *gorm.DB, components []*api_model.Component) error

SyncComponentScaleRules -

func (*ServiceAction) SyncComponentVolumeRels

func (s *ServiceAction) SyncComponentVolumeRels(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

SyncComponentVolumeRels -

func (*ServiceAction) SyncComponentVolumes

func (s *ServiceAction) SyncComponentVolumes(tx *gorm.DB, components []*api_model.Component) error

SyncComponentVolumes -

func (*ServiceAction) TenantServiceDeletePluginRelation

func (s *ServiceAction) TenantServiceDeletePluginRelation(tenantID, serviceID, pluginID string) *util.APIHandleError

TenantServiceDeletePluginRelation uninstall plugin for app

func (*ServiceAction) TransServieToDelete

func (s *ServiceAction) TransServieToDelete(ctx context.Context, tenantID, serviceID string) error

TransServieToDelete trans service info to delete table

func (*ServiceAction) UpdAutoscalerRule

func (s *ServiceAction) UpdAutoscalerRule(req *api_model.AutoscalerRuleReq) error

UpdAutoscalerRule -

func (*ServiceAction) UpdVolume

func (s *ServiceAction) UpdVolume(sid string, req *api_model.UpdVolumeReq) error

UpdVolume updates service volume.

func (*ServiceAction) UpdateLabel

func (s *ServiceAction) UpdateLabel(l *api_model.LabelsStruct, serviceID string) error

UpdateLabel updates labels

func (*ServiceAction) UpdateServiceMonitor

func (s *ServiceAction) UpdateServiceMonitor(tenantID, serviceID, name string, update api_model.UpdateServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)

UpdateServiceMonitor update service monitor

func (*ServiceAction) UpdateTenantServicePluginRelation

func (s *ServiceAction) UpdateTenantServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

UpdateTenantServicePluginRelation

func (*ServiceAction) UpdateVersionEnv

func (s *ServiceAction) UpdateVersionEnv(uve *api_model.SetVersionEnv) *util.APIHandleError

UpdateVersionEnv

func (*ServiceAction) VolumeDependency

func (s *ServiceAction) VolumeDependency(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError

VolumeDependency VolumeDependency

func (*ServiceAction) VolumnVar

func (s *ServiceAction) VolumnVar(tsv *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError

VolumnVar var volumn

type ServiceDependency

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

ServiceDependency documents a set of services and their dependencies. provides the ability to build linked lists of dependencies and find circular dependencies.

func NewServiceDependency

func NewServiceDependency(serviceIDs []string) (*ServiceDependency, error)

NewServiceDependency creates a new ServiceDependency.

type ServiceEventHandler

type ServiceEventHandler struct {
}

ServiceEventHandler -

func GetServiceEventHandler

func GetServiceEventHandler() *ServiceEventHandler

GetServiceEventHandler -

func NewServiceEventHandler

func NewServiceEventHandler() *ServiceEventHandler

NewServiceEventHandler -

func (*ServiceEventHandler) ListByEventIDs

func (s *ServiceEventHandler) ListByEventIDs(eventIDs []string) ([]*dbmodel.ServiceEvent, error)

ListByEventIDs -

type ServiceHandler

type ServiceHandler interface {
	ServiceBuild(tenantID, serviceID string, r *api_model.BuildServiceStruct) error
	AddLabel(l *api_model.LabelsStruct, serviceID string) error
	DeleteLabel(l *api_model.LabelsStruct, serviceID string) error
	UpdateLabel(l *api_model.LabelsStruct, serviceID string) error
	StartStopService(s *api_model.StartStopStruct) error
	ServiceVertical(ctx context.Context, v *model.VerticalScalingTaskBody) error
	ServiceHorizontal(h *model.HorizontalScalingTaskBody) error
	ServiceUpgrade(r *model.RollingUpgradeTaskBody) error
	ServiceCreate(ts *api_model.ServiceStruct) error
	ServiceUpdate(sc map[string]interface{}) error
	LanguageSet(langS *api_model.LanguageSet) error
	GetService(tenantID string) ([]*dbmodel.TenantServices, error)
	GetServicesByAppID(appID string, page, pageSize int) (*api_model.ListServiceResponse, error)
	GetPagedTenantRes(offset, len int) ([]*api_model.TenantResource, int, error)
	GetTenantRes(uuid string) (*api_model.TenantResource, error)
	CodeCheck(c *api_model.CheckCodeStruct) error
	ServiceDepend(action string, ds *api_model.DependService) error
	EnvAttr(action string, at *dbmodel.TenantServiceEnvVar) error
	PortVar(action string, tenantID, serviceID string, vp *api_model.ServicePorts, oldPort int) error
	CreatePorts(tenantID, serviceID string, vps *api_model.ServicePorts) error
	PortOuter(tenantName, serviceID string, containerPort int, servicePort *api_model.ServicePortInnerOrOuter) (*dbmodel.TenantServiceLBMappingPort, string, error)
	PortInner(tenantName, serviceID, operation string, port int) error
	VolumnVar(avs *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError
	UpdVolume(sid string, req *api_model.UpdVolumeReq) error
	VolumeDependency(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError
	GetDepVolumes(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError)
	GetVolumes(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError)
	ServiceProbe(tsp *dbmodel.TenantServiceProbe, action string) error
	RollBack(rs *api_model.RollbackStruct) error
	GetStatus(serviceID string) (*api_model.StatusList, error)
	GetServicesStatus(tenantID string, services []string) []map[string]interface{}
	GetEnterpriseRunningServices(enterpriseID string) ([]string, *util.APIHandleError)
	CreateTenant(*dbmodel.Tenants) error
	CreateTenandIDAndName(eid string) (string, string, error)
	GetPods(serviceID string) (*K8sPodInfos, error)
	GetMultiServicePods(serviceIDs []string) (*K8sPodInfos, error)
	GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)
	TransServieToDelete(ctx context.Context, tenantID, serviceID string) error
	TenantServiceDeletePluginRelation(tenantID, serviceID, pluginID string) *util.APIHandleError
	GetTenantServicePluginRelation(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
	SetTenantServicePluginRelation(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
	UpdateTenantServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
	UpdateVersionEnv(uve *api_model.SetVersionEnv) *util.APIHandleError
	DeletePluginConfig(serviceID, pluginID string) *util.APIHandleError
	ServiceCheck(*api_model.ServiceCheckStruct) (string, string, *util.APIHandleError)
	GetServiceCheckInfo(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError)
	GetServiceDeployInfo(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError)
	ListVersionInfo(serviceID string) (*api_model.BuildListRespVO, error)

	AddAutoscalerRule(req *api_model.AutoscalerRuleReq) error
	UpdAutoscalerRule(req *api_model.AutoscalerRuleReq) error
	ListScalingRecords(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error)

	UpdateServiceMonitor(tenantID, serviceID, name string, update api_model.UpdateServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)
	DeleteServiceMonitor(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error)
	AddServiceMonitor(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)

	SyncComponentBase(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentMonitors(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentPorts(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentRelations(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentEnvs(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentVolumeRels(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentVolumes(tx *gorm.DB, components []*api_model.Component) error
	SyncComponentConfigFiles(tx *gorm.DB, components []*api_model.Component) error
	SyncComponentProbes(tx *gorm.DB, components []*api_model.Component) error
	SyncComponentLabels(tx *gorm.DB, components []*api_model.Component) error
	SyncComponentPlugins(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
	SyncComponentScaleRules(tx *gorm.DB, components []*api_model.Component) error
	SyncComponentEndpoints(tx *gorm.DB, components []*api_model.Component) error

	Log(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, podName, containerName string, follow bool) error
}

ServiceHandler service handler

func GetServiceManager

func GetServiceManager() ServiceHandler

GetServiceManager get manager

type TenantAction

type TenantAction struct {
	MQClient mqclient.MQClient

	OptCfg *option.Config
	// contains filtered or unexported fields
}

TenantAction tenant act

func CreateTenManager

func CreateTenManager(mqc mqclient.MQClient, statusCli *client.AppRuntimeSyncClient,
	optCfg *option.Config,
	kubeClient *kubernetes.Clientset,
	prometheusCli prometheus.Interface,
	k8sClient k8sclient.Client) *TenantAction

CreateTenManager create Manger

func (*TenantAction) BindTenantsResource

func (t *TenantAction) BindTenantsResource(source []*dbmodel.Tenants) api_model.TenantList

BindTenantsResource query tenant resource used and sort

func (*TenantAction) CheckResourceName

func (t *TenantAction) CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)

CheckResourceName checks resource name.

func (*TenantAction) DeleteTenant

func (t *TenantAction) DeleteTenant(ctx context.Context, tenantID string) error

DeleteTenant deletes tenant based on the given tenantID.

tenant can only be deleted without service or plugin

func (*TenantAction) GetAllocatableResources

func (t *TenantAction) GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error)

GetAllocatableResources returns allocatable cpu and memory (MB)

func (*TenantAction) GetClusterResource

func (t *TenantAction) GetClusterResource(ctx context.Context) *ClusterResourceStats

GetClusterResource get cluster resource

func (*TenantAction) GetProtocols

func (t *TenantAction) GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError)

GetProtocols GetProtocols

func (*TenantAction) GetServicesResources

func (t *TenantAction) GetServicesResources(tr *api_model.ServicesResources) (re map[string]map[string]interface{}, err error)

GetServicesResources Gets the resource usage of the specified service.

func (*TenantAction) GetServicesStatus

func (t *TenantAction) GetServicesStatus(ids string) map[string]string

GetServicesStatus returns a list of service status matching ids.

func (*TenantAction) GetTenantResource

func (t *TenantAction) GetTenantResource(tenantID string) (ts TenantResourceStats, err error)

GetTenantResource get tenant resource

func (*TenantAction) GetTenants

func (t *TenantAction) GetTenants(query string) ([]*dbmodel.Tenants, error)

GetTenants get tenants

func (*TenantAction) GetTenantsByEid

func (t *TenantAction) GetTenantsByEid(eid, query string) ([]*dbmodel.Tenants, error)

GetTenantsByEid GetTenantsByEid

func (*TenantAction) GetTenantsByName

func (t *TenantAction) GetTenantsByName(name string) (*dbmodel.Tenants, error)

GetTenantsByName get tenants

func (*TenantAction) GetTenantsByUUID

func (t *TenantAction) GetTenantsByUUID(uuid string) (*dbmodel.Tenants, error)

GetTenantsByUUID get tenants

func (*TenantAction) GetTenantsName

func (t *TenantAction) GetTenantsName() ([]string, error)

GetTenantsName get tenants name

func (*TenantAction) GetTenantsResources

func (t *TenantAction) GetTenantsResources(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error)

GetTenantsResources Gets the resource usage of the specified tenant.

func (*TenantAction) IsClosedStatus

func (t *TenantAction) IsClosedStatus(status string) bool

IsClosedStatus checks if the status is closed status.

func (*TenantAction) StatsMemCPU

func (t *TenantAction) StatsMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

StatsMemCPU StatsMemCPU

func (*TenantAction) TenantsSum

func (t *TenantAction) TenantsSum() (int, error)

TenantsSum TenantsSum

func (*TenantAction) TotalMemCPU

func (t *TenantAction) TotalMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

TotalMemCPU StatsMemCPU

func (*TenantAction) TransPlugins

func (t *TenantAction) TransPlugins(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError

TransPlugins TransPlugins

func (*TenantAction) UpdateTenant

func (t *TenantAction) UpdateTenant(tenant *dbmodel.Tenants) error

UpdateTenant update tenant info

type TenantHandler

type TenantHandler interface {
	GetTenants(query string) ([]*dbmodel.Tenants, error)
	GetTenantsByName(name string) (*dbmodel.Tenants, error)
	GetTenantsByEid(eid, query string) ([]*dbmodel.Tenants, error)
	GetTenantsByUUID(uuid string) (*dbmodel.Tenants, error)
	GetTenantsName() ([]string, error)
	StatsMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)
	TotalMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)
	GetTenantsResources(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error)
	GetTenantResource(tenantID string) (TenantResourceStats, error)
	GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error)
	GetServicesResources(tr *api_model.ServicesResources) (map[string]map[string]interface{}, error)
	TenantsSum() (int, error)
	GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError)
	TransPlugins(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError
	GetServicesStatus(ids string) map[string]string
	IsClosedStatus(status string) bool
	BindTenantsResource(source []*dbmodel.Tenants) api_model.TenantList
	UpdateTenant(*dbmodel.Tenants) error
	DeleteTenant(ctx context.Context, tenantID string) error
	GetClusterResource(ctx context.Context) *ClusterResourceStats
	CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)
}

TenantHandler tenant handler

func GetTenantManager

func GetTenantManager() TenantHandler

GetTenantManager get manager

type TenantResourceStats

type TenantResourceStats struct {
	TenantID         string `json:"tenant_id,omitempty"`
	CPURequest       int64  `json:"cpu_request,omitempty"`
	CPULimit         int64  `json:"cpu_limit,omitempty"`
	MemoryRequest    int64  `json:"memory_request,omitempty"`
	MemoryLimit      int64  `json:"memory_limit,omitempty"`
	RunningAppNum    int64  `json:"running_app_num"`
	UnscdCPUReq      int64  `json:"unscd_cpu_req,omitempty"`
	UnscdCPULimit    int64  `json:"unscd_cpu_limit,omitempty"`
	UnscdMemoryReq   int64  `json:"unscd_memory_req,omitempty"`
	UnscdMemoryLimit int64  `json:"unscd_memory_limit,omitempty"`
}

TenantResourceStats tenant resource stats

type ThirdPartyServiceHanlder

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

ThirdPartyServiceHanlder handles business logic for all third-party services

func Create3rdPartySvcHandler

func Create3rdPartySvcHandler(dbmanager db.Manager, statusCli *client.AppRuntimeSyncClient) *ThirdPartyServiceHanlder

Create3rdPartySvcHandler creates a new *ThirdPartyServiceHanlder.

func Get3rdPartySvcHandler

func Get3rdPartySvcHandler() *ThirdPartyServiceHanlder

Get3rdPartySvcHandler returns the defalut ThirdParthServiceHanlder

func (*ThirdPartyServiceHanlder) AddEndpoints

func (t *ThirdPartyServiceHanlder) AddEndpoints(sid string, d *model.AddEndpiontsReq) error

AddEndpoints adds endpoints for third-party service.

func (*ThirdPartyServiceHanlder) DelEndpoints

func (t *ThirdPartyServiceHanlder) DelEndpoints(epid, sid string) error

DelEndpoints deletes endpoints for third-party service.

func (*ThirdPartyServiceHanlder) ListEndpoints

func (t *ThirdPartyServiceHanlder) ListEndpoints(componentID string) ([]*model.ThirdEndpoint, error)

ListEndpoints lists third-party service endpoints.

func (*ThirdPartyServiceHanlder) UpdEndpoints

UpdEndpoints updates endpoints for third-party service.

type TokenIdenAction

type TokenIdenAction struct{}

TokenIdenAction

func CreateTokenIdenManager

func CreateTokenIdenManager(conf option.Config) (*TokenIdenAction, error)

CreateTokenIdenManager token identification

func (*TokenIdenAction) AddAPIManager

func (t *TokenIdenAction) AddAPIManager(am *api_model.APIManager) *util.APIHandleError

AddAPIManager

func (*TokenIdenAction) AddTokenIntoMap

func (t *TokenIdenAction) AddTokenIntoMap(rui *dbmodel.RegionUserInfo)

AddTokenIntoMap

func (*TokenIdenAction) CheckToken

func (t *TokenIdenAction) CheckToken(token, uri string) bool

CheckToken

func (*TokenIdenAction) DeleteAPIManager

func (t *TokenIdenAction) DeleteAPIManager(am *api_model.APIManager) *util.APIHandleError

DeleteAPIManager

func (*TokenIdenAction) DeleteTokenFromMap

func (t *TokenIdenAction) DeleteTokenFromMap(oldtoken string, rui *dbmodel.RegionUserInfo)

DeleteTokenFromMap

func (*TokenIdenAction) GetAPIManager

func (t *TokenIdenAction) GetAPIManager() map[string][]*dbmodel.RegionAPIClass

GetAPIManager

func (*TokenIdenAction) InitTokenMap

func (t *TokenIdenAction) InitTokenMap() error

InitTokenMap

type TokenMap

type TokenMap map[string]*dbmodel.RegionUserInfo

TokenMap

type TokenMapHandler

type TokenMapHandler interface {
	AddTokenIntoMap(rui *dbmodel.RegionUserInfo)
	DeleteTokenFromMap(oldtoken string, rui *dbmodel.RegionUserInfo)
	CheckToken(token, uri string) bool
	GetAPIManager() map[string][]*dbmodel.RegionAPIClass
	AddAPIManager(am *api_model.APIManager) *util.APIHandleError
	DeleteAPIManager(am *api_model.APIManager) *util.APIHandleError
	InitTokenMap() error
}

TokenMapHandler DefaultTokenMapHandler

func GetTokenIdenHandler

func GetTokenIdenHandler() TokenMapHandler

GetTokenIdenHandler

type VersionInfo

type VersionInfo struct {
	Version []*LangInfo `json:"version"`
}

VersionInfo VersionInfo

type VolumeTypeAction

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

VolumeTypeAction action

func CreateVolumeTypeManger

func CreateVolumeTypeManger(statusCli *client.AppRuntimeSyncClient) *VolumeTypeAction

CreateVolumeTypeManger create VolumeType manager

func (*VolumeTypeAction) DeleteVolumeType

func (vta *VolumeTypeAction) DeleteVolumeType(volumeType string) error

DeleteVolumeType delte volume type

func (*VolumeTypeAction) GetAllStorageClasses

func (vta *VolumeTypeAction) GetAllStorageClasses() ([]*pb.StorageClassDetail, error)

GetAllStorageClasses get all storage class

func (*VolumeTypeAction) GetAllVolumeTypes

func (vta *VolumeTypeAction) GetAllVolumeTypes() ([]*api_model.VolumeTypeStruct, error)

GetAllVolumeTypes get all volume types

func (*VolumeTypeAction) GetAllVolumeTypesByPage

func (vta *VolumeTypeAction) GetAllVolumeTypesByPage(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error)

GetAllVolumeTypesByPage get all volume types by page

func (*VolumeTypeAction) GetVolumeTypeByType

func (vta *VolumeTypeAction) GetVolumeTypeByType(volumtType string) (*dbmodel.TenantServiceVolumeType, error)

GetVolumeTypeByType get volume type by type

func (*VolumeTypeAction) SetVolumeType

func (vta *VolumeTypeAction) SetVolumeType(vol *api_model.VolumeTypeStruct) error

SetVolumeType set volume type

func (*VolumeTypeAction) UpdateVolumeType

func (vta *VolumeTypeAction) UpdateVolumeType(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error

UpdateVolumeType

func (*VolumeTypeAction) VolumeTypeAction

func (vta *VolumeTypeAction) VolumeTypeAction(action, volumeTypeID string) error

VolumeTypeAction open volme type or close it

func (*VolumeTypeAction) VolumeTypeVar

func (vta *VolumeTypeAction) VolumeTypeVar(action string, vtm *dbmodel.TenantServiceVolumeType) error

VolumeTypeVar volume type crud

type VolumeTypeHandler

type VolumeTypeHandler interface {
	VolumeTypeVar(action string, vtm *dbmodel.TenantServiceVolumeType) error
	GetAllVolumeTypes() ([]*api_model.VolumeTypeStruct, error)
	GetAllVolumeTypesByPage(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error)
	GetVolumeTypeByType(volumeType string) (*dbmodel.TenantServiceVolumeType, error)
	GetAllStorageClasses() ([]*pb.StorageClassDetail, error)
	VolumeTypeAction(action, volumeTypeID string) error
	DeleteVolumeType(volumeTypeID string) error
	SetVolumeType(vtm *api_model.VolumeTypeStruct) error
	UpdateVolumeType(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error
}

VolumeTypeHandler LicenseAction

func GetVolumeTypeHandler

func GetVolumeTypeHandler() VolumeTypeHandler

GetVolumeTypeHandler get volumeType handler

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL