Package | Description |
---|---|
io.picodata.driver.api |
Contains interfaces and classes essential for end-user driver API
|
io.picodata.driver.api.tuple |
Contains tuple representation classes and helpers
|
io.picodata.driver.api.tuple.operations |
This sub-package is dedicated to Tarantool update and upsert operations
|
io.picodata.driver.codecs |
Contains implementations of Netty codecs
|
io.picodata.driver.core |
Driver core classes
|
io.picodata.driver.core.tuple |
Contains implementations of tuple representation classes and helpers
|
io.picodata.driver.mappers |
Contains converters and mappers that map Java object and MessagePack
|
io.picodata.driver.mappers.converters.object |
Contains converters that map Java object to MessagePack
|
io.picodata.driver.protocol |
Tarantool binary protocol primitives and helpers
|
io.picodata.driver.protocol.requests |
This sub-package is dedicated to Tarantool operation requests
|
Modifier and Type | Method and Description |
---|---|
<T> CompletableFuture<T> |
TarantoolCallOperations.call(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier)
Execute a function defined on Tarantool instance.
|
<T,R extends List<T>> |
TarantoolCallOperations.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier)
Execute a function defined on Tarantool instance.
|
<T,R extends List<T>> |
TarantoolCallOperations.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
Class<T> resultClass)
Execute a function defined on Tarantool instance.
|
<T,R extends List<T>> |
TarantoolCallOperations.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter)
Execute a function defined on Tarantool instance.
|
<T> CompletableFuture<T> |
TarantoolCallOperations.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> resultClass)
Execute a function defined on Tarantool instance.
|
<T> CompletableFuture<T> |
TarantoolCallOperations.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier)
Execute a function defined on Tarantool instance.
|
<T> CompletableFuture<T> |
TarantoolCallOperations.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter)
Execute a function defined on Tarantool instance.
|
<T> CompletableFuture<TarantoolResult<T>> |
TarantoolCallOperations.callForTupleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> entityClass)
Execute a function defined on Tarantool instance.
|
CompletableFuture<List<?>> |
TarantoolEvalOperations.eval(String expression,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<? extends MessagePackValueMapper> resultMapperSupplier)
Execute a Lua expression in the Tarantool instance.
|
Modifier and Type | Method and Description |
---|---|
org.msgpack.value.Value |
TarantoolNullField.toMessagePackValue(MessagePackObjectMapper mapper) |
Modifier and Type | Method and Description |
---|---|
org.msgpack.value.Value |
TupleSpliceOperation.toMessagePackValue(MessagePackObjectMapper mapper) |
Constructor and Description |
---|
MessagePackFrameEncoder(MessagePackObjectMapper mapper) |
Modifier and Type | Method and Description |
---|---|
<T> CompletableFuture<T> |
ProxyTarantoolClient.call(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) |
<T> CompletableFuture<T> |
RetryingTarantoolClient.call(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) |
<T> CompletableFuture<T> |
AbstractTarantoolClient.call(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) |
<T,R extends List<T>> |
ProxyTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) |
<T,R extends List<T>> |
RetryingTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) |
<T,R extends List<T>> |
AbstractTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<R,MultiValueCallResult<T,R>>> resultMapperSupplier) |
<T,R extends List<T>> |
ProxyTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
Class<T> resultClass) |
<T,R extends List<T>> |
RetryingTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
Class<T> resultClass) |
<T,R extends List<T>> |
AbstractTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
Class<T> resultClass) |
<T,R extends List<T>> |
ProxyTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter) |
<T,R extends List<T>> |
RetryingTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter) |
<T,R extends List<T>> |
AbstractTarantoolClient.callForMultiResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<R> resultContainerSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter) |
<S> CompletableFuture<S> |
AbstractTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<S> resultClass) |
<T> CompletableFuture<T> |
ProxyTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> resultClass) |
<T> CompletableFuture<T> |
RetryingTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> resultClass) |
<S> CompletableFuture<S> |
AbstractTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<S,SingleValueCallResult<S>>> resultMapperSupplier) |
<T> CompletableFuture<T> |
ProxyTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) |
<T> CompletableFuture<T> |
RetryingTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<CallResultMapper<T,SingleValueCallResult<T>>> resultMapperSupplier) |
<S> CompletableFuture<S> |
AbstractTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
ValueConverter<org.msgpack.value.Value,S> valueConverter) |
<T> CompletableFuture<T> |
ProxyTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter) |
<T> CompletableFuture<T> |
RetryingTarantoolClient.callForSingleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
ValueConverter<org.msgpack.value.Value,T> valueConverter) |
<T> CompletableFuture<TarantoolResult<T>> |
ProxyTarantoolClient.callForTupleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> entityClass) |
<T> CompletableFuture<TarantoolResult<T>> |
RetryingTarantoolClient.callForTupleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> entityClass) |
<T> CompletableFuture<TarantoolResult<T>> |
AbstractTarantoolClient.callForTupleResult(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<T> tupleClass) |
CompletableFuture<List<?>> |
ProxyTarantoolClient.eval(String expression,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<? extends MessagePackValueMapper> resultMapperSupplier) |
CompletableFuture<List<?>> |
RetryingTarantoolClient.eval(String expression,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<? extends MessagePackValueMapper> resultMapperSupplier) |
CompletableFuture<List<?>> |
AbstractTarantoolClient.eval(String expression,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<? extends MessagePackValueMapper> resultMapperSupplier) |
Modifier and Type | Method and Description |
---|---|
org.msgpack.value.Value |
TarantoolTupleImpl.toMessagePackValue(MessagePackObjectMapper mapper) |
org.msgpack.value.Value |
TarantoolFieldImpl.toMessagePackValue(MessagePackObjectMapper mapper) |
Modifier and Type | Interface and Description |
---|---|
interface |
MessagePackMapper
Combines both ObjectMapper and ValueMapper interfaces
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultMessagePackMapper
Default implementation of
MessagePackObjectMapper and MessagePackValueMapper . |
Constructor and Description |
---|
DefaultCollectionToArrayValueConverter(MessagePackObjectMapper mapper) |
DefaultListToArrayValueConverter(MessagePackObjectMapper mapper) |
DefaultMapToMapValueConverter(MessagePackObjectMapper mapper) |
DefaultPackableObjectConverter(MessagePackObjectMapper mapper) |
Modifier and Type | Method and Description |
---|---|
void |
TarantoolRequest.toMessagePack(org.msgpack.core.MessagePacker packer,
MessagePackObjectMapper mapper)
Encode incapsulated data using
MessagePacker |
org.msgpack.value.Value |
TarantoolRequestBody.toMessagePackValue(MessagePackObjectMapper mapper) |
org.msgpack.value.Value |
TarantoolHeader.toMessagePackValue(MessagePackObjectMapper mapper)
Converts the current header contents into a MessagePack
Value |
org.msgpack.value.Value |
Packable.toMessagePackValue(MessagePackObjectMapper mapper)
Convert this instance into a corresponding MessagePack
Value |
Modifier and Type | Method and Description |
---|---|
static TarantoolRequestSignature |
TarantoolRequestSignature.create(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Class<?> resultClass)
Factory method for caching default result mapper suppliers
|
static TarantoolRequestSignature |
TarantoolRequestSignature.create(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<?> resultContainerSupplier,
Class<?> resultClass)
Factory method for caching default multi value result mapper suppliers
|
static TarantoolRequestSignature |
TarantoolRequestSignature.create(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<?> resultContainerSupplier,
ValueConverter<org.msgpack.value.Value,?> valueConverter)
Factory method for caching default multi value result mapper suppliers
|
static TarantoolRequestSignature |
TarantoolRequestSignature.create(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
Supplier<? extends MessagePackValueMapper> resultMapperSupplier)
Factory method for a typical RPC usage
|
static TarantoolRequestSignature |
TarantoolRequestSignature.create(String functionName,
Collection<?> arguments,
Supplier<? extends MessagePackObjectMapper> argumentsMapperSupplier,
ValueConverter<org.msgpack.value.Value,?> valueConverter)
Factory method for caching default result mapper suppliers
|
Constructor and Description |
---|
TarantoolRequestBody(Map<Integer,?> body,
MessagePackObjectMapper mapper)
Basic constructor.
|
Copyright © 2025 Picodata. All rights reserved.