MCPcopy Create free account

hub / github.com/FinVolution/stargate / functions

Functions999 in github.com/FinVolution/stargate

⨍ Functions 999◇ Types & classes 313
↓ 1 callersMethodgetInstancesByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:607
↓ 1 callersMethodgetInstancesByGroupIdEx
(Long groupId)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:72
↓ 1 callersMethodgetJobDetails
获取job详情 @param baseUrl @param jobId @return
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkCtrlClient.java:102
↓ 1 callersMethodgetJobStatus
()
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:197
↓ 1 callersMethodgetJobsByPage
(String env, String appId, Long groupId, String operationType, String status, String startTime, String endTime
gate-server/src/main/java/com/ppdai/stargate/service/JobService.java:129
↓ 1 callersMethodgetLinuxLocalIP
()
gate-server/src/main/java/com/ppdai/stargate/utils/IPUtil.java:15
↓ 1 callersMethodgetLogAndWriteAsync
(SessionClusterArgs sessionClusterArgs, TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:196
↓ 1 callersMethodgetMessageType
()
gate-server/src/main/java/com/ppdai/stargate/exception/BaseException.java:48
↓ 1 callersMethodgetNewJob
()
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:78
↓ 1 callersMethodgetReleaseLog
(String groupName, long groupId, long jobId, boolean fromUI)
gate-server/src/main/java/com/ppdai/stargate/service/GroupLogService.java:58
↓ 1 callersMethodgetResource
(String env, String spec)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:31
↓ 1 callersMethodgetRunningJob
()
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:85
↓ 1 callersMethodgetServiceFromAppName
(String appName)
gate-server/src/main/java/com/ppdai/stargate/utils/NamingUtil.java:19
↓ 1 callersMethodgetStackTrace
()
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:92
↓ 1 callersMethodgetSubNet
(String IP)
gate-server/src/main/java/com/ppdai/stargate/service/IpService.java:61
↓ 1 callersMethodgetWinLocalIP
()
gate-server/src/main/java/com/ppdai/stargate/utils/IPUtil.java:39
↓ 1 callersMethodhcCheck
(String url)
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:64
↓ 1 callersMethodhcCheckByProxy
(String url)
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:74
↓ 1 callersMethodimageMapper
(ImageEntity imageEntity)
gate-server/src/main/java/com/ppdai/stargate/remote/impl/RemoteDockeryard.java:96
↓ 1 callersMethodisFullLoad
()
gate-server/src/main/java/com/ppdai/stargate/job/JobExecutor.java:125
↓ 1 callersMethodisIp
(String IP)
gate-server/src/main/java/com/ppdai/stargate/service/validator/IpServiceValidator.java:11
↓ 1 callersMethodisNodeDown
(V1Node v1Node)
gate-server/src/main/java/com/ppdai/stargate/service/NodeService.java:26
↓ 1 callersMethodisWatchClosed
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:482
↓ 1 callersMethodlist
()
gate-server/src/main/java/com/ppdai/stargate/controller/api/EnvApiController.java:29
↓ 1 callersMethodlock
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/manager/JobManager.java:34
↓ 1 callersMethodlog
(@RequestBody GetInstanceLogRequest request)
gate-server/src/main/java/com/ppdai/stargate/controller/api/InstanceApiController.java:254
↓ 1 callersMethodonExpire
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:88
↓ 1 callersMethodonFail
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobHandler.java:47
↓ 1 callersMethodonFail
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:82
↓ 1 callersMethodonInterrupt
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobHandler.java:61
↓ 1 callersMethodonInterrupt
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:94
↓ 1 callersMethodonSuccess
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobHandler.java:40
↓ 1 callersMethodonSuccess
(TaskInfo taskInfo)
gate-server/src/main/java/com/ppdai/stargate/job/task/AbstractTaskHandler.java:76
↓ 1 callersMethodonlyAddInstance
部署实例 @param request @return
gate-server/src/main/java/com/ppdai/stargate/service/cloud/CloudInstanceService.java:287
↓ 1 callersMethodphoenixIp
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:36
↓ 1 callersMethodphoenixIps
(String env, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:41
↓ 1 callersMethodphoenixPort
()
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:47
↓ 1 callersMethodpodIsReady
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/flink/PhoenixClientService.java:52
↓ 1 callersMethodprocessExpiredJob
检查是否有执行超时的job
gate-server/src/main/java/com/ppdai/stargate/job/JobMonitor.java:63
↓ 1 callersMethodprocessNewJob
()
gate-server/src/main/java/com/ppdai/stargate/job/JobMonitor.java:22
↓ 1 callersMethodprocessNotReadyAddress
处理失败实例 @param serviceName @param endpointAddress
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:229
↓ 1 callersMethodprocessNotReadyAddressSingle
处理不带发布组的不可用实例 @param instanceEntity
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:137
↓ 1 callersMethodprocessReadyAddress
处理成功实例 @param serviceName @param endpointAddress
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:357
↓ 1 callersMethodprocessReadyAddressSingle
处理不带发布组的可用实例 @param instanceEntity
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:279
↓ 1 callersMethodpullIn
拉入实例（接流量） @param domain @param instance
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteRegistry.java:22
↓ 1 callersMethodpullInOne
(String domain, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/TrafficService.java:42
↓ 1 callersMethodpullOut
拉出实例（摘流量） @param domain @param instance @throws IOException
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteRegistry.java:30
↓ 1 callersMethodpullOutOne
(String domain, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/TrafficService.java:51
↓ 1 callersMethodreadFromLocal
(String groupName, long jobId)
gate-server/src/main/java/com/ppdai/stargate/service/GroupLogService.java:33
↓ 1 callersMethodreadFromRemote
(String groupName, long groupId, long jobId, String host)
gate-server/src/main/java/com/ppdai/stargate/service/GroupLogService.java:51
↓ 1 callersMethodreadInstanceSpecs
从Remote PAAS中获取instance实例规格列表
gate-server/src/main/java/com/ppdai/stargate/service/TaskService.java:26
↓ 1 callersMethodreadUserInfo
()
gate-server/src/main/java/com/ppdai/stargate/aop/AuthorizationAspect.java:53
↓ 1 callersMethodrecordOperation
(AuditLogEntity actionItem)
gate-server/src/main/java/com/ppdai/stargate/service/AuditService.java:23
↓ 1 callersMethodrecoverInstance2Step
(InstanceEntity okInstance)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceJobService.java:262
↓ 1 callersMethodregister
(String env, String appId, String appName, String domain, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteRegistry.java:12
↓ 1 callersMethodregisterOne
(String env, String appId, String appName, String domain, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/TrafficService.java:30
↓ 1 callersMethodreleaseResourceByInstance
(String podName)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:305
↓ 1 callersMethodremoveAllPodHaControllers
()
gate-server/src/main/java/com/ppdai/stargate/service/PodHaService.java:89
↓ 1 callersMethodremoveAppById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:112
↓ 1 callersMethodremoveById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/dao/GroupRepository.java:23
↓ 1 callersMethodremoveIpById
(Long id)
gate-server/src/main/java/com/ppdai/stargate/service/IpService.java:139
↓ 1 callersMethodremovePodHaController
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/PodHaService.java:74
↓ 1 callersMethodrestart
(@PathVariable("groupId") Long groupId)
gate-server/src/main/java/com/ppdai/stargate/controller/flink/FlinkGroupController.java:224
↓ 1 callersMethodrestart
重启实例 @param request @return
gate-server/src/main/java/com/ppdai/stargate/service/cloud/CloudInstanceService.java:172
↓ 1 callersMethodrestart
(TaskInfo taskInfo, InstanceEntity instanceEntity, ApplicationEntity applicationEntity, EnvVO envVO)
gate-server/src/main/java/com/ppdai/stargate/job/task/handler/instance/RestartOneInK8sTaskHandler.java:41
↓ 1 callersMethodrestartFailedJobs
(String[] jobIdList)
gate-server/src/main/java/com/ppdai/stargate/job/task/handler/group/SyncInstanceJobTaskHandler.java:40
↓ 1 callersMethodrestartJob
(@RequestParam Long jobId)
gate-server/src/main/java/com/ppdai/stargate/controller/GroupController.java:643
↓ 1 callersMethodrun
()
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:611
↓ 1 callersMethodsearchUsersByUserName
根据用户名模糊查询用户列表 @param userName 用户名 @return
gate-server/src/main/java/com/ppdai/stargate/remote/RemoteCmdb.java:76
↓ 1 callersMethodsetCode
(Integer code)
gate-server/src/main/java/com/ppdai/stargate/controller/response/Response.java:72
↓ 1 callersMethodsetEnvironmentInUse
(Long envId, Boolean isInUse)
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:53
↓ 1 callersMethodsetPodNameForDynamicResource
(String appId, String appName, String env, String spec, String podName, String zone)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:312
↓ 1 callersMethodsetPodNameForResource
(String appId, String env, String spec, String ip, String zone, String podName)
gate-server/src/main/java/com/ppdai/stargate/service/ResourceService.java:416
↓ 1 callersMethodsetResourceOverSubscribeFlag
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:252
↓ 1 callersMethodstartContainer
(String dockerUrl, String dns, InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:156
↓ 1 callersMethodstartEventPolling
()
gate-server/src/main/java/com/ppdai/stargate/k8s/PodHaController.java:437
↓ 1 callersMethodstopContainer
(InstanceEntity instanceEntity)
gate-server/src/main/java/com/ppdai/stargate/service/ContainerService.java:197
↓ 1 callersMethodsubIp
(String dashboard)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:182
↓ 1 callersMethodsubPort
(String dashboard)
gate-server/src/main/java/com/ppdai/stargate/service/flink/FlinkService.java:189
↓ 1 callersMethodsubmitJob
(JobInfo jobInfo)
gate-server/src/main/java/com/ppdai/stargate/job/JobExecutor.java:39
↓ 1 callersMethodsyncEnvs
()
gate-server/src/main/java/com/ppdai/stargate/service/EnvService.java:79
↓ 1 callersMethodsyncIpStatus
(@RequestParam String env)
gate-server/src/main/java/com/ppdai/stargate/controller/IpController.java:45
↓ 1 callersMethodsyncIpStatusByEnv
(String env)
gate-server/src/main/java/com/ppdai/stargate/service/IpService.java:156
↓ 1 callersMethodtransferInstances
(TransferInstanceVO transferInstanceVO)
gate-server/src/main/java/com/ppdai/stargate/service/InstanceService.java:562
↓ 1 callersMethodup
(@RequestBody UpInstanceRequest request, HttpServletRequest httpServletRequest)
gate-server/src/main/java/com/ppdai/stargate/controller/api/InstanceApiController.java:220
↓ 1 callersMethodupdate
(@RequestBody UpdateDnsRequest request)
gate-server/src/main/java/com/ppdai/stargate/controller/DnsController.java:38
↓ 1 callersMethodupdate
(DnsEntity recordEntity)
gate-server/src/main/java/com/ppdai/stargate/service/DnsService.java:47
↓ 1 callersMethodupdate
(TaskInfo taskInfo, InstanceEntity instanceEntity, ApplicationEntity applicationEntity, EnvVO envVO)
gate-server/src/main/java/com/ppdai/stargate/job/task/handler/instance/UpdateOneInK8sTaskHandler.java:30
↓ 1 callersMethodupdateAllApps
(List<AppVO> appVOs)
gate-server/src/main/java/com/ppdai/stargate/service/AppService.java:131
↓ 1 callersMethodupdateAppPod
(String dockerUrl, String namespace, String podName, String image)
gate-server/src/main/java/com/ppdai/stargate/client/K8sClient.java:509
↓ 1 callersMethodupdateConfig
(HadoopConfigEntity hadoopConfigEntity)
gate-server/src/main/java/com/ppdai/stargate/service/HadoopConfigService.java:76
↓ 1 callersMethodupdateLockByName
(LockEnum lock, String owner, String oldOwner, Long expiration)
gate-server/src/main/java/com/ppdai/stargate/dao/GlobalLockRepository.java:16
↓ 1 callersMethodwaitJobs
(String[] jobIdList)
gate-server/src/main/java/com/ppdai/stargate/job/task/handler/group/SyncInstanceJobTaskHandler.java:65
MethodAbstractResponse
(int code, String msg)
gate-server/src/main/java/com/ppdai/stargate/dto/AbstractResponse.java:13
MethodAddStaticResourceResponse
(int code, String msg)
gate-server/src/main/java/com/ppdai/stargate/dto/AddStaticResourceResponse.java:7
MethodBaseException
(MessageType msgType)
gate-server/src/main/java/com/ppdai/stargate/exception/BaseException.java:9
MethodChangeResourceTypeResponse
(int code, String msg)
gate-server/src/main/java/com/ppdai/stargate/dto/ChangeResourceTypeResponse.java:11
MethodConsulClient
(String consulHost, JsonHttpClient httpClient)
gate-server/src/main/java/com/ppdai/stargate/client/ConsulClient.java:26
MethodCreateResourceResponse
(int code, String msg)
gate-server/src/main/java/com/ppdai/stargate/dto/CreateResourceResponse.java:12
MethodDeleteResourceResponse
(int code, String msg)
gate-server/src/main/java/com/ppdai/stargate/dto/DeleteResourceResponse.java:7
← previousnext →301–400 of 999, ranked by callers