程序包 com.alibaba.nacos.client.redo.service

类 AbstractRedoService

java.lang.Object

com.alibaba.nacos.client.redo.service.AbstractRedoService

所有已实现的接口:

com.alibaba.nacos.common.lifecycle.Closeable, com.alibaba.nacos.common.remote.client.ConnectionEventListener

直接已知子类:

AiGrpcRedoService

public abstract class AbstractRedoService
extends Object
implements com.alibaba.nacos.common.remote.client.ConnectionEventListener, com.alibaba.nacos.common.lifecycle.Closeable

Abstract redo service.

作者:

xiweng.yy

构造器概要

构造器

限定符	构造器	说明
protected	AbstractRedoService(org.slf4j.Logger logger, com.alibaba.nacos.client.env.NacosClientProperties properties, String module)

方法概要

修饰符和类型	方法	说明
protected abstract AbstractRedoTask	buildRedoTask()	Build redo task to do redo work.
<T> void	cachedRedoData(String key, RedoData<T> redoData, Class<T> clazz)	Cache the redo data by class and redo data key.
<T> void	dataDeregister(String key, Class<T> clazz)	Data deregister, mark unregistering status as true.
<T> void	dataDeregistered(String key, Class<T> clazz)	Data deregister finished, mark unregistering status as true.
<T> void	dataRegistered(String key, Class<T> clazz)	Data register successfully, mark registered status as true.
<T> Set<RedoData<T>>	findRedoData(Class<T> clazz)	Find all redo data which need to do redo.
<T> RedoData<T>	getRedoData(String key, Class<?> clazz)	get Cache redo data.
boolean	isConnected()
boolean	isDataRegistered(String key, Class<?> clazz)	Judge data has registered to server.
void	onConnected(com.alibaba.nacos.common.remote.client.Connection connection)
void	onDisConnect(com.alibaba.nacos.common.remote.client.Connection connection)
<T> void	removeRedoData(String key, Class<T> clazz)	Remove data for redo.
void	shutdown()
protected void	startRedoTask()

从类继承的方法 java.lang.Object

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

构造器详细资料

AbstractRedoService

protected AbstractRedoService(org.slf4j.Logger logger,
 com.alibaba.nacos.client.env.NacosClientProperties properties,
 String module)

方法详细资料

startRedoTask

protected void startRedoTask()

buildRedoTask

protected abstract AbstractRedoTask buildRedoTask()

Build redo task to do redo work.

返回:

redo task

onConnected

public void onConnected(com.alibaba.nacos.common.remote.client.Connection connection)

指定者:

onConnected 在接口中 com.alibaba.nacos.common.remote.client.ConnectionEventListener

onDisConnect

public void onDisConnect(com.alibaba.nacos.common.remote.client.Connection connection)

指定者:

onDisConnect 在接口中 com.alibaba.nacos.common.remote.client.ConnectionEventListener

shutdown

public void shutdown()

指定者:

shutdown 在接口中 com.alibaba.nacos.common.lifecycle.Closeable

isConnected

public boolean isConnected()

cachedRedoData

public <T> void cachedRedoData(String key,
 RedoData<T> redoData,
 Class<T> clazz)

Cache the redo data by class and redo data key.

参数:

key - key of redo data

redoData - the redo data

clazz - clazz of stored in RedoData.

removeRedoData

public <T> void removeRedoData(String key,
 Class<T> clazz)

Remove data for redo.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

dataRegistered

public <T> void dataRegistered(String key,
 Class<T> clazz)

Data register successfully, mark registered status as true.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

dataDeregister

public <T> void dataDeregister(String key,
 Class<T> clazz)

Data deregister, mark unregistering status as true.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

dataDeregistered

public <T> void dataDeregistered(String key,
 Class<T> clazz)

Data deregister finished, mark unregistering status as true.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

isDataRegistered

public boolean isDataRegistered(String key,
 Class<?> clazz)

Judge data has registered to server.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

返回:

true if registered, otherwise false

findRedoData

public <T> Set<RedoData<T>> findRedoData(Class<T> clazz)

Find all redo data which need to do redo.

返回:

set of RedoData need to do redo.

getRedoData

public <T> RedoData<T> getRedoData(String key,
 Class<?> clazz)

get Cache redo data.

参数:

key - key of redo data

clazz - clazz of stored in RedoData.

返回:

cache redo data