| Package | Description |
|---|---|
| com.taosdata.jdbc.ws | |
| com.taosdata.jdbc.ws.entity | |
| com.taosdata.jdbc.ws.stmt2.entity | |
| com.taosdata.jdbc.ws.tmq | |
| com.taosdata.jdbc.ws.tmq.entity |
| Modifier and Type | Method and Description |
|---|---|
Response |
Transport.send(Request request)
Sends a request with default timeout and retry enabled.
|
Response |
Transport.send(Request request,
boolean reSend,
long timeout)
Sends a request with specified timeout and retry configuration.
|
Response |
Transport.send(Request request,
long timeout)
Sends a request with specified timeout and retry enabled.
|
Response |
Transport.send(String action,
long reqId,
io.netty.buffer.ByteBuf buffer,
boolean resend,
long timeout)
Sends a request with pre-allocated ByteBuf buffer.
|
Response |
Transport.send(String action,
long reqId,
long resultId,
long type,
byte[] rawData,
byte[] rawData2,
long timeout)
Sends a binary request with dual data payloads.
|
Response |
Transport.send(String action,
long reqId,
long resultId,
long type,
byte[] rawData,
long timeout)
Sends a binary request with single data payload.
|
Response |
Transport.sendWithoutRetry(Request request,
long timeout)
Sends a request without automatic retry on connection failure.
|
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<Response> |
FutureResponse.getFuture() |
| Constructor and Description |
|---|
FutureResponse(String action,
Long id,
CompletableFuture<Response> future) |
| Modifier and Type | Class and Description |
|---|---|
class |
CommonResp |
class |
ConnectResp
connection result pojo
|
class |
FetchBlockHealthCheckResp |
class |
FetchBlockNewResp |
class |
QueryResp
query result pojo
|
class |
VersionResp
connection result pojo
|
| Modifier and Type | Method and Description |
|---|---|
Class<? extends Response> |
Action.getResponseClazz() |
| Modifier and Type | Class and Description |
|---|---|
class |
ResultResp
query result pojo
|
class |
Stmt2ExecResp |
class |
Stmt2PrepareResp |
class |
Stmt2Resp |
| Modifier and Type | Method and Description |
|---|---|
Class<? extends Response> |
ConsumerAction.getResponseClazz() |
| Modifier and Type | Class and Description |
|---|---|
class |
AssignmentResp |
class |
CommitOffsetResp |
class |
CommitResp |
class |
CommittedResp |
class |
FetchJsonMetaResp |
class |
FetchRawBlockResp |
class |
FetchResp |
class |
ListTopicsResp |
class |
PollResp |
class |
PositionResp |
class |
SeekResp |
class |
SubscribeResp |
class |
UnsubscribeResp |
Copyright © 2025. All rights reserved.