com.seeyon.ctp.cache.proxy.utils

类 AsyncOpt

java.lang.Object

com.seeyon.ctp.cache.proxy.utils.AsyncOpt

public abstract class AsyncOpt
extends java.lang.Object

异步操作接口

从以下版本开始:

V5 V8.2

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	AsyncOpt.CanalListener

构造器概要

构造器

构造器和说明
AsyncOpt()

方法概要

限定符和类型	方法和说明
abstract long	getCanalMaxVersion(java.lang.String cacheFullName) 获取管道最大的版本号
static AsyncOpt	getInstance()
abstract java.util.List<Pair<java.lang.Long,java.lang.String>>	pullFromCanal(java.lang.String cacheFullName, java.lang.Long localVersion) 读取数据到本地
abstract java.lang.Long	pushToCanal(java.lang.String cacheFullName, java.lang.String content) 推送数据到远端
abstract void	registerListener(AsyncOpt.CanalListener canalListener) 注册管道事件监听

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

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

构造器详细资料

AsyncOpt

public AsyncOpt()

方法详细资料

getInstance

public static AsyncOpt getInstance()

getCanalMaxVersion

public abstract long getCanalMaxVersion(java.lang.String cacheFullName)

获取管道最大的版本号

参数:

cacheFullName - 缓存名称

返回:

从以下版本开始:

V5 V8.2

pullFromCanal

public abstract java.util.List<Pair<java.lang.Long,java.lang.String>> pullFromCanal(java.lang.String cacheFullName,
                                                                                    java.lang.Long localVersion)

读取数据到本地

参数:

cacheFullName - 缓存名称

localVersion - 本地版本号

返回:

从以下版本开始:

V5 V8.2

pushToCanal

public abstract java.lang.Long pushToCanal(java.lang.String cacheFullName,
                                           java.lang.String content)

推送数据到远端

参数:

cacheFullName - 缓存名称

content - 变更数据

返回:

从以下版本开始:

V5 V8.2

registerListener

public abstract void registerListener(AsyncOpt.CanalListener canalListener)

注册管道事件监听

参数:

canalListener - 监听器

从以下版本开始:

V5 V8.2