Package io.weaviate.client.base

Class AsyncBaseClient<T>

java.lang.Object

io.weaviate.client.base.AsyncBaseClient<T>

Direct Known Subclasses:

Activator, Aggregate, AllGetter, AssignedRolesGetter, AssignedUsersGetter, AsyncBaseGraphQLClient, BackupCanceler, BackupCreateStatusGetter, BackupCreator, BackupGetter, BackupRestorer, BackupRestoreStatusGetter, ByNameGetter, ClassCreator, ClassDeleter, ClassExists, ClassGetter, ClassUpdater, Creator, Deactivator, Deleter, Explore, Getter, KeyRotator, LiveChecker, MetaGetter, MyUserGetter, NodesStatusGetter, ObjectCreator, ObjectDeleter, ObjectsBatchDeleter, ObjectsBatcher, ObjectsChecker, ObjectsGetter, ObjectUpdater, ObjectValidator, OpenIDConfigGetter, PermissionAdder, PermissionChecker, PermissionRemover, PropertyCreator, Raw, ReadyChecker, ReferenceCreator, ReferenceDeleter, ReferenceReplacer, ReferencesBatcher, RoleAllGetter, RoleAssigner, RoleCreator, RoleDeleter, RoleExists, RoleGetter, RoleRevoker, Scheduler, SchemaGetter, ShardsGetter, ShardsUpdater, ShardUpdater, TenantsCreator, TenantsDeleter, TenantsExists, TenantsGetter, TenantsUpdater, UserAssignmentsGetter, UserRolesGetter, VectorAdder

public abstract class AsyncBaseClient<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient	client

Constructor Summary

Constructors

Constructor	Description
AsyncBaseClient(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client, Config config, AccessTokenProvider tokenProvider)

Method Summary

Modifier and Type	Method	Description
protected org.apache.hc.client5.http.async.methods.SimpleHttpRequest	getRequest(String endpoint, Object payload, String method)
protected Future<Result<T>>	sendDeleteRequest(String endpoint, Object payload, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendDeleteRequest(String endpoint, Object payload, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)
protected Future<Result<T>>	sendGetRequest(String endpoint, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendGetRequest(String endpoint, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)
protected Future<Result<T>>	sendHeadRequest(String endpoint, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendHeadRequest(String endpoint, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)
protected Future<Result<T>>	sendPatchRequest(String endpoint, Object payload, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendPatchRequest(String endpoint, Object payload, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)
protected Future<Result<T>>	sendPostRequest(String endpoint, Object payload, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendPostRequest(String endpoint, Object payload, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)
protected Future<Result<T>>	sendPutRequest(String endpoint, Object payload, Class<T> classOfT, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)
protected Future<Result<T>>	sendPutRequest(String endpoint, Object payload, org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback, ResponseParser<T> parser)

Methods inherited from class java.lang.Object

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

Field Details

client

protected final org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client

Constructor Details

AsyncBaseClient

public AsyncBaseClient(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client,
 Config config,
 AccessTokenProvider tokenProvider)

Method Details

sendGetRequest

protected Future<Result<T>> sendGetRequest(String endpoint,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendGetRequest

protected Future<Result<T>> sendGetRequest(String endpoint,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

sendPostRequest

protected Future<Result<T>> sendPostRequest(String endpoint,
 Object payload,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendPostRequest

protected Future<Result<T>> sendPostRequest(String endpoint,
 Object payload,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

sendPutRequest

protected Future<Result<T>> sendPutRequest(String endpoint,
 Object payload,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendPutRequest

protected Future<Result<T>> sendPutRequest(String endpoint,
 Object payload,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

sendPatchRequest

protected Future<Result<T>> sendPatchRequest(String endpoint,
 Object payload,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendPatchRequest

protected Future<Result<T>> sendPatchRequest(String endpoint,
 Object payload,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

sendDeleteRequest

protected Future<Result<T>> sendDeleteRequest(String endpoint,
 Object payload,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendDeleteRequest

protected Future<Result<T>> sendDeleteRequest(String endpoint,
 Object payload,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

sendHeadRequest

protected Future<Result<T>> sendHeadRequest(String endpoint,
 Class<T> classOfT,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback)

sendHeadRequest

protected Future<Result<T>> sendHeadRequest(String endpoint,
 org.apache.hc.core5.concurrent.FutureCallback<Result<T>> callback,
 ResponseParser<T> parser)

getRequest

protected org.apache.hc.client5.http.async.methods.SimpleHttpRequest getRequest(String endpoint,
 Object payload,
 String method)