rainbond: github.com/goodrain/rainbond/api/handler Index | Files | Directories

package handler

import "github.com/goodrain/rainbond/api/handler"

Index

Package Files

EventLogHandler.go LicenseHandler.go PluginHandler.go TenantHandler.go app.go app_restore_action.go app_restore_handler.go cloud.go cloudHandler.go event.go eventLog.go gateway_action.go gateway_handler.go handler.go license.go license_pack.go netRules.go netRulesHandler.go plugin.go proxy.go rootFunc.go rootFuncHandler.go service.go service_batch_operation.go service_check.go service_handler.go service_operation.go service_plugin.go tenant.go third_party_service_handler.go tokenIden.go tokenIdenHandler.go

Constants

const TIMELAYOUT = "2006-01-02T15:04:05"

TIMELAYOUT timelayout

Variables

var ErrEventIDIsExist = fmt.Errorf("event_id is exist")

ErrEventIDIsExist event id is exist

var ErrEventIsRuning = fmt.Errorf("event is running")

ErrEventIsRuning last event is running

func BasePack Uses

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

BasePack base pack

func CheckLabel Uses

func CheckLabel(serviceID string) bool

CheckLabel check label

func CheckMapKey Uses

func CheckMapKey(rebody map[string]interface{}, key string, defaultValue interface{}) map[string]interface{}

CheckMapKey CheckMapKey

func CreateDefaultTokenMap Uses

func CreateDefaultTokenMap(conf option.Config)

CreateDefaultTokenMap CreateDefaultTokenMap

func CreateLicenseManger Uses

func CreateLicenseManger() error

CreateLicenseManger create service manager

func CreateLicensesInfoManager Uses

func CreateLicensesInfoManager() error

CreateLicensesInfoManager CreateLicensesInfoManager

func CreateRootFuncHandler Uses

func CreateRootFuncHandler(conf option.Config) error

CreateRootFuncHandler create root func handler

func CreateTokenIdenHandler Uses

func CreateTokenIdenHandler(conf option.Config) error

CreateTokenIdenHandler create token identification handler

func GetAPPBackupHandler Uses

func GetAPPBackupHandler() *group.BackupHandle

GetAPPBackupHandler GetAPPBackupHandler

func GetBuilderProxy Uses

func GetBuilderProxy() proxy.Proxy

GetBuilderProxy GetNodeProxy

func GetDefaultSourceURI Uses

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

GetDefaultSourceURI GetDefaultSourceURI

func GetDefaultTokenMap Uses

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

GetDefaultTokenMap GetDefaultTokenMap

func GetMonitorProxy Uses

func GetMonitorProxy() proxy.Proxy

GetMonitorProxy GetMonitorProxy

func GetNodeProxy Uses

func GetNodeProxy() proxy.Proxy

GetNodeProxy GetNodeProxy

func GetPluginShareHandle Uses

func GetPluginShareHandle() *share.PluginShareHandle

GetPluginShareHandle get plugin share handle

func GetPrometheusProxy Uses

func GetPrometheusProxy() proxy.Proxy

GetPrometheusProxy GetPrometheusProxy

func GetServicesDisk Uses

func GetServicesDisk(ids []string, p proxy.Proxy) map[string]float64

GetServicesDisk get service disk

func GetShareHandle Uses

func GetShareHandle() *share.ServiceShareHandle

GetShareHandle get share handle

func InitHandle Uses

func InitHandle(conf option.Config, statusCli *client.AppRuntimeSyncClient) error

InitHandle 初始化handle

func InitProxy Uses

func InitProxy(conf option.Config)

InitProxy 初始化

func ListLicense Uses

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

ListLicense lise license

func SetTokenCache Uses

func SetTokenCache(info *dbmodel.RegionUserInfo)

SetTokenCache SetTokenCache

func TransStatus Uses

func TransStatus(eStatus string) string

TransStatus trans service status

type AppAction Uses

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

AppAction app action

func CreateAppManager Uses

func CreateAppManager(mqClient client.MQClient) *AppAction

CreateAppManager create app manager

func GetAppHandler Uses

func GetAppHandler() *AppAction

GetAppHandler GetAppHandler

func (*AppAction) Complete Uses

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

Complete Complete

func (*AppAction) ExportApp Uses

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

ExportApp ExportApp

func (*AppAction) GetStaticDir Uses

func (a *AppAction) GetStaticDir() string

GetStaticDir get static dir

func (*AppAction) ImportApp Uses

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

ImportApp import app

type AppRestoreAction Uses

type AppRestoreAction struct {
}

AppRestoreAction is an implementation of AppRestoreHandler

func (*AppRestoreAction) RestoreDepVols Uses

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

RestoreDepVols restores service dependent volumes.

func (*AppRestoreAction) RestoreDeps Uses

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

RestoreDeps restores service dependencies.

func (*AppRestoreAction) RestoreEnvs Uses

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

RestoreEnvs restores environment variables.

func (*AppRestoreAction) RestorePlugins Uses

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

RestorePlugins restores service plugins.

func (*AppRestoreAction) RestorePorts Uses

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

RestorePorts restores service ports.

func (*AppRestoreAction) RestoreProbe Uses

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

RestoreProbe restores service probe.

func (*AppRestoreAction) RestoreVolumes Uses

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

RestoreVolumes restores service volumes.

type AppRestoreHandler Uses

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 Uses

func GetAppRestoreHandler() AppRestoreHandler

GetAppRestoreHandler returns a default AppRestoreHandler

func NewAppRestoreHandler Uses

func NewAppRestoreHandler() AppRestoreHandler

NewAppRestoreHandler creates a new AppRestoreHandler.

type BatchOperationHandler Uses

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

BatchOperationHandler batch operation handler

func CreateBatchOperationHandler Uses

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

CreateBatchOperationHandler create batch operation handler

func GetBatchOperationHandler Uses

func GetBatchOperationHandler() *BatchOperationHandler

GetBatchOperationHandler get handler

func (*BatchOperationHandler) Build Uses

func (b *BatchOperationHandler) Build(buildInfos []model.BuildInfoRequestStruct) (re BatchOperationResult)

Build build

func (*BatchOperationHandler) Start Uses

func (b *BatchOperationHandler) Start(startInfos []model.StartOrStopInfoRequestStruct) (re BatchOperationResult)

Start batch start

func (*BatchOperationHandler) Stop Uses

func (b *BatchOperationHandler) Stop(stopInfos []model.StartOrStopInfoRequestStruct) (re BatchOperationResult)

Stop batch stop

func (*BatchOperationHandler) Upgrade Uses

func (b *BatchOperationHandler) Upgrade(upgradeInfos []model.UpgradeInfoRequestStruct) (re BatchOperationResult)

Upgrade batch upgrade

type BatchOperationResult Uses

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

BatchOperationResult batch operation result

type CloudAction Uses

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

CloudAction cloud action struct

func CreateCloudManager Uses

func CreateCloudManager(conf option.Config) *CloudAction

CreateCloudManager get cloud manager

func (*CloudAction) CertDispatcher Uses

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

CertDispatcher Cert

func (*CloudAction) GetTokenInfo Uses

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

GetTokenInfo GetTokenInfo

func (*CloudAction) TokenDispatcher Uses

func (c *CloudAction) TokenDispatcher(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError)

TokenDispatcher token

func (*CloudAction) UpdateTokenTime Uses

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

UpdateTokenTime UpdateTokenTime

type CloudHandler Uses

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 Uses

func GetCloudManager() CloudHandler

GetCloudManager get manager

type ClusterResourceStats Uses

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

ClusterResourceStats cluster resource stats

type EventHandler Uses

type EventHandler interface {
    GetLinesLogs(alias string, n int) ([]byte, error)
    GetLogList(serviceAlias string) ([]string, error)
    GetLogInstance(serviceID string) (string, error)
    GetLevelLog(eventID string, level string) (*api_model.DataLog, error)
    GetLogFile(serviceAlias, fileName string) (string, string, error)
}

EventHandler event handler interface

func GetEventHandler Uses

func GetEventHandler() EventHandler

GetEventHandler get event handler

type GatewayAction Uses

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

GatewayAction -

func CreateGatewayManager Uses

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

CreateGatewayManager creates gateway manager.

func (*GatewayAction) AddCertificate Uses

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

AddCertificate adds certificate to db if it doesn't exists

func (*GatewayAction) AddHTTPRule Uses

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

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

func (*GatewayAction) AddIPPool Uses

func (g *GatewayAction) AddIPPool(req *apimodel.IPPoolStruct) error

AddIPPool adds AddIPPool

func (*GatewayAction) AddRuleExtensions Uses

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 Uses

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

AddTCPRule adds tcp rule.

func (*GatewayAction) DeleteHTTPRule Uses

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

DeleteHTTPRule deletes http rule, including certificate and rule extensions

func (*GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction Uses

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

DeleteHTTPRuleByServiceIDWithTransaction deletes http rule, including certificate and rule extensions

func (*GatewayAction) DeleteTCPRule Uses

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

DeleteTCPRule deletes a tcp rule

func (*GatewayAction) DeleteTCPRuleByServiceIDWithTransaction Uses

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

DeleteTCPRuleByServiceIDWithTransaction deletes a tcp rule

func (*GatewayAction) GetAvailablePort Uses

func (g *GatewayAction) GetAvailablePort() (int, error)

GetAvailablePort returns a available port

func (*GatewayAction) PortExists Uses

func (g *GatewayAction) PortExists(port int) bool

PortExists returns if the port exists

func (*GatewayAction) RuleConfig Uses

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

RuleConfig -

func (*GatewayAction) SendTask Uses

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

SendTask sends apply rules task

func (*GatewayAction) TCPAvailable Uses

func (g *GatewayAction) TCPAvailable(ip string, port int, ruleID string) bool

TCPAvailable checks if the ip and port for TCP is available.

func (*GatewayAction) UpdateCertificate Uses

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

UpdateCertificate updates certificate for http rule

func (*GatewayAction) UpdateHTTPRule Uses

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

UpdateHTTPRule updates http rule

func (*GatewayAction) UpdateTCPRule Uses

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

UpdateTCPRule updates a tcp rule

type GatewayHandler Uses

type GatewayHandler interface {
    AddHTTPRule(req *apimodel.AddHTTPRuleStruct) (string, error)
    UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) (string, error)
    DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) (string, 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) (string, error)
    UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) (string, error)
    DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) (string, error)
    DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

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

    GetAvailablePort() (int, error)
    PortExists(port int) bool
    SendTask(in map[string]interface{}) error
    TCPAvailable(ip string, port int, ruleID string) bool
    AddIPPool(req *apimodel.IPPoolStruct) error

    RuleConfig(req *apimodel.RuleConfigReq) error
}

GatewayHandler gateway api handler

func GetGatewayHandler Uses

func GetGatewayHandler() GatewayHandler

GetGatewayHandler returns a default GatewayHandler

type Info Uses

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 信息

func ReadLicenseFromConsole Uses

func ReadLicenseFromConsole(token string, defaultLicense string) (Info, error)

ReadLicenseFromConsole 从控制台api获取license

func ReadLicenseFromFile Uses

func ReadLicenseFromFile(licenseFile string) (Info, error)

ReadLicenseFromFile 从文件获取license

type K8sPodInfo Uses

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

K8sPodInfo for api

type LangInfo Uses

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

LangInfo LangInfo

type LicenseAction Uses

type LicenseAction struct{}

LicenseAction LicenseAction

func (*LicenseAction) PackLicense Uses

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

PackLicense PackLicense

func (*LicenseAction) StoreLicense Uses

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

StoreLicense StoreLicense

type LicenseHandler Uses

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

LicenseHandler LicenseAction

func GetLicenseHandler Uses

func GetLicenseHandler() LicenseHandler

GetLicenseHandler get license handler

type LicenseInfoHandler Uses

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

LicenseInfoHandler LicenseInfoHandler

func GetLicensesInfosHandler Uses

func GetLicensesInfosHandler() LicenseInfoHandler

GetLicensesInfosHandler GetLicensesInfosHandler

type LicensesInfos Uses

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

LicensesInfos LicensesInfos 验证

func (*LicensesInfos) ShowInfos Uses

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

ShowInfos ShowInfos

type LogAction Uses

type LogAction struct {
    EtcdEndpoints []string
    // contains filtered or unexported fields
}

LogAction log action struct

func CreateLogManager Uses

func CreateLogManager(etcdEndpoint []string) *LogAction

CreateLogManager get log manager

func (*LogAction) GetLevelLog Uses

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

GetLevelLog 获取指定操作的操作日志

func (*LogAction) GetLinesLogs Uses

func (l *LogAction) GetLinesLogs(alias string, n int) ([]byte, error)

GetLinesLogs GetLinesLogs

func (*LogAction) GetLogFile Uses

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

GetLogFile GetLogFile

func (*LogAction) GetLogInstance Uses

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

GetLogInstance get log web socket instance

func (*LogAction) GetLogList Uses

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

GetLogList get log list

type MajorInfo Uses

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

MajorInfo MajorInfo

type MinorInfo Uses

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

MinorInfo MinorInfo

type NetRulesAction Uses

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

NetRulesAction rules action struct

func CreateNetRulesManager Uses

func CreateNetRulesManager(etcdCli *clientv3.Client) *NetRulesAction

CreateNetRulesManager get net rules manager

func (*NetRulesAction) CreateDownStreamNetRules Uses

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

CreateDownStreamNetRules CreateDownStreamNetRules

func (*NetRulesAction) GetDownStreamNetRule Uses

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

GetDownStreamNetRule GetDownStreamNetRule

func (*NetRulesAction) UpdateDownStreamNetRule Uses

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

UpdateDownStreamNetRule UpdateDownStreamNetRule

type NetRulesHandler Uses

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 Uses

func GetRulesManager() NetRulesHandler

GetRulesManager get manager

type OperationHandler Uses

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

OperationHandler operation handler

func CreateOperationHandler Uses

func CreateOperationHandler(mqCli gclient.MQClient) *OperationHandler

CreateOperationHandler create operation handler

func GetOperationHandler Uses

func GetOperationHandler() *OperationHandler

GetOperationHandler get handler

func (*OperationHandler) Build Uses

func (o *OperationHandler) Build(buildInfo model.BuildInfoRequestStruct) (re OperationResult)

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

func (*OperationHandler) Restart Uses

func (o *OperationHandler) Restart(restartInfo model.StartOrStopInfoRequestStruct) (re OperationResult)

Restart service restart TODO

func (*OperationHandler) RollBack Uses

func (o *OperationHandler) RollBack(rollback model.RollbackInfoRequestStruct) (re OperationResult)

RollBack service rollback

func (*OperationHandler) Start Uses

func (o *OperationHandler) Start(startInfo model.StartOrStopInfoRequestStruct) (re OperationResult)

Start service start

func (*OperationHandler) Stop Uses

func (o *OperationHandler) Stop(stopInfo model.StartOrStopInfoRequestStruct) (re OperationResult)

Stop service stop

func (*OperationHandler) Upgrade Uses

func (o *OperationHandler) Upgrade(ru model.UpgradeInfoRequestStruct) (re OperationResult)

Upgrade service upgrade

type OperationResult Uses

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 Uses

type PluginAction struct {
    MQClient client.MQClient
}

PluginAction plugin action struct

func CreatePluginManager Uses

func CreatePluginManager(mqClient client.MQClient) *PluginAction

CreatePluginManager get plugin manager

func (*PluginAction) AddDefaultEnv Uses

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

AddDefaultEnv AddDefaultEnv

func (*PluginAction) BuildPluginManual Uses

func (p *PluginAction) BuildPluginManual(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

BuildPluginManual BuildPluginManual

func (*PluginAction) CreatePluginAct Uses

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

CreatePluginAct PluginAct

func (*PluginAction) DeleteDefaultEnv Uses

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

DeleteDefaultEnv DeleteDefaultEnv

func (*PluginAction) DeletePluginAct Uses

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

DeletePluginAct DeletePluginAct

func (*PluginAction) DeletePluginBuildVersion Uses

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

DeletePluginBuildVersion DeletePluginBuildVersion

func (*PluginAction) GetAllPluginBuildVersions Uses

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

GetAllPluginBuildVersions GetAllPluginBuildVersions

func (*PluginAction) GetDefaultEnv Uses

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

GetDefaultEnv GetDefaultEnv

func (*PluginAction) GetEnvsWhichCanBeSet Uses

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

GetEnvsWhichCanBeSet GetEnvsWhichCanBeSet

func (*PluginAction) GetPluginBuildVersion Uses

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

GetPluginBuildVersion GetPluginBuildVersion

func (*PluginAction) GetPlugins Uses

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

GetPlugins get all plugins by tenantID

func (*PluginAction) UpdateDefaultEnv Uses

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

UpdateDefaultEnv UpdateDefaultEnv

func (*PluginAction) UpdatePluginAct Uses

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

UpdatePluginAct UpdatePluginAct

type PluginHandler Uses

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)
}

PluginHandler plugin handler

func GetPluginManager Uses

func GetPluginManager() PluginHandler

GetPluginManager get manager

type QueryResult Uses

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 Uses

type RootAction struct{}

RootAction root function action struct

func CreateRootFuncManager Uses

func CreateRootFuncManager(conf option.Config) *RootAction

CreateRootFuncManager get root func manager

func (*RootAction) ResolvePHP Uses

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

ResolvePHP php 应用构建

type RootFuncHandler Uses

type RootFuncHandler interface {
}

RootFuncHandler root function handler interface

func GetRootFuncHandler Uses

func GetRootFuncHandler() RootFuncHandler

GetRootFuncHandler get root handler

type ServiceAction Uses

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

ServiceAction service act

func CreateManager Uses

func CreateManager(conf option.Config, mqClient gclient.MQClient,
    etcdCli *clientv3.Client, statusCli *client.AppRuntimeSyncClient) *ServiceAction

CreateManager create Manger

func (*ServiceAction) AddLabel Uses

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

AddLabel add labels

func (*ServiceAction) ChangeLBPort Uses

func (s *ServiceAction) ChangeLBPort(tenantID, serviceID string, containerPort, changelbPort int) (*dbmodel.TenantServiceLBMappingPort, *util.APIHandleError)

ChangeLBPort change lb mapping port only support change to existing port in this tenants

func (*ServiceAction) CodeCheck Uses

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

CodeCheck code check

func (*ServiceAction) CreateTenandIDAndName Uses

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

CreateTenandIDAndName create tenant_id and tenant_name

func (*ServiceAction) CreateTenant Uses

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

CreateTenant create tenant

func (*ServiceAction) DeleteLabel Uses

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

DeleteLabel deletes label

func (*ServiceAction) DeletePluginConfig Uses

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

DeletePluginConfig delete service plugin dynamic discovery config

func (*ServiceAction) EnvAttr Uses

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

EnvAttr env attr

func (*ServiceAction) GetDepVolumes Uses

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

GetDepVolumes 获取依赖存储

func (*ServiceAction) GetPagedTenantRes Uses

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

GetPagedTenantRes get pagedTenantServiceRes(s)

func (*ServiceAction) GetPodContainerMemory Uses

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

GetPodContainerMemory Use Prometheus to query memory resources

func (*ServiceAction) GetPods Uses

func (s *ServiceAction) GetPods(serviceID string) ([]*K8sPodInfo, error)

GetPods get pods

func (*ServiceAction) GetService Uses

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

GetService get service(s)

func (*ServiceAction) GetServiceCheckInfo Uses

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

GetServiceCheckInfo get application source detection information

func (*ServiceAction) GetServiceDeployInfo Uses

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

GetServiceDeployInfo get service deploy info

func (*ServiceAction) GetServicesStatus Uses

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

GetServicesStatus 获取一组应用状态,若 serviceIDs为空,获取租户所有应用状态

func (*ServiceAction) GetStatus Uses

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

GetStatus GetStatus

func (*ServiceAction) GetTenantRes Uses

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

GetTenantRes get pagedTenantServiceRes(s)

func (*ServiceAction) GetTenantServicePluginRelation Uses

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

GetTenantServicePluginRelation GetTenantServicePluginRelation

func (*ServiceAction) GetVolumes Uses

func (s *ServiceAction) GetVolumes(serviceID string) ([]*dbmodel.TenantServiceVolume, *util.APIHandleError)

GetVolumes 获取应用全部存储

func (*ServiceAction) LanguageSet Uses

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

LanguageSet language set

func (*ServiceAction) ListVersionInfo Uses

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

ListVersionInfo lists version info

func (*ServiceAction) PortInner Uses

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

PortInner 端口对内服务操作 TODO: send task to worker

func (*ServiceAction) PortOuter Uses

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

PortOuter 端口对外服务操作

func (*ServiceAction) PortVar Uses

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

PortVar port var

func (*ServiceAction) RollBack Uses

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

RollBack RollBack

func (*ServiceAction) SavePluginConfig Uses

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

SavePluginConfig save plugin dynamic discovery config

func (*ServiceAction) ServiceBuild Uses

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

ServiceBuild service build

func (*ServiceAction) ServiceCheck Uses

func (s *ServiceAction) ServiceCheck(scs *api_model.ServiceCheckStruct) (string, string, *util.APIHandleError)

ServiceCheck check service build source

func (*ServiceAction) ServiceCreate Uses

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

ServiceCreate create service

func (*ServiceAction) ServiceDepend Uses

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

ServiceDepend service depend

func (*ServiceAction) ServiceHorizontal Uses

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

ServiceHorizontal Service Horizontal

func (*ServiceAction) ServiceProbe Uses

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

ServiceProbe ServiceProbe

func (*ServiceAction) ServiceUpdate Uses

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

ServiceUpdate update service

func (*ServiceAction) ServiceUpgrade Uses

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

ServiceUpgrade service upgrade

func (*ServiceAction) ServiceVertical Uses

func (s *ServiceAction) ServiceVertical(vs *model.VerticalScalingTaskBody) error

ServiceVertical vertical service

func (*ServiceAction) SetTenantServicePluginRelation Uses

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

SetTenantServicePluginRelation SetTenantServicePluginRelation

func (*ServiceAction) StartStopService Uses

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

StartStopService start service

func (*ServiceAction) TenantServiceDeletePluginRelation Uses

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

TenantServiceDeletePluginRelation uninstall plugin for app

func (*ServiceAction) TransServieToDelete Uses

func (s *ServiceAction) TransServieToDelete(serviceID string) error

TransServieToDelete trans service info to delete table

func (*ServiceAction) UpdVolume Uses

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

UpdVolume updates service volume.

func (*ServiceAction) UpdateLabel Uses

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

UpdateLabel updates labels

func (*ServiceAction) UpdateServiceLabel Uses

func (s *ServiceAction) UpdateServiceLabel(serviceID, value string) error

UpdateServiceLabel UpdateLabel

func (*ServiceAction) UpdateTenantServicePluginRelation Uses

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

UpdateTenantServicePluginRelation UpdateTenantServicePluginRelation

func (*ServiceAction) UpdateVersionEnv Uses

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

UpdateVersionEnv UpdateVersionEnv

func (*ServiceAction) VolumeDependency Uses

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

VolumeDependency VolumeDependency

func (*ServiceAction) VolumnVar Uses

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

VolumnVar var volumn

type ServiceHandler Uses

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
    UpdateServiceLabel(serviceID, value string) error
    StartStopService(s *api_model.StartStopStruct) error
    ServiceVertical(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)
    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
    PortOuter(tenantName, serviceID string, containerPort int, servicePort *api_model.ServicePortInnerOrOuter) (*dbmodel.TenantServiceLBMappingPort, string, error)
    PortInner(tenantName, serviceID, operation string, port int) error
    ChangeLBPort(tenantID, serviceID string, containerPort, changelbPort int) (*dbmodel.TenantServiceLBMappingPort, *util.APIHandleError)
    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) ([]*dbmodel.TenantServiceVolume, *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]string
    CreateTenant(*dbmodel.Tenants) error
    CreateTenandIDAndName(eid string) (string, string, error)
    GetPods(serviceID string) ([]*K8sPodInfo, error)
    TransServieToDelete(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)
}

ServiceHandler service handler

func GetServiceManager Uses

func GetServiceManager() ServiceHandler

GetServiceManager get manager

type TenantAction Uses

type TenantAction struct {
    MQClient pb.TaskQueueClient

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

TenantAction tenant act

func CreateTenManager Uses

func CreateTenManager(MQClient pb.TaskQueueClient, statusCli *client.AppRuntimeSyncClient,
    optCfg *option.Config) *TenantAction

CreateTenManager create Manger

func (*TenantAction) GetAllocatableResources Uses

func (t *TenantAction) GetAllocatableResources() (*ClusterResourceStats, error)

GetAllocatableResources returns allocatable cpu and memory (MB)

func (*TenantAction) GetProtocols Uses

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

GetProtocols GetProtocols

func (*TenantAction) GetServicesResources Uses

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 Uses

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

GetServicesStatus returns a list of service status matching ids.

func (*TenantAction) GetTenantResource Uses

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

GetTenantResource get tenant resource

func (*TenantAction) GetTenants Uses

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

GetTenants get tenants

func (*TenantAction) GetTenantsByEid Uses

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

GetTenantsByEid GetTenantsByEid

func (*TenantAction) GetTenantsByName Uses

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

GetTenantsByName get tenants

func (*TenantAction) GetTenantsByUUID Uses

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

GetTenantsByUUID get tenants

func (*TenantAction) GetTenantsName Uses

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

GetTenantsName get tenants name

func (*TenantAction) GetTenantsPaged Uses

func (t *TenantAction) GetTenantsPaged(offset, len int) ([]*dbmodel.Tenants, error)

GetTenantsPaged GetTenantsPaged

func (*TenantAction) GetTenantsResources Uses

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

GetTenantsResources Gets the resource usage of the specified tenant.

func (*TenantAction) IsClosedStatus Uses

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

IsClosedStatus checks if the status is closed status.

func (*TenantAction) StatsMemCPU Uses

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

StatsMemCPU StatsMemCPU

func (*TenantAction) TenantsSum Uses

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

TenantsSum TenantsSum

func (*TenantAction) TotalMemCPU Uses

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

TotalMemCPU StatsMemCPU

func (*TenantAction) TransPlugins Uses

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

TransPlugins TransPlugins

type TenantHandler Uses

type TenantHandler interface {
    GetTenants() ([]*dbmodel.Tenants, error)
    GetTenantsPaged(offset, len int) ([]*dbmodel.Tenants, error)
    GetTenantsByName(name string) (*dbmodel.Tenants, error)
    GetTenantsByEid(eid 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(tr *api_model.TenantResources) (map[string]map[string]interface{}, error)
    GetTenantResource(tenantID string) (TenantResourceStats, error)
    GetAllocatableResources() (*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
}

TenantHandler tenant handler

func GetTenantManager Uses

func GetTenantManager() TenantHandler

GetTenantManager get manager

type TenantResourceStats Uses

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 Uses

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

ThirdPartyServiceHanlder handles business logic for all third-party services

func Create3rdPartySvcHandler Uses

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

Create3rdPartySvcHandler creates a new *ThirdPartyServiceHanlder.

func Get3rdPartySvcHandler Uses

func Get3rdPartySvcHandler() *ThirdPartyServiceHanlder

Get3rdPartySvcHandler returns the defalut ThirdParthServiceHanlder

func (*ThirdPartyServiceHanlder) AddEndpoints Uses

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

AddEndpoints adds endpoints for third-party service.

func (*ThirdPartyServiceHanlder) DelEndpoints Uses

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

DelEndpoints deletes endpoints for third-party service.

func (*ThirdPartyServiceHanlder) ListEndpoints Uses

func (t *ThirdPartyServiceHanlder) ListEndpoints(sid string) ([]*model.EndpointResp, error)

ListEndpoints lists third-party service endpoints.

func (*ThirdPartyServiceHanlder) UpdEndpoints Uses

func (t *ThirdPartyServiceHanlder) UpdEndpoints(d *model.UpdEndpiontsReq) error

UpdEndpoints updates endpoints for third-party service.

type TokenIdenAction Uses

type TokenIdenAction struct{}

TokenIdenAction TokenIdenAction

func CreateTokenIdenManager Uses

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

CreateTokenIdenManager token identification

func (*TokenIdenAction) AddAPIManager Uses

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

AddAPIManager AddAPIManager

func (*TokenIdenAction) AddTokenIntoMap Uses

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

AddTokenIntoMap AddTokenIntoMap

func (*TokenIdenAction) CheckToken Uses

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

CheckToken CheckToken

func (*TokenIdenAction) DeleteAPIManager Uses

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

DeleteAPIManager DeleteAPIManager

func (*TokenIdenAction) DeleteTokenFromMap Uses

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

DeleteTokenFromMap DeleteTokenFromMap

func (*TokenIdenAction) GetAPIManager Uses

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

GetAPIManager GetAPIManager

func (*TokenIdenAction) InitTokenMap Uses

func (t *TokenIdenAction) InitTokenMap() error

InitTokenMap InitTokenMap

type TokenMap Uses

type TokenMap map[string]*dbmodel.RegionUserInfo

TokenMap TokenMap

type TokenMapHandler Uses

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 Uses

func GetTokenIdenHandler() TokenMapHandler

GetTokenIdenHandler GetTokenIdenHandler

type VersionInfo Uses

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

VersionInfo VersionInfo

Directories

PathSynopsis
cloud
group
share

Package handler imports 56 packages (graph) and is imported by 5 packages. Updated 2019-07-21. Refresh now. Tools for package owners.