Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/FinVolution/stargate
/ functions
Functions
999 in github.com/FinVolution/stargate
⨍
Functions
999
◇
Types & classes
313
↓ 374 callers
Method
getName
()
gate-server/src/main/java/com/ppdai/stargate/job/IHandler.java:5
↓ 222 callers
Method
getMessage
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:76
↓ 166 callers
Method
error
(String message, T detail)
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:52
↓ 154 callers
Method
newException
(MessageType msgType, String message, Object... params)
gate-server/src/main/java/com/ppdai/stargate/exception/BaseException.java:33
↓ 128 callers
Method
add
(List<DnsDto> recordDtoList)
gate-server/src/main/java/com/ppdai/stargate/service/DnsService.java:31
↓ 118 callers
Method
getEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:61
↓ 103 callers
Method
put
(String url, String body)
gate-server/src/main/java/com/ppdai/stargate/client/JsonHttpClient.java:92
↓ 96 callers
Method
get
查询实例 @param request @return
gate-server/src/main/java/com/ppdai/stargate/service/cloud/CloudInstanceService.java:394
↓ 63 callers
Method
get
(String url)
gate-server/src/main/java/com/ppdai/stargate/client/JsonHttpClient.java:202
↓ 53 callers
Method
mark
(MessageType type)
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:10
↓ 52 callers
Method
getZone
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:486
↓ 51 callers
Method
add
(@RequestBody CreateDnsRequest request)
gate-server/src/main/java/com/ppdai/stargate/controller/DnsController.java:30
↓ 46 callers
Method
convert
(S s, Class<T> tClass)
gate-server/src/main/java/com/ppdai/stargate/utils/ConvertUtil.java:17
↓ 38 callers
Method
success
(T detail)
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:44
↓ 27 callers
Method
getCode
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:68
↓ 25 callers
Method
getGroupById
获取指定站点发布组信息 @param groupId 指定的发布组ID @return 返回站点发布组实体信息
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:272
↓ 22 callers
Method
saveInstance
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:76
↓ 19 callers
Method
getAppByCmdbId
(String appCmdbId)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:191
↓ 17 callers
Method
getK8sClientByZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:51
↓ 16 callers
Method
createJobWithTasks
创建任务 @param jobInfo 任务信息 @return 返回创建后的任务信息
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:53
↓ 16 callers
Method
getJobInfoById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:117
↓ 15 callers
Method
findByName
(String instanceName)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:38
↓ 15 callers
Method
getMsg
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/MessageType.java:21
↓ 14 callers
Method
getInstance
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:34
↓ 13 callers
Method
execute
(T t)
gate-server/src/main/java/com/ppdai/stargate/job/IHandler.java:7
↓ 13 callers
Method
fetchZonesByEnv
获取指定环境的zone列表 @param env 环境名 @return
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:91
↓ 13 callers
Method
findOne
(Long id)
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:13
↓ 13 callers
Method
hasInProcessTasksByInstance
(Long instanceId)
gate-server/src/main/java/com/ppdai/stargate/manager/TaskManager.java:70
↓ 12 callers
Method
get
(@RequestBody GetJobRequest request)
gate-server/src/main/java/com/ppdai/stargate/controller/api/JobApiController.java:39
↓ 12 callers
Method
getDescription
()
gate-server/src/main/java/com/ppdai/stargate/constant/JobTypeEnum.java:13
↓ 12 callers
Method
post
(String url, Object reqObj)
gate-server/src/main/java/com/ppdai/stargate/client/JsonHttpClient.java:26
↓ 11 callers
Method
checkJwtToken
(HttpServletRequest httpServletRequest)
gate-server/src/main/java/com/ppdai/stargate/utils/TokenValidator.java:23
↓ 11 callers
Method
getInstancesByGroupId
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:68
↓ 10 callers
Method
fetchZoneNamesByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/ZoneService.java:32
↓ 10 callers
Method
findByPodName
(String podName)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:12
↓ 9 callers
Method
getAppDomainByEnv
(String appCmdbId, String env)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:195
↓ 8 callers
Method
findAll
()
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:37
↓ 7 callers
Method
findById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/dao/IpRepository.java:18
↓ 7 callers
Method
get
(@RequestBody GetInstanceRequest request)
gate-server/src/main/java/com/ppdai/stargate/controller/api/InstanceApiController.java:48
↓ 7 callers
Method
getInstanceStatus
向Remote Registry中查看实例运行状态 @return 返回服务器实例列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteRegistry.java:37
↓ 7 callers
Method
toStringIfNotEmpty
(T t, String defaultStr)
gate-server/src/main/java/com/ppdai/stargate/utils/Strings.java:17
↓ 7 callers
Method
updateJob
更新任务结果 @param jobInfo 任务信息 @return 返回更新后的任务信息
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:101
↓ 6 callers
Method
addSyncInstanceJob
同步发布组内实例任务状态 @param operatorType @param groupId @param jobIdList @return
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:60
↓ 6 callers
Method
buildFlinkResponse
(String response)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:193
↓ 6 callers
Method
findByAppId
(String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:44
↓ 6 callers
Method
findRecentUsedImages
(String env, String appId, List<String> operationTypes, Pageable pageable)
gate-server/src/main/java/com/ppdai/stargate/dao/JobRepository.java:35
↓ 6 callers
Method
getConsulClient
(String env, String appId, String appName)
gate-server/src/main/java/com/ppdai/stargate/remote/impl/RemoteConsul.java:25
↓ 6 callers
Method
getLimitMemory
Memory配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:28
↓ 6 callers
Method
getTaskInfosByJobId
(Long jobId)
gate-server/src/main/java/com/ppdai/stargate/manager/TaskManager.java:48
↓ 6 callers
Method
getUpstream
(String domain)
gate-server/src/main/java/com/ppdai/stargate/remote/impl/RemoteConsul.java:24
↓ 6 callers
Method
stringToJsonObject
(String str)
gate-server/src/main/java/com/ppdai/stargate/utils/Strings.java:22
↓ 5 callers
Method
buildProxyResponse
(Request request)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:173
↓ 5 callers
Method
convert
(JobEntity jobEntity)
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:141
↓ 5 callers
Method
deployUpdateRestartDestroy
(String name, int port,
gate-server/src/test/java/com/ppdai/stargate/service/cloud/CloudInstanceServiceTest.java:77
↓ 5 callers
Method
findAllInstances
()
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:17
↓ 5 callers
Method
findByIp
(String ip)
gate-server/src/main/java/com/ppdai/stargate/dao/IpRepository.java:21
↓ 5 callers
Method
findUnoccupiedIp
(String network)
gate-server/src/main/java/com/ppdai/stargate/dao/IpRepository.java:27
↓ 5 callers
Method
formatInstanceName
获取机器实例的名字,名字格式为:应用ID + 发布组名 + 实例index,其中实例index需要增1 该命名规范保证了实例名字的唯一性,并和PAAS实例命名保持一致 @param groupName 应用发布组ID @param index 实例在应用发布组中的index @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:88
↓ 5 callers
Method
formatNamespace
(String department)
gate-server/src/main/java/com/ppdai/stargate/utils/NamingUtil.java:28
↓ 5 callers
Method
getApplication
(String appId)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:46
↓ 5 callers
Method
getInstances
(String upstream)
gate-server/src/main/java/com/ppdai/stargate/client/ConsulClient.java:48
↓ 5 callers
Method
getK8sMasterRpcUrl
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:113
↓ 5 callers
Method
getRemoteRegistryByDomain
(String domain)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteRegistryManager.java:17
↓ 5 callers
Method
occupy
(String ip)
gate-server/src/main/java/com/ppdai/stargate/dao/IpRepository.java:14
↓ 5 callers
Method
updateTask
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/manager/TaskManager.java:42
↓ 4 callers
Method
checkGroupInstances
操作发布组实例时检查实例是否属于发布组 @param groupId @param instanceNames
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:171
↓ 4 callers
Method
checkSiteQuota
检查站点的配额是否足够 @param countOfInstanceApply 站点待申请的实例配额 @param instanceSpec 发布的实例规格
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:188
↓ 4 callers
Method
deploy
(@RequestBody DeployInstanceRequest request, HttpServletRequest httpServletRequest)
gate-server/src/main/java/com/ppdai/stargate/controller/api/InstanceApiController.java:152
↓ 4 callers
Method
fetchAppQuotasByAppAndEnv
根据应用Id和环境名获取配额列表 @param appId 应用Id @param environment 环境名 @return 返回配额列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:39
↓ 4 callers
Method
fetchNetworkByZoneAndEnv
(String zone, String env)
gate-server/src/main/java/com/ppdai/stargate/service/ZoneService.java:59
↓ 4 callers
Method
findAvailableStaticResourcesByZone
(String appId, String env, String spec, String zone)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:21
↓ 4 callers
Method
findByEnvAndAppId
(String env, String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:17
↓ 4 callers
Method
getImagesByAppName
获取指定应用的镜像列表 @param appName 应用名 @return 返回镜像列表
gate-server/src/main/java/com/ppdai/stargate/service/ImageService.java:61
↓ 4 callers
Method
getJobCountByEnvAndStatus
(String env, JobStatus jobStatus)
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:181
↓ 4 callers
Method
getLocalIP
()
gate-server/src/main/java/com/ppdai/stargate/utils/IPUtil.java:50
↓ 4 callers
Method
getRemoteRegistry
(String domain)
gate-server/src/main/java/com/ppdai/stargate/service/TrafficService.java:21
↓ 4 callers
Method
getUpstreamUrlPrefix
(String upstream)
gate-server/src/main/java/com/ppdai/stargate/client/ConsulClient.java:18
↓ 4 callers
Method
getUsername
()
gate-server/src/main/java/com/ppdai/stargate/utils/UserInfoUtil.java:10
↓ 4 callers
Method
ifAppEnableStaticResource
(String appId, String env)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:482
↓ 4 callers
Method
localIP
()
gate-server/src/main/java/com/ppdai/stargate/utils/IPUtil.java:54
↓ 4 callers
Method
log
查询实例日志 @param request @return
gate-server/src/main/java/com/ppdai/stargate/service/cloud/CloudInstanceService.java:481
↓ 4 callers
Method
queryAllPods
查询所有namespace的Pods @param fieldSelectorMap @return @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:461
↓ 4 callers
Method
queryAppPods
查询指定namespace的Pods @param namespace @return @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:440
↓ 3 callers
Method
checkPullInInstance
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:295
↓ 3 callers
Method
checkPullInInstances
缩容时检查实例是否接入流量 操作实例时检查实例是否接入流量 @param groupEntity @param instanceNames 实例名列表
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:144
↓ 3 callers
Method
createConfigMap
(String namespace, String configName, Map<String, String> dataMap)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:380
↓ 3 callers
Method
createExecuteThreadPool
()
gate-server/src/main/java/com/ppdai/stargate/job/JobExecuteConfig.java:20
↓ 3 callers
Method
createNamespace
创建namespace @param namespace @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:358
↓ 3 callers
Method
delete
(String url, Map<String, String> headers)
gate-server/src/main/java/com/ppdai/stargate/client/JsonHttpClient.java:143
↓ 3 callers
Method
deleteConfigMap
(String namespace, String configName)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:415
↓ 3 callers
Method
destroy
(@PathVariable(value = "groupId") Long groupId)
gate-server/src/main/java/com/ppdai/stargate/controller/flink/FlinkGroupController.java:205
↓ 3 callers
Method
fetchAllZones
获取所有的zone列表 @return
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:97
↓ 3 callers
Method
fetchAppQuotaStatusByAppAndEnv
(String appId, String environment)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:225
↓ 3 callers
Method
findByNameEx
(String instanceName)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:47
↓ 3 callers
Method
findInstancesByGroupId
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:29
↓ 3 callers
Method
getAllEnvironments
()
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:24
↓ 3 callers
Method
getAppDomain
(ApplicationEntity applicationEntity, String env)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:57
↓ 3 callers
Method
getContainersByInstanceName
查询指定实例名的容器 @param env @param namespace @param instanceName @return @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:322
↓ 3 callers
Method
getContainersByZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:379
↓ 3 callers
Method
getCurrentJobByGroupId
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:216
next →
1–100 of 999, ranked by callers