MCPcopy Create free account

hub / github.com/FinVolution/stargate / functions

Functions999 in github.com/FinVolution/stargate

↓ 3 callersMethodgetHandler
(String name)
gate-server/src/main/java/com/ppdai/stargate/job/HandlerRegistry.java:27
↓ 3 callersMethodgetImageList
获取指定应用的镜像列表 @param appName 应用名字 @return 返回镜像列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteDockerRepo.java:26
↓ 3 callersMethodgetImagesByPage
获取镜像分页列表 @param orgName 组织名 @param appName 应用名 @param page 页码 @param size 每页数量 @return 返回镜像分页列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteDockerRepo.java:18
↓ 3 callersMethodgetInUseEnvironments
获取所有可用的环境列表(除去被禁用的环境) @return 可用的环境列表
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:34
↓ 3 callersMethodgetInstanceStatus
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:297
↓ 3 callersMethodgetJavaOpts
jvm参数 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:40
↓ 3 callersMethodgetLimitCpu
CPU配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:22
↓ 3 callersMethodgetRequestCpu
CPU配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:10
↓ 3 callersMethodgetRequestMemory
Memory配额 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:16
↓ 3 callersMethodlock
(LockEnum lock, String owner, String oldOwner, Long expiration)
gate-server/src/main/java/com/ppdai/stargate/service/DistLockService.java:41
↓ 3 callersMethodputInstance
(String upstream, String ipAndPort, NginxInstanceAttrVO nginxInstanceAttrVO)
gate-server/src/main/java/com/ppdai/stargate/client/ConsulClient.java:31
↓ 3 callersMethodqueryAndCheckInstance
(String name, String image)
gate-server/src/test/java/com/ppdai/stargate/service/cloud/CloudInstanceServiceTest.java:38
↓ 3 callersMethodqueryInUseEnvironment
根据环境名获取可用的环境信息 @return 可用的环境信息
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:44
↓ 3 callersMethodsetPodNameForStaticResource
(Long resourceId, String podName)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:37
↓ 3 callersMethodshutdown
()
gate-server/src/test/java/com/ppdai/stargate/client/K8sClientTest.java:29
↓ 3 callersMethodstartEventTrigger
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:430
↓ 3 callersMethodtryLock
(LockEnum lock, String owner, Long expiration)
gate-server/src/main/java/com/ppdai/stargate/service/DistLockService.java:18
↓ 3 callersMethodupdateAppMember
更新应用的成员 @param appId 应用ID @param developers 开发人员域账号 @param testers 测试人员域账号
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:84
↓ 3 callersMethodwaitUntilSuccOrTimeout
(InstanceEntity instanceEntity, long timeoutMilliSecs)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:215
↓ 2 callersMethodaddExecCommandJob
(InstanceEntity instanceEntity, String command)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:279
↓ 2 callersMethodaddPodHaController
(String env, List<ZoneDto> zoneDtoList)
gate-server/src/main/java/com/ppdai/stargate/service/PodHaService.java:47
↓ 2 callersMethodapiInfo
()
gate-server/src/main/java/com/ppdai/stargate/config/SwaggerConfiguration.java:26
↓ 2 callersMethodchangeResourcesType
(String appId, String env, boolean isStatic, boolean resultType)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:33
↓ 2 callersMethodcontainerLog
(InstanceEntity instanceEntity, String name)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:274
↓ 2 callersMethodconvert
(TaskEntity taskEntity)
gate-server/src/main/java/com/ppdai/stargate/manager/TaskManager.java:53
↓ 2 callersMethodcreatePodHaController
(ZoneDto zoneDto)
gate-server/src/main/java/com/ppdai/stargate/k8s/ControllerFactoryService.java:45
↓ 2 callersMethodcreateService
(String appName, String namespace)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:691
↓ 2 callersMethoddeleteAppPod
(String namespace, String podName)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:534
↓ 2 callersMethoddeleteById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/dao/HadoopConfigRepository.java:16
↓ 2 callersMethoddeleteByNameAndEnvId
(String name, String envId)
gate-server/src/main/java/com/ppdai/stargate/dao/DnsRepository.java:12
↓ 2 callersMethoddeploy
(String name, int port, String appId,
gate-server/src/test/java/com/ppdai/stargate/service/ExecCommandServiceTest.java:39
↓ 2 callersMethoddeployAppPod
(AppPodTemplateVI appPodTemplateVI)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:484
↓ 2 callersMethoddestroy
(String name)
gate-server/src/test/java/com/ppdai/stargate/service/ExecCommandServiceTest.java:81
↓ 2 callersMethodexecCommand
(String pod, String namespace, String[] commands)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:595
↓ 2 callersMethodexecCommand
(String[] commands, String env, String zone, String namespace, String instance)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:94
↓ 2 callersMethodexecCurl
(String instance, String endpoint)
gate-server/src/main/java/com/ppdai/stargate/service/ExecCommandService.java:29
↓ 2 callersMethodexecPing
(String instance, String endpoint)
gate-server/src/main/java/com/ppdai/stargate/service/ExecCommandService.java:68
↓ 2 callersMethodfetchAppByAppId
获取指定appId的应用 @param appId @return
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:69
↓ 2 callersMethodfetchAppsByUsername
获取指定用户负责的应用列表 @return 返回应用列表
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:24
↓ 2 callersMethodfindByAppIdAndEnv
(String appId, String env)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:18
↓ 2 callersMethodfindByAppIdEx
(String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:20
↓ 2 callersMethodfindByEnvAndAppId
(String env, String appId)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:240
↓ 2 callersMethodfindByEnvAndNameAndIsActiveTrue
(String env, String name)
gate-server/src/main/java/com/ppdai/stargate/dao/HadoopConfigRepository.java:14
↓ 2 callersMethodfindByNameAndEnvId
(String name, String envId)
gate-server/src/main/java/com/ppdai/stargate/dao/DnsRepository.java:15
↓ 2 callersMethodfindByStatus
(JobStatus jobStatus, Pageable pageable)
gate-server/src/main/java/com/ppdai/stargate/dao/JobRepository.java:20
↓ 2 callersMethodfindFirstByGroupId
(Long groupId, Sort sort)
gate-server/src/main/java/com/ppdai/stargate/dao/JobRepository.java:30
↓ 2 callersMethodfindGroupInstancesByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:65
↓ 2 callersMethodfindInstancesByAppId
(String appId)
gate-server/src/main/java/com/ppdai/stargate/dao/InstanceRepository.java:23
↓ 2 callersMethodfindInstancesByHostIp
(String env, String hostIp)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:215
↓ 2 callersMethodfindResourcesByEnvAndZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:41
↓ 2 callersMethodfindStaticResourceByIp
(String appId, String env, String spec, String ip)
gate-server/src/main/java/com/ppdai/stargate/dao/ResourceRepository.java:30
↓ 2 callersMethodfindTasksByJobId
(Long jobId)
gate-server/src/main/java/com/ppdai/stargate/dao/TaskRepository.java:13
↓ 2 callersMethodfindUsersByUserName
(String userName)
gate-server/src/main/java/com/ppdai/stargate/service/UserService.java:15
↓ 2 callersMethodgetAppByName
(String appName)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:216
↓ 2 callersMethodgetAppPodLog
获取Pod里面容器的日志 @param namespace @param instanceName @return
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:670
↓ 2 callersMethodgetByPage
(String name, String envId, String content, int page, int size)
gate-server/src/main/java/com/ppdai/stargate/service/DnsService.java:66
↓ 2 callersMethodgetConfigMap
(String namespace, String configName)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:401
↓ 2 callersMethodgetContainerLog
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:238
↓ 2 callersMethodgetContainersByHostIp
查询指定物理机IP的容器 @param env @param hostIp @return @throws ApiException
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:340
↓ 2 callersMethodgetDBTime
()
gate-server/src/main/java/com/ppdai/stargate/dao/GlobalLockRepository.java:21
↓ 2 callersMethodgetDetails
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:84
↓ 2 callersMethodgetFlinkJobStatusByGroupId
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:75
↓ 2 callersMethodgetJobBaseInfo
(String baseUrl, BaseFlinkReq baseFlinkReq)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:150
↓ 2 callersMethodgetK8sClientRpcByZone
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:72
↓ 2 callersMethodgetK8sClientsByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteManager.java:36
↓ 2 callersMethodgetNodeByIp
(String hostIp)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:651
↓ 2 callersMethodgetScope
告诉k8s需要从该scope扣除资源 @return
gate-server/src/main/java/com/ppdai/stargate/vo/K8sQuotaVO.java:34
↓ 2 callersMethodgetZoneListByInstanceCount
根据要发布的实例数获取分配好的zone列表 @param env @param zone @param instanceCount @param groupId @return
gate-server/src/main/java/com/ppdai/stargate/service/ZoneService.java:84
↓ 2 callersMethodlistGroupByEnvAndAppId
获取指定站点的发布组列表 @return 返回发布组实体列表
gate-server/src/main/java/com/ppdai/stargate/service/GroupService.java:56
↓ 2 callersMethodlistHadoopConfigs
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/HadoopConfigService.java:33
↓ 2 callersMethodonExpire
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobHandler.java:54
↓ 2 callersMethodphoenixAddress
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:32
↓ 2 callersMethodprocessEndpoints
(Endpoints endpoints)
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:111
↓ 2 callersMethodrecoverInstance1Step
(InstanceEntity badInstance)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:230
↓ 2 callersMethodremovePodNameFromResource
(String podName)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:462
↓ 2 callersMethodremoveResourceById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:231
↓ 2 callersMethodrestartJobById
(Long jobId)
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:98
↓ 2 callersMethodsetEnvironmentEnableHa
(Long envId, Boolean enable)
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:66
↓ 2 callersMethodstart
启动job @param baseUrl http://localhost:8009 @return
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:71
↓ 2 callersMethodstopEventPolling
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:471
↓ 2 callersMethodstopEventTrigger
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:459
↓ 2 callersMethodsyncAllApps
同步应用列表到本地数据库 @return 若同步成功,则返回True
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:173
↓ 2 callersMethodupdateContainer
(String dockerUrl, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:187
↓ 2 callersMethodwaitUntilDeleteOrTimeout
(InstanceEntity instanceEntity, long timeoutMilliSecs)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:280
↓ 1 callersMethodAddIp
(AddIpRequestVI addIpRequestVI)
gate-server/src/main/java/com/ppdai/stargate/service/IpService.java:70
↓ 1 callersMethodAddIpValidator
(AddIpRequestVI addIpRequestVI)
gate-server/src/main/java/com/ppdai/stargate/service/validator/IpServiceValidator.java:33
↓ 1 callersMethodaddCreateGroupJob
(String operatorType, Long groupId, Long instanceId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:67
↓ 1 callersMethodaddDeployApplicationFlinkJob
flink1.11 @param operatorType @param instanceId @return
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:98
↓ 1 callersMethodaddDeployJob
添加部署实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:47
↓ 1 callersMethodaddDestroyFlinkJob
(String operatorType, Long groupId, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:184
↓ 1 callersMethodaddDestroyJob
添加销毁实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:77
↓ 1 callersMethodaddDownJob
添加拉出流量任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:138
↓ 1 callersMethodaddRestartFlinkJob
(String operatorType, Long instanceId, Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:213
↓ 1 callersMethodaddRestartJob
添加重启实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:203
↓ 1 callersMethodaddStopFlinkJob
(String operatorType, GroupEntity groupEntity, Long instanceId)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:162
↓ 1 callersMethodaddUpJob
添加拉入流量任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:109
↓ 1 callersMethodaddUpdateFlinkJob
(String operatorType, Long groupId, Long instanceId, FlinkDeployRequest f
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkJobService.java:128
↓ 1 callersMethodaddUpdateJob
添加更新实例任务 @param instanceEntity @return
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:167
↓ 1 callersMethodallocateResourceForPodName
(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 callersMethodallotZoneForInstance
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:272
← previousnext →101–200 of 999, ranked by callers