KVSKVSClient Class

Client for KVS

Definition

Namespace: Aerospike.Client.KVS
Assembly: AerospikeClient (in AerospikeClient.dll) Version: 7.0.0
C#
public class KVSClient : ClientBase<KVSKVSClient>
Inheritance
Object    ClientBase    ClientBaseKVSKVSClient    KVSKVSClient

Constructors

KVSKVSClient(CallInvoker)Creates a new client for KVS that uses a custom CallInvoker.
KVSKVSClient(ChannelBase)Creates a new client for KVS

Methods

BatchOperate(AerospikeRequestPayload, CallOptions) Process batch requests.
BatchOperate(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Process batch requests.
BatchOperateStreaming(CallOptions) Process a stream of batch requests.
BatchOperateStreaming(Metadata, NullableDateTime, CancellationToken) Process a stream of batch requests.
Delete(AerospikeRequestPayload, CallOptions) Delete a single record.
Delete(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Delete a single record.
DeleteAsync(AerospikeRequestPayload, CallOptions) Delete a single record.
DeleteAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Delete a single record.
DeleteStreaming(CallOptions) Process a stream of single record delete requests.
DeleteStreaming(Metadata, NullableDateTime, CancellationToken) Process a stream of single record delete requests.
Execute(AerospikeRequestPayload, CallOptions) Execute single key user defined function on server and return results.
Execute(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Execute single key user defined function on server and return results.
ExecuteAsync(AerospikeRequestPayload, CallOptions) Execute single key user defined function on server and return results.
ExecuteAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Execute single key user defined function on server and return results.
ExecuteStreaming(CallOptions) Process a stream of single record execute requests.
ExecuteStreaming(Metadata, NullableDateTime, CancellationToken) Process a stream of single record execute requests.
Exists(AerospikeRequestPayload, CallOptions) Check if a record exists.
Exists(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Check if a record exists.
ExistsAsync(AerospikeRequestPayload, CallOptions) Check if a record exists.
ExistsAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Check if a record exists.
ExistsStreaming(CallOptions) Process stream of single record exist requests.
ExistsStreaming(Metadata, NullableDateTime, CancellationToken) Process stream of single record exist requests.
GetHeader(AerospikeRequestPayload, CallOptions) Get a single record header containing metadata like generation, expiration
GetHeader(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Get a single record header containing metadata like generation, expiration
GetHeaderAsync(AerospikeRequestPayload, CallOptions) Get a single record header containing metadata like generation, expiration
GetHeaderAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Get a single record header containing metadata like generation, expiration
GetHeaderStreaming(CallOptions) Process stream of single record get header requests.
GetHeaderStreaming(Metadata, NullableDateTime, CancellationToken) Process stream of single record get header requests.
Operate(AerospikeRequestPayload, CallOptions) Perform multiple read/write operations on a single key in one batch call.
Operate(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Perform multiple read/write operations on a single key in one batch call.
OperateAsync(AerospikeRequestPayload, CallOptions) Perform multiple read/write operations on a single key in one batch call.
OperateAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Perform multiple read/write operations on a single key in one batch call.
OperateStreaming(CallOptions) Perform a stream of operate requests.
OperateStreaming(Metadata, NullableDateTime, CancellationToken) Perform a stream of operate requests.
Read(AerospikeRequestPayload, CallOptions) Read a single record
Read(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Read a single record
ReadAsync(AerospikeRequestPayload, CallOptions) Read a single record
ReadAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Read a single record
ReadStreaming(CallOptions) Process stream of single record read requests.
ReadStreaming(Metadata, NullableDateTime, CancellationToken) Process stream of single record read requests.
Touch(AerospikeRequestPayload, CallOptions) Reset single record's time to expiration using the write policy's expiration.
Touch(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Reset single record's time to expiration using the write policy's expiration.
TouchAsync(AerospikeRequestPayload, CallOptions) Reset single record's time to expiration using the write policy's expiration.
TouchAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Reset single record's time to expiration using the write policy's expiration.
TouchStreaming(CallOptions) Process a stream of single record touch requests.
TouchStreaming(Metadata, NullableDateTime, CancellationToken) Process a stream of single record touch requests.
WithHost Creates a new client that sets host field for calls explicitly. gRPC supports multiple "hosts" being served by a single server. By default (if a client was not created by calling this method), host null with the meaning "use default host" is used.
(Inherited from ClientBaseKVSKVSClient)
Write(AerospikeRequestPayload, CallOptions) Write a single record
Write(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Write a single record
WriteAsync(AerospikeRequestPayload, CallOptions) Write a single record
WriteAsync(AerospikeRequestPayload, Metadata, NullableDateTime, CancellationToken) Write a single record
WriteStreaming(CallOptions) Process a stream of single record write requests.
WriteStreaming(Metadata, NullableDateTime, CancellationToken) Process a stream of single record write requests.

See Also