Package com.bytedesk.core.server_metrics

Class ServerMetricsRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

com.bytedesk.core.server_metrics.ServerMetricsRestService

@Service
public class ServerMetricsRestService
extends BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ServerMetricsRestService.ServerMetricsAverage
static class	ServerMetricsRestService.ServerMetricsPeak

Field Summary

Fields

Modifier and Type	Field	Description
private final org.modelmapper.ModelMapper	modelMapper
private final ServerMetricsRepository	serverMetricsRepository
private final ServerRestService	serverRestService
private final UidUtils	uidUtils

Fields inherited from class com.bytedesk.core.base.BaseRestService

authService

Constructor Summary

Constructors

Constructor	Description
ServerMetricsRestService()

Method Summary

Modifier and Type	Method	Description
int	cleanupOldMetrics(int retentionDays)
ServerMetricsResponse	convertToResponse(ServerMetricsEntity entity)
ServerMetricsResponse	create(ServerMetricsRequest request)
protected org.springframework.data.jpa.domain.Specification<ServerMetricsEntity>	createSpecification(ServerMetricsRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
void	delete(ServerMetricsRequest request)
void	deleteByUid(String uid)
ServerMetricsEntity	doSave(ServerMetricsEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<ServerMetricsEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<ServerMetricsEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
Optional<ServerMetricsEntity>	findByUid(String uid)
List<ServerMetricsEntity>	findHighUsageMetrics(Double cpuThreshold, Double memoryThreshold, Double diskThreshold, ZonedDateTime startTime, ZonedDateTime endTime)
ServerMetricsRestService.ServerMetricsAverage	getAverageMetrics(String serverUid, ZonedDateTime startTime, ZonedDateTime endTime)
Optional<ServerMetricsEntity>	getLatestMetrics(String serverUid)
long	getMetricsCount(String serverUid)
List<ServerMetricsEntity>	getMetricsHistory(String serverUid, ZonedDateTime startTime, ZonedDateTime endTime)
ServerMetricsRestService.ServerMetricsPeak	getPeakMetrics(String serverUid, ZonedDateTime startTime, ZonedDateTime endTime)
protected String	getUidFromRequest(ServerMetricsRequest request)	从请求对象中获取UID的通用实现 使用反射调用getUid方法
ServerMetricsEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, ServerMetricsEntity entity)
ServerMetricsEntity	recordMetrics(ServerEntity serverEntity)
ServerMetricsResponse	update(ServerMetricsRequest request)

Methods inherited from class com.bytedesk.core.base.BaseRestService

deleteByOrgUid, findByOrgUid, queryByOrg, queryByUid, queryByUser, recover, save, setUserUidToRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

serverMetricsRepository

private final ServerMetricsRepository serverMetricsRepository

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

serverRestService

private final ServerRestService serverRestService

Constructor Details

ServerMetricsRestService

public ServerMetricsRestService()

Method Details

createSpecification

protected org.springframework.data.jpa.domain.Specification<ServerMetricsEntity> createSpecification(ServerMetricsRequest request)

Description copied from class: BaseRestService

创建Specification对象，子类必须实现 用于queryByOrg的通用实现

Specified by:

createSpecification in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

executePageQuery

protected org.springframework.data.domain.Page<ServerMetricsEntity> executePageQuery(org.springframework.data.jpa.domain.Specification<ServerMetricsEntity> spec,
 org.springframework.data.domain.Pageable pageable)

Description copied from class: BaseRestService

执行分页查询，子类必须实现 用于queryByOrg的通用实现

Specified by:

executePageQuery in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

findByUid

@Cacheable(value="server_metrics",
           key="#uid",
           unless="#result==null")
public Optional<ServerMetricsEntity> findByUid(String uid)

Specified by:

findByUid in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

create

public ServerMetricsResponse create(ServerMetricsRequest request)

Specified by:

create in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

update

public ServerMetricsResponse update(ServerMetricsRequest request)

Specified by:

update in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

deleteByUid

public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

delete

public void delete(ServerMetricsRequest request)

Specified by:

delete in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

getUidFromRequest

protected String getUidFromRequest(ServerMetricsRequest request)

Description copied from class: BaseRestService

从请求对象中获取UID的通用实现 使用反射调用getUid方法

Overrides:

getUidFromRequest in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

doSave

public ServerMetricsEntity doSave(ServerMetricsEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

handleOptimisticLockingFailureException

public ServerMetricsEntity handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 ServerMetricsEntity entity)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

convertToResponse

public ServerMetricsResponse convertToResponse(ServerMetricsEntity entity)

Specified by:

convertToResponse in class BaseRestService<ServerMetricsEntity,ServerMetricsRequest,ServerMetricsResponse>

recordMetrics

@Transactional
public ServerMetricsEntity recordMetrics(ServerEntity serverEntity)

getMetricsHistory

public List<ServerMetricsEntity> getMetricsHistory(String serverUid,
 ZonedDateTime startTime,
 ZonedDateTime endTime)

getLatestMetrics

public Optional<ServerMetricsEntity> getLatestMetrics(String serverUid)

getAverageMetrics

public ServerMetricsRestService.ServerMetricsAverage getAverageMetrics(String serverUid,
 ZonedDateTime startTime,
 ZonedDateTime endTime)

getPeakMetrics

public ServerMetricsRestService.ServerMetricsPeak getPeakMetrics(String serverUid,
 ZonedDateTime startTime,
 ZonedDateTime endTime)

findHighUsageMetrics

public List<ServerMetricsEntity> findHighUsageMetrics(Double cpuThreshold,
 Double memoryThreshold,
 Double diskThreshold,
 ZonedDateTime startTime,
 ZonedDateTime endTime)

cleanupOldMetrics

@Transactional
public int cleanupOldMetrics(int retentionDays)

getMetricsCount

public long getMetricsCount(String serverUid)