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
↓ 3 callers
Method
getHandler
(String name)
gate-server/src/main/java/com/ppdai/stargate/job/HandlerRegistry.java:27
↓ 3 callers
Method
getImageList
获取指定应用的镜像列表 @param appName 应用名字 @return 返回镜像列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteDockerRepo.java:26
↓ 3 callers
Method
getImagesByPage
获取镜像分页列表 @param orgName 组织名 @param appName 应用名 @param page 页码 @param size 每页数量 @return 返回镜像分页列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteDockerRepo.java:18
↓ 3 callers
Method
getInUseEnvironments
获取所有可用的环境列表(除去被禁用的环境) @return 可用的环境列表
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:34
↓ 3 callers
Method
getInstanceStatus
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:297
↓ 3 callers
Method
getJavaOpts
jvm参数 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:40
↓ 3 callers
Method
getLimitCpu
CPU配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:22
↓ 3 callers
Method
getRequestCpu
CPU配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:10
↓ 3 callers
Method
getRequestMemory
Memory配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:16
↓ 3 callers
Method
lock
(LockEnum lock, String owner, String oldOwner, Long expiration)
gate-server/src/main/java/com/ppdai/stargate/service/DistLockService.java:41
↓ 3 callers
Method
putInstance
(String upstream, String ipAndPort, NginxInstanceAttrVO nginxInstanceAttrVO)
gate-server/src/main/java/com/ppdai/stargate/client/ConsulClient.java:31
↓ 3 callers
Method
queryAndCheckInstance
(String name, String image)
gate-server/src/test/java/com/ppdai/stargate/service/cloud/CloudInstanceServiceTest.java:38
↓ 3 callers
Method
queryInUseEnvironment
根据环境名获取可用的环境信息 @return 可用的环境信息
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:44
↓ 3 callers
Method
setPodNameForStaticResource
(Long resourceId, String podName)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:37
↓ 3 callers
Method
shutdown
()
gate-server/src/test/java/com/ppdai/stargate/client/K8sClientTest.java:29
↓ 3 callers
Method
startEventTrigger
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:430
↓ 3 callers
Method
tryLock
(LockEnum lock, String owner, Long expiration)
gate-server/src/main/java/com/ppdai/stargate/service/DistLockService.java:18
↓ 3 callers
Method
updateAppMember
更新应用的成员 @param appId 应用ID @param developers 开发人员域账号 @param testers 测试人员域账号
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:84
↓ 3 callers
Method
waitUntilSuccOrTimeout
(InstanceEntity instanceEntity, long timeoutMilliSecs)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:215
↓ 2 callers
Method
addExecCommandJob
(InstanceEntity instanceEntity, String command)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:279
↓ 2 callers
Method
addPodHaController
(String env, List<ZoneDto> zoneDtoList)
gate-server/src/main/java/com/ppdai/stargate/service/PodHaService.java:47
↓ 2 callers
Method
apiInfo
()
gate-server/src/main/java/com/ppdai/stargate/config/SwaggerConfiguration.java:26
↓ 2 callers
Method
changeResourcesType
(String appId, String env, boolean isStatic, boolean resultType)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:33
↓ 2 callers
Method
containerLog
(InstanceEntity instanceEntity, String name)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:274
↓ 2 callers
Method
convert
(TaskEntity taskEntity)
gate-server/src/main/java/com/ppdai/stargate/manager/TaskManager.java:53
↓ 2 callers
Method
createPodHaController
(ZoneDto zoneDto)
gate-server/src/main/java/com/ppdai/stargate/k8s/ControllerFactoryService.java:45
↓ 2 callers
Method
createService
(String appName, String namespace)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:691
↓ 2 callers
Method
deleteAppPod
(String namespace, String podName)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:534
↓ 2 callers
Method
deleteById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/dao/HadoopConfigRepository.java:16
↓ 2 callers
Method
deleteByNameAndEnvId
(String name, String envId)
gate-server/src/main/java/com/ppdai/stargate/dao/DnsRepository.java:12
↓ 2 callers
Method
deploy
(String name, int port, String appId,
gate-server/src/test/java/com/ppdai/stargate/service/ExecCommandServiceTest.java:39
↓ 2 callers
Method
deployAppPod
(AppPodTemplateVI appPodTemplateVI)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:484
↓ 2 callers
Method
destroy
(String name)
gate-server/src/test/java/com/ppdai/stargate/service/ExecCommandServiceTest.java:81
↓ 2 callers
Method
execCommand
(String pod, String namespace, String[] commands)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:595
↓ 2 callers
Method
execCommand
(String[] commands, String env, String zone, String namespace, String instance)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:94
↓ 2 callers
Method
execCurl
(String instance, String endpoint)
gate-server/src/main/java/com/ppdai/stargate/service/ExecCommandService.java:29
↓ 2 callers
Method
execPing
(String instance, String endpoint)
gate-server/src/main/java/com/ppdai/stargate/service/ExecCommandService.java:68
↓ 2 callers
Method
fetchAppByAppId
获取指定appId的应用 @param appId @return
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:69
↓ 2 callers
Method
fetchAppsByUsername
获取指定用户负责的应用列表 @return 返回应用列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:24
↓ 2 callers
Method
findByAppIdAndEnv
(String appId, String env)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:18
↓ 2 callers
Method
findByAppIdEx
(String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:20
↓ 2 callers
Method
findByEnvAndAppId
(String env, String appId)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:240
↓ 2 callers
Method
findByEnvAndNameAndIsActiveTrue
(String env, String name)
gate-server/src/main/java/com/ppdai/stargate/dao/HadoopConfigRepository.java:14
↓ 2 callers
Method
findByNameAndEnvId
(String name, String envId)
gate-server/src/main/java/com/ppdai/stargate/dao/DnsRepository.java:15
↓ 2 callers
Method
findByStatus
(JobStatus jobStatus, Pageable pageable)
gate-server/src/main/java/com/ppdai/stargate/dao/JobRepository.java:20
↓ 2 callers
Method
findFirstByGroupId
(Long groupId, Sort sort)
gate-server/src/main/java/com/ppdai/stargate/dao/JobRepository.java:30
↓ 2 callers
Method
findGroupInstancesByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:65
↓ 2 callers
Method
findInstancesByAppId
(String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:23
↓ 2 callers
Method
findInstancesByHostIp
(String env, String hostIp)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:215
↓ 2 callers
Method
findResourcesByEnvAndZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:41
↓ 2 callers
Method
findStaticResourceByIp
(String appId, String env, String spec, String ip)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:30
↓ 2 callers
Method
findTasksByJobId
(Long jobId)
gate-server/src/main/java/com/ppdai/stargate/dao/TaskRepository.java:13
↓ 2 callers
Method
findUsersByUserName
(String userName)
gate-server/src/main/java/com/ppdai/stargate/service/UserService.java:15
↓ 2 callers
Method
getAppByName
(String appName)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:216
↓ 2 callers
Method
getAppPodLog
获取Pod里面容器的日志 @param namespace @param instanceName @return
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:670
↓ 2 callers
Method
getByPage
(String name, String envId, String content, int page, int size)
gate-server/src/main/java/com/ppdai/stargate/service/DnsService.java:66
↓ 2 callers
Method
getConfigMap
(String namespace, String configName)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:401
↓ 2 callers
Method
getContainerLog
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:238
↓ 2 callers
Method
getContainersByHostIp
查询指定物理机IP的容器 @param env @param hostIp @return @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:340
↓ 2 callers
Method
getDBTime
()
gate-server/src/main/java/com/ppdai/stargate/dao/GlobalLockRepository.java:21
↓ 2 callers
Method
getDetails
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:84
↓ 2 callers
Method
getFlinkJobStatusByGroupId
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:75
↓ 2 callers
Method
getJobBaseInfo
(String baseUrl, BaseFlinkReq baseFlinkReq)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:150
↓ 2 callers
Method
getK8sClientRpcByZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:72
↓ 2 callers
Method
getK8sClientsByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:36
↓ 2 callers
Method
getNodeByIp
(String hostIp)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:651
↓ 2 callers
Method
getScope
告诉k8s需要从该scope扣除资源 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:34
↓ 2 callers
Method
getZoneListByInstanceCount
根据要发布的实例数获取分配好的zone列表 @param env @param zone @param instanceCount @param groupId @return
gate-server/src/main/java/com/ppdai/stargate/service/ZoneService.java:84
↓ 2 callers
Method
listGroupByEnvAndAppId
获取指定站点的发布组列表 @return 返回发布组实体列表
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:56
↓ 2 callers
Method
listHadoopConfigs
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/HadoopConfigService.java:33
↓ 2 callers
Method
onExpire
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobHandler.java:54
↓ 2 callers
Method
phoenixAddress
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:32
↓ 2 callers
Method
processEndpoints
(Endpoints endpoints)
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:111
↓ 2 callers
Method
recoverInstance1Step
(InstanceEntity badInstance)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:230
↓ 2 callers
Method
removePodNameFromResource
(String podName)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:462
↓ 2 callers
Method
removeResourceById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:231
↓ 2 callers
Method
restartJobById
(Long jobId)
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:98
↓ 2 callers
Method
setEnvironmentEnableHa
(Long envId, Boolean enable)
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:66
↓ 2 callers
Method
start
启动job @param baseUrl http://localhost:8009 @return
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:71
↓ 2 callers
Method
stopEventPolling
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:471
↓ 2 callers
Method
stopEventTrigger
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:459
↓ 2 callers
Method
syncAllApps
同步应用列表到本地数据库 @return 若同步成功,则返回True
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:173
↓ 2 callers
Method
updateContainer
(String dockerUrl, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:187
↓ 2 callers
Method
waitUntilDeleteOrTimeout
(InstanceEntity instanceEntity, long timeoutMilliSecs)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:280
↓ 1 callers
Method
AddIp
(AddIpRequestVI addIpRequestVI)
gate-server/src/main/java/com/ppdai/stargate/service/IpService.java:70
↓ 1 callers
Method
AddIpValidator
(AddIpRequestVI addIpRequestVI)
gate-server/src/main/java/com/ppdai/stargate/service/validator/IpServiceValidator.java:33
↓ 1 callers
Method
addCreateGroupJob
(String operatorType, Long groupId, Long instanceId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:67
↓ 1 callers
Method
addDeployApplicationFlinkJob
flink1.11 @param operatorType @param instanceId @return
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:98
↓ 1 callers
Method
addDeployJob
添加部署实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:47
↓ 1 callers
Method
addDestroyFlinkJob
(String operatorType, Long groupId, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:184
↓ 1 callers
Method
addDestroyJob
添加销毁实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:77
↓ 1 callers
Method
addDownJob
添加拉出流量任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:138
↓ 1 callers
Method
addRestartFlinkJob
(String operatorType, Long instanceId, Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:213
↓ 1 callers
Method
addRestartJob
添加重启实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:203
↓ 1 callers
Method
addStopFlinkJob
(String operatorType, GroupEntity groupEntity, Long instanceId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:162
↓ 1 callers
Method
addUpJob
添加拉入流量任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:109
↓ 1 callers
Method
addUpdateFlinkJob
(String operatorType, Long groupId, Long instanceId, FlinkDeployRequest f
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:128
↓ 1 callers
Method
addUpdateJob
添加更新实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:167
↓ 1 callers
Method
allocateResourceForPodName
(String appId, String appName, String env, String spec, String podName, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:381
↓ 1 callers
Method
allotZoneForInstance
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:272
← previous
next →
101–200 of 999, ranked by callers