net.gdface.sdk.fse.thrift

Class FeatureSeThriftClientAsync

java.lang.Object

net.gdface.sdk.fse.thrift.FeatureSeThriftClientAsync

public class FeatureSeThriftClientAsync
extends java.lang.Object

基于thrift/swift框架生成的client端代码提供FeatureSe接口的异步RPC实现(线程安全)
转发所有FeatureSe接口方法到delegate()指定的实例
所有服务端抛出的RuntimeException异常被封装到ServiceRuntimeException中抛出
Example:

        FeatureSeThriftClientAsync thriftInstance = ClientFactory
            .builder()
            .setHostAndPort("127.0.0.1",26413)
            .build(FeatureSe.class, FeatureSeThriftClientAsync.class);
 

计算机生成代码(generated by automated tools ThriftServiceDecoratorGenerator @author guyadong)

Author:

guyadong

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FeatureSeThriftClientAsync.DefaultCallback<V> 默认的FutureCallback实现

Constructor Summary

Constructors

Constructor and Description
FeatureSeThriftClientAsync(net.gdface.thrift.ClientFactory factory)
FeatureSeThriftClientAsync(com.google.common.net.HostAndPort hostAndPort)
FeatureSeThriftClientAsync(java.lang.String host, int port)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean>	addFeature(byte[] featureId, byte[] feature, long appid) see also FeatureSe.addFeature(byte[],byte[],long)
void	addFeature(byte[] featureId, byte[] feature, long appid, com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)
com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean>	addFeature(byte[] featureId, byte[] feature, java.lang.String imgMD5) see also FeatureSe.addFeature(byte[],byte[],java.lang.String)
void	addFeature(byte[] featureId, byte[] feature, java.lang.String imgMD5, com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)
com.google.common.util.concurrent.ListenableFuture<java.lang.Void>	clearAll() see also FeatureSe.clearAll()
void	clearAll(com.google.common.util.concurrent.FutureCallback<java.lang.Void> callback)
protected FeatureSe.Async	delegate()
net.gdface.thrift.ClientFactory	getFactory()
com.google.common.util.concurrent.ListenableFuture<CodeBean>	getFeature(byte[] featureId) see also FeatureSe.getFeature(byte[])
void	getFeature(byte[] featureId, com.google.common.util.concurrent.FutureCallback<CodeBean> callback)
com.google.common.util.concurrent.ListenableFuture<CodeBean>	getFeatureByHex(java.lang.String featureId) see also FeatureSe.getFeatureByHex(java.lang.String)
void	getFeatureByHex(java.lang.String featureId, com.google.common.util.concurrent.FutureCallback<CodeBean> callback)
com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean>	removeFeature(byte[] featureId) see also FeatureSe.removeFeature(byte[])
void	removeFeature(byte[] featureId, com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)
com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean>	removeFeatureByHex(java.lang.String featureId) see also FeatureSe.removeFeatureByHex(java.lang.String)
void	removeFeatureByHex(java.lang.String featureId, com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)
com.google.common.util.concurrent.ListenableFuture<CodeBean[]>	searchCode(byte[] code, double sim, int rows) see also FeatureSe.searchCode(byte[],double,int)
void	searchCode(byte[] code, double sim, int rows, com.google.common.util.concurrent.FutureCallback<CodeBean[]> callback)
com.google.common.util.concurrent.ListenableFuture<java.lang.Integer>	size() see also FeatureSe.size()
void	size(com.google.common.util.concurrent.FutureCallback<java.lang.Integer> callback)
boolean	testConnect() test if connectable for RPC service
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

FeatureSeThriftClientAsync

public FeatureSeThriftClientAsync(net.gdface.thrift.ClientFactory factory)

FeatureSeThriftClientAsync

public FeatureSeThriftClientAsync(java.lang.String host,
                                  int port)

Parameters:

host - RPC service host

port - RPC service port

FeatureSeThriftClientAsync

public FeatureSeThriftClientAsync(com.google.common.net.HostAndPort hostAndPort)

Parameters:

hostAndPort - RPC service host and port

Method Detail

getFactory

public net.gdface.thrift.ClientFactory getFactory()

testConnect

public boolean testConnect()

test if connectable for RPC service

Returns:

return true if connectable ,otherwise false

delegate

protected FeatureSe.Async delegate()

Returns:

返回FeatureSe.Async实例

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

addFeature

public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> addFeature(byte[] featureId,
                                                                                        byte[] feature,
                                                                                        java.lang.String imgMD5)

see also FeatureSe.addFeature(byte[],byte[],java.lang.String)

addFeature

public void addFeature(byte[] featureId,
                       byte[] feature,
                       java.lang.String imgMD5,
                       com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)

addFeature

public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> addFeature(byte[] featureId,
                                                                                        byte[] feature,
                                                                                        long appid)

see also FeatureSe.addFeature(byte[],byte[],long)

addFeature

public void addFeature(byte[] featureId,
                       byte[] feature,
                       long appid,
                       com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)

clearAll

public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> clearAll()

see also FeatureSe.clearAll()

clearAll

public void clearAll(com.google.common.util.concurrent.FutureCallback<java.lang.Void> callback)

getFeature

public com.google.common.util.concurrent.ListenableFuture<CodeBean> getFeature(byte[] featureId)

see also FeatureSe.getFeature(byte[])

getFeature

public void getFeature(byte[] featureId,
                       com.google.common.util.concurrent.FutureCallback<CodeBean> callback)

getFeatureByHex

public com.google.common.util.concurrent.ListenableFuture<CodeBean> getFeatureByHex(java.lang.String featureId)

see also FeatureSe.getFeatureByHex(java.lang.String)

getFeatureByHex

public void getFeatureByHex(java.lang.String featureId,
                            com.google.common.util.concurrent.FutureCallback<CodeBean> callback)

removeFeature

public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> removeFeature(byte[] featureId)

see also FeatureSe.removeFeature(byte[])

removeFeature

public void removeFeature(byte[] featureId,
                          com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)

removeFeatureByHex

public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> removeFeatureByHex(java.lang.String featureId)

see also FeatureSe.removeFeatureByHex(java.lang.String)

removeFeatureByHex

public void removeFeatureByHex(java.lang.String featureId,
                               com.google.common.util.concurrent.FutureCallback<java.lang.Boolean> callback)

searchCode

public com.google.common.util.concurrent.ListenableFuture<CodeBean[]> searchCode(byte[] code,
                                                                                 double sim,
                                                                                 int rows)

see also FeatureSe.searchCode(byte[],double,int)

searchCode

public void searchCode(byte[] code,
                       double sim,
                       int rows,
                       com.google.common.util.concurrent.FutureCallback<CodeBean[]> callback)

size

public com.google.common.util.concurrent.ListenableFuture<java.lang.Integer> size()

see also FeatureSe.size()

size

public void size(com.google.common.util.concurrent.FutureCallback<java.lang.Integer> callback)