handler

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

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

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

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

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
}

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

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

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

type GatewayHandler interface {
	AddHTTPRule(req *apimodel.AddHTTPRuleStruct) (string, error)
	UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) (string, error)
	DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) (string, 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)

	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
}

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"`
}

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"`
}

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

type LicenseAction struct{}

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

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

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

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

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

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

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

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
}

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

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"`
}

type PluginAction struct {
	MQClient client.MQClient
}

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

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

type RootAction struct{}

type RootFuncHandler interface {
}

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

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

type TenantAction struct {
	MQClient pb.TaskQueueClient

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

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
}

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"`
}

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

type TokenIdenAction struct{}

type TokenMap map[string]*dbmodel.RegionUserInfo

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
}

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