Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kvs

package

Go to main page

Versions in this module

v6

v6.15.1

Apr 10, 2024

v6.15.0

Jan 25, 2024

v6.14.1

Nov 1, 2023

v6.14.0

Aug 23, 2023

Changes in this version

+ var About_ServiceDesc = grpc.ServiceDesc

+ var BackgroundTaskStatus_name = map[int32]string

+ var BackgroundTaskStatus_value = map[string]int32

+ var CommitLevel_name = map[int32]string

+ var CommitLevel_value = map[string]int32

+ var File_kv_proto protoreflect.FileDescriptor

+ var GenerationPolicy_name = map[int32]string

+ var GenerationPolicy_value = map[string]int32

+ var IndexCollectionType_name = map[int32]string

+ var IndexCollectionType_value = map[string]int32

+ var KVS_ServiceDesc = grpc.ServiceDesc

+ var OperationType_name = map[int32]string

+ var OperationType_value = map[string]int32

+ var Query_ServiceDesc = grpc.ServiceDesc

+ var ReadModeAP_name = map[int32]string

+ var ReadModeAP_value = map[string]int32

+ var ReadModeSC_name = map[int32]string

+ var ReadModeSC_value = map[string]int32

+ var RecordExistsAction_name = map[int32]string

+ var RecordExistsAction_value = map[string]int32

+ var Replica_name = map[int32]string

+ var Replica_value = map[string]int32

+ var Scan_ServiceDesc = grpc.ServiceDesc

+ func RegisterAboutServer(s grpc.ServiceRegistrar, srv AboutServer)

+ func RegisterKVSServer(s grpc.ServiceRegistrar, srv KVSServer)

+ func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

+ func RegisterScanServer(s grpc.ServiceRegistrar, srv ScanServer)

+ type AbortRequest struct

+ AbortId uint32

+ func (*AbortRequest) Descriptor() ([]byte, []int)

+ func (*AbortRequest) ProtoMessage()

+ func (x *AbortRequest) GetAbortId() uint32

+ func (x *AbortRequest) ProtoReflect() protoreflect.Message

+ func (x *AbortRequest) Reset()

+ func (x *AbortRequest) String() string

+ type AboutClient interface

+ Get func(ctx context.Context, in *AboutRequest, opts ...grpc.CallOption) (*AboutResponse, error)

+ func NewAboutClient(cc grpc.ClientConnInterface) AboutClient

+ type AboutRequest struct

+ func (*AboutRequest) Descriptor() ([]byte, []int)

+ func (*AboutRequest) ProtoMessage()

+ func (x *AboutRequest) ProtoReflect() protoreflect.Message

+ func (x *AboutRequest) Reset()

+ func (x *AboutRequest) String() string

+ type AboutResponse struct

+ Version string

+ func (*AboutResponse) Descriptor() ([]byte, []int)

+ func (*AboutResponse) ProtoMessage()

+ func (x *AboutResponse) GetVersion() string

+ func (x *AboutResponse) ProtoReflect() protoreflect.Message

+ func (x *AboutResponse) Reset()

+ func (x *AboutResponse) String() string

+ type AboutServer interface

+ Get func(context.Context, *AboutRequest) (*AboutResponse, error)

+ type AerospikeRequestPayload struct

+ AbortRequest *AbortRequest

+ BackgroundExecuteRequest *BackgroundExecuteRequest

+ BackgroundTaskStatusRequest *BackgroundTaskStatusRequest

+ Id uint32

+ Iteration uint32

+ Payload []byte

+ QueryRequest *QueryRequest

+ ReadPolicy *ReadPolicy

+ ScanRequest *ScanRequest

+ WritePolicy *WritePolicy

+ func (*AerospikeRequestPayload) Descriptor() ([]byte, []int)

+ func (*AerospikeRequestPayload) ProtoMessage()

+ func (x *AerospikeRequestPayload) GetAbortRequest() *AbortRequest

+ func (x *AerospikeRequestPayload) GetBackgroundExecuteRequest() *BackgroundExecuteRequest

+ func (x *AerospikeRequestPayload) GetBackgroundTaskStatusRequest() *BackgroundTaskStatusRequest

+ func (x *AerospikeRequestPayload) GetId() uint32

+ func (x *AerospikeRequestPayload) GetIteration() uint32

+ func (x *AerospikeRequestPayload) GetPayload() []byte

+ func (x *AerospikeRequestPayload) GetQueryRequest() *QueryRequest

+ func (x *AerospikeRequestPayload) GetReadPolicy() *ReadPolicy

+ func (x *AerospikeRequestPayload) GetScanRequest() *ScanRequest

+ func (x *AerospikeRequestPayload) GetWritePolicy() *WritePolicy

+ func (x *AerospikeRequestPayload) ProtoReflect() protoreflect.Message

+ func (x *AerospikeRequestPayload) Reset()

+ func (x *AerospikeRequestPayload) String() string

+ type AerospikeResponsePayload struct

+ BackgroundTaskStatus *BackgroundTaskStatus

+ HasNext bool

+ Id uint32

+ InDoubt bool

+ Payload []byte

+ Status int32

+ func (*AerospikeResponsePayload) Descriptor() ([]byte, []int)

+ func (*AerospikeResponsePayload) ProtoMessage()

+ func (x *AerospikeResponsePayload) GetBackgroundTaskStatus() BackgroundTaskStatus

+ func (x *AerospikeResponsePayload) GetHasNext() bool

+ func (x *AerospikeResponsePayload) GetId() uint32

+ func (x *AerospikeResponsePayload) GetInDoubt() bool

+ func (x *AerospikeResponsePayload) GetPayload() []byte

+ func (x *AerospikeResponsePayload) GetStatus() int32

+ func (x *AerospikeResponsePayload) ProtoReflect() protoreflect.Message

+ func (x *AerospikeResponsePayload) Reset()

+ func (x *AerospikeResponsePayload) String() string

+ type BackgroundExecutePolicy struct

+ CommitLevel *CommitLevel

+ Compress bool

+ DurableDelete *bool

+ Expiration *uint32

+ Expression []byte

+ Generation *uint32

+ GenerationPolicy *GenerationPolicy

+ ReadModeAP ReadModeAP

+ ReadModeSC ReadModeSC

+ RecordExistsAction *RecordExistsAction

+ Replica Replica

+ RespondAllOps *bool

+ SendKey *bool

+ TotalTimeout *uint32

+ Xdr *bool

+ func (*BackgroundExecutePolicy) Descriptor() ([]byte, []int)

+ func (*BackgroundExecutePolicy) ProtoMessage()

+ func (x *BackgroundExecutePolicy) GetCommitLevel() CommitLevel

+ func (x *BackgroundExecutePolicy) GetCompress() bool

+ func (x *BackgroundExecutePolicy) GetDurableDelete() bool

+ func (x *BackgroundExecutePolicy) GetExpiration() uint32

+ func (x *BackgroundExecutePolicy) GetExpression() []byte

+ func (x *BackgroundExecutePolicy) GetGeneration() uint32

+ func (x *BackgroundExecutePolicy) GetGenerationPolicy() GenerationPolicy

+ func (x *BackgroundExecutePolicy) GetReadModeAP() ReadModeAP

+ func (x *BackgroundExecutePolicy) GetReadModeSC() ReadModeSC

+ func (x *BackgroundExecutePolicy) GetRecordExistsAction() RecordExistsAction

+ func (x *BackgroundExecutePolicy) GetReplica() Replica

+ func (x *BackgroundExecutePolicy) GetRespondAllOps() bool

+ func (x *BackgroundExecutePolicy) GetSendKey() bool

+ func (x *BackgroundExecutePolicy) GetTotalTimeout() uint32

+ func (x *BackgroundExecutePolicy) GetXdr() bool

+ func (x *BackgroundExecutePolicy) ProtoReflect() protoreflect.Message

+ func (x *BackgroundExecutePolicy) Reset()

+ func (x *BackgroundExecutePolicy) String() string

+ type BackgroundExecuteRequest struct

+ Statement *Statement

+ WritePolicy *BackgroundExecutePolicy

+ func (*BackgroundExecuteRequest) Descriptor() ([]byte, []int)

+ func (*BackgroundExecuteRequest) ProtoMessage()

+ func (x *BackgroundExecuteRequest) GetStatement() *Statement

+ func (x *BackgroundExecuteRequest) GetWritePolicy() *BackgroundExecutePolicy

+ func (x *BackgroundExecuteRequest) ProtoReflect() protoreflect.Message

+ func (x *BackgroundExecuteRequest) Reset()

+ func (x *BackgroundExecuteRequest) String() string

+ type BackgroundTaskStatus int32

+ const BackgroundTaskStatus_COMPLETE

+ const BackgroundTaskStatus_IN_PROGRESS

+ const BackgroundTaskStatus_NOT_FOUND

+ func (BackgroundTaskStatus) Descriptor() protoreflect.EnumDescriptor

+ func (BackgroundTaskStatus) EnumDescriptor() ([]byte, []int)

+ func (BackgroundTaskStatus) Type() protoreflect.EnumType

+ func (x BackgroundTaskStatus) Enum() *BackgroundTaskStatus

+ func (x BackgroundTaskStatus) Number() protoreflect.EnumNumber

+ func (x BackgroundTaskStatus) String() string

+ type BackgroundTaskStatusRequest struct

+ IsScan bool

+ TaskId int64

+ func (*BackgroundTaskStatusRequest) Descriptor() ([]byte, []int)

+ func (*BackgroundTaskStatusRequest) ProtoMessage()

+ func (x *BackgroundTaskStatusRequest) GetIsScan() bool

+ func (x *BackgroundTaskStatusRequest) GetTaskId() int64

+ func (x *BackgroundTaskStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *BackgroundTaskStatusRequest) Reset()

+ func (x *BackgroundTaskStatusRequest) String() string

+ type CommitLevel int32

+ const CommitLevel_COMMIT_ALL

+ const CommitLevel_COMMIT_MASTER

+ func (CommitLevel) Descriptor() protoreflect.EnumDescriptor

+ func (CommitLevel) EnumDescriptor() ([]byte, []int)

+ func (CommitLevel) Type() protoreflect.EnumType

+ func (x CommitLevel) Enum() *CommitLevel

+ func (x CommitLevel) Number() protoreflect.EnumNumber

+ func (x CommitLevel) String() string

+ type Filter struct

+ Begin []byte

+ ColType IndexCollectionType

+ End []byte

+ Name string

+ PackedCtx []byte

+ ValType int32

+ func (*Filter) Descriptor() ([]byte, []int)

+ func (*Filter) ProtoMessage()

+ func (x *Filter) GetBegin() []byte

+ func (x *Filter) GetColType() IndexCollectionType

+ func (x *Filter) GetEnd() []byte

+ func (x *Filter) GetName() string

+ func (x *Filter) GetPackedCtx() []byte

+ func (x *Filter) GetValType() int32

+ func (x *Filter) ProtoReflect() protoreflect.Message

+ func (x *Filter) Reset()

+ func (x *Filter) String() string

+ type GenerationPolicy int32

+ const GenerationPolicy_EXPECT_GEN_EQUAL

+ const GenerationPolicy_EXPECT_GEN_GT

+ const GenerationPolicy_NONE

+ func (GenerationPolicy) Descriptor() protoreflect.EnumDescriptor

+ func (GenerationPolicy) EnumDescriptor() ([]byte, []int)

+ func (GenerationPolicy) Type() protoreflect.EnumType

+ func (x GenerationPolicy) Enum() *GenerationPolicy

+ func (x GenerationPolicy) Number() protoreflect.EnumNumber

+ func (x GenerationPolicy) String() string

+ type IndexCollectionType int32

+ const IndexCollectionType_DEFAULT

+ const IndexCollectionType_LIST

+ const IndexCollectionType_MAPKEYS

+ const IndexCollectionType_MAPVALUES

+ func (IndexCollectionType) Descriptor() protoreflect.EnumDescriptor

+ func (IndexCollectionType) EnumDescriptor() ([]byte, []int)

+ func (IndexCollectionType) Type() protoreflect.EnumType

+ func (x IndexCollectionType) Enum() *IndexCollectionType

+ func (x IndexCollectionType) Number() protoreflect.EnumNumber

+ func (x IndexCollectionType) String() string

+ type KVSClient interface

+ BatchOperate func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (KVS_BatchOperateClient, error)

+ BatchOperateStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_BatchOperateStreamingClient, error)

+ Delete func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ DeleteStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_DeleteStreamingClient, error)

+ Execute func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ ExecuteStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_ExecuteStreamingClient, error)

+ Exists func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ ExistsStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_ExistsStreamingClient, error)

+ GetHeader func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ GetHeaderStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_GetHeaderStreamingClient, error)

+ Operate func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ OperateStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_OperateStreamingClient, error)

+ Read func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ ReadStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_ReadStreamingClient, error)

+ Touch func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ TouchStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_TouchStreamingClient, error)

+ Write func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (*AerospikeResponsePayload, error)

+ WriteStreaming func(ctx context.Context, opts ...grpc.CallOption) (KVS_WriteStreamingClient, error)

+ func NewKVSClient(cc grpc.ClientConnInterface) KVSClient

+ type KVSServer interface

+ BatchOperate func(*AerospikeRequestPayload, KVS_BatchOperateServer) error

+ BatchOperateStreaming func(KVS_BatchOperateStreamingServer) error

+ Delete func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ DeleteStreaming func(KVS_DeleteStreamingServer) error

+ Execute func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ ExecuteStreaming func(KVS_ExecuteStreamingServer) error

+ Exists func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ ExistsStreaming func(KVS_ExistsStreamingServer) error

+ GetHeader func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ GetHeaderStreaming func(KVS_GetHeaderStreamingServer) error

+ Operate func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ OperateStreaming func(KVS_OperateStreamingServer) error

+ Read func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ ReadStreaming func(KVS_ReadStreamingServer) error

+ Touch func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ TouchStreaming func(KVS_TouchStreamingServer) error

+ Write func(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ WriteStreaming func(KVS_WriteStreamingServer) error

+ type KVS_BatchOperateClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ type KVS_BatchOperateServer interface

+ Send func(*AerospikeResponsePayload) error

+ type KVS_BatchOperateStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_BatchOperateStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_DeleteStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_DeleteStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_ExecuteStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_ExecuteStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_ExistsStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_ExistsStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_GetHeaderStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_GetHeaderStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_OperateStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_OperateStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_ReadStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_ReadStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_TouchStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_TouchStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type KVS_WriteStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type KVS_WriteStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type Operation struct

+ BinName *string

+ Type OperationType

+ Value []byte

+ func (*Operation) Descriptor() ([]byte, []int)

+ func (*Operation) ProtoMessage()

+ func (x *Operation) GetBinName() string

+ func (x *Operation) GetType() OperationType

+ func (x *Operation) GetValue() []byte

+ func (x *Operation) ProtoReflect() protoreflect.Message

+ func (x *Operation) Reset()

+ func (x *Operation) String() string

+ type OperationType int32

+ const OperationType_ADD

+ const OperationType_APPEND

+ const OperationType_BIT_MODIFY

+ const OperationType_BIT_READ

+ const OperationType_CDT_MODIFY

+ const OperationType_CDT_READ

+ const OperationType_DELETE

+ const OperationType_EXP_MODIFY

+ const OperationType_EXP_READ

+ const OperationType_HLL_MODIFY

+ const OperationType_HLL_READ

+ const OperationType_MAP_MODIFY

+ const OperationType_MAP_READ

+ const OperationType_PREPEND

+ const OperationType_READ

+ const OperationType_READ_HEADER

+ const OperationType_TOUCH

+ const OperationType_WRITE

+ func (OperationType) Descriptor() protoreflect.EnumDescriptor

+ func (OperationType) EnumDescriptor() ([]byte, []int)

+ func (OperationType) Type() protoreflect.EnumType

+ func (x OperationType) Enum() *OperationType

+ func (x OperationType) Number() protoreflect.EnumNumber

+ func (x OperationType) String() string

+ type PartitionFilter struct

+ Begin *uint32

+ Count uint32

+ Digest []byte

+ PartitionStatuses []*PartitionStatus

+ Retry bool

+ func (*PartitionFilter) Descriptor() ([]byte, []int)

+ func (*PartitionFilter) ProtoMessage()

+ func (x *PartitionFilter) GetBegin() uint32

+ func (x *PartitionFilter) GetCount() uint32

+ func (x *PartitionFilter) GetDigest() []byte

+ func (x *PartitionFilter) GetPartitionStatuses() []*PartitionStatus

+ func (x *PartitionFilter) GetRetry() bool

+ func (x *PartitionFilter) ProtoReflect() protoreflect.Message

+ func (x *PartitionFilter) Reset()

+ func (x *PartitionFilter) String() string

+ type PartitionStatus struct

+ BVal *int64

+ Digest []byte

+ Id *uint32

+ Retry bool

+ func (*PartitionStatus) Descriptor() ([]byte, []int)

+ func (*PartitionStatus) ProtoMessage()

+ func (x *PartitionStatus) GetBVal() int64

+ func (x *PartitionStatus) GetDigest() []byte

+ func (x *PartitionStatus) GetId() uint32

+ func (x *PartitionStatus) GetRetry() bool

+ func (x *PartitionStatus) ProtoReflect() protoreflect.Message

+ func (x *PartitionStatus) Reset()

+ func (x *PartitionStatus) String() string

+ type QueryClient interface

+ BackgroundExecute func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (Query_BackgroundExecuteClient, error)

+ BackgroundExecuteStreaming func(ctx context.Context, opts ...grpc.CallOption) (Query_BackgroundExecuteStreamingClient, error)

+ BackgroundTaskStatus func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (Query_BackgroundTaskStatusClient, error)

+ BackgroundTaskStatusStreaming func(ctx context.Context, opts ...grpc.CallOption) (Query_BackgroundTaskStatusStreamingClient, error)

+ Query func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (Query_QueryClient, error)

+ QueryStreaming func(ctx context.Context, opts ...grpc.CallOption) (Query_QueryStreamingClient, error)

+ func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

+ type QueryPolicy struct

+ Compress bool

+ Expression []byte

+ FailOnClusterChange *bool

+ IncludeBinData *bool

+ InfoTimeout *uint32

+ MaxConcurrentNodes *uint32

+ ReadModeAP ReadModeAP

+ ReadModeSC ReadModeSC

+ RecordQueueSize *uint32

+ Replica Replica

+ SendKey *bool

+ ShortQuery *bool

+ TotalTimeout *uint32

+ func (*QueryPolicy) Descriptor() ([]byte, []int)

+ func (*QueryPolicy) ProtoMessage()

+ func (x *QueryPolicy) GetCompress() bool

+ func (x *QueryPolicy) GetExpression() []byte

+ func (x *QueryPolicy) GetFailOnClusterChange() bool

+ func (x *QueryPolicy) GetIncludeBinData() bool

+ func (x *QueryPolicy) GetInfoTimeout() uint32

+ func (x *QueryPolicy) GetMaxConcurrentNodes() uint32

+ func (x *QueryPolicy) GetReadModeAP() ReadModeAP

+ func (x *QueryPolicy) GetReadModeSC() ReadModeSC

+ func (x *QueryPolicy) GetRecordQueueSize() uint32

+ func (x *QueryPolicy) GetReplica() Replica

+ func (x *QueryPolicy) GetSendKey() bool

+ func (x *QueryPolicy) GetShortQuery() bool

+ func (x *QueryPolicy) GetTotalTimeout() uint32

+ func (x *QueryPolicy) ProtoReflect() protoreflect.Message

+ func (x *QueryPolicy) Reset()

+ func (x *QueryPolicy) String() string

+ type QueryRequest struct

+ Background bool

+ PartitionFilter *PartitionFilter

+ QueryPolicy *QueryPolicy

+ Statement *Statement

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (x *QueryRequest) GetBackground() bool

+ func (x *QueryRequest) GetPartitionFilter() *PartitionFilter

+ func (x *QueryRequest) GetQueryPolicy() *QueryPolicy

+ func (x *QueryRequest) GetStatement() *Statement

+ func (x *QueryRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryRequest) Reset()

+ func (x *QueryRequest) String() string

+ type QueryServer interface

+ BackgroundExecute func(*AerospikeRequestPayload, Query_BackgroundExecuteServer) error

+ BackgroundExecuteStreaming func(Query_BackgroundExecuteStreamingServer) error

+ BackgroundTaskStatus func(*AerospikeRequestPayload, Query_BackgroundTaskStatusServer) error

+ BackgroundTaskStatusStreaming func(Query_BackgroundTaskStatusStreamingServer) error

+ Query func(*AerospikeRequestPayload, Query_QueryServer) error

+ QueryStreaming func(Query_QueryStreamingServer) error

+ type Query_BackgroundExecuteClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ type Query_BackgroundExecuteServer interface

+ Send func(*AerospikeResponsePayload) error

+ type Query_BackgroundExecuteStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type Query_BackgroundExecuteStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type Query_BackgroundTaskStatusClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ type Query_BackgroundTaskStatusServer interface

+ Send func(*AerospikeResponsePayload) error

+ type Query_BackgroundTaskStatusStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type Query_BackgroundTaskStatusStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type Query_QueryClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ type Query_QueryServer interface

+ Send func(*AerospikeResponsePayload) error

+ type Query_QueryStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type Query_QueryStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type ReadModeAP int32

+ const ReadModeAP_ALL

+ const ReadModeAP_ONE

+ func (ReadModeAP) Descriptor() protoreflect.EnumDescriptor

+ func (ReadModeAP) EnumDescriptor() ([]byte, []int)

+ func (ReadModeAP) Type() protoreflect.EnumType

+ func (x ReadModeAP) Enum() *ReadModeAP

+ func (x ReadModeAP) Number() protoreflect.EnumNumber

+ func (x ReadModeAP) String() string

+ type ReadModeSC int32

+ const ReadModeSC_ALLOW_REPLICA

+ const ReadModeSC_ALLOW_UNAVAILABLE

+ const ReadModeSC_LINEARIZE

+ const ReadModeSC_SESSION

+ func (ReadModeSC) Descriptor() protoreflect.EnumDescriptor

+ func (ReadModeSC) EnumDescriptor() ([]byte, []int)

+ func (ReadModeSC) Type() protoreflect.EnumType

+ func (x ReadModeSC) Enum() *ReadModeSC

+ func (x ReadModeSC) Number() protoreflect.EnumNumber

+ func (x ReadModeSC) String() string

+ type ReadPolicy struct

+ ReadModeAP ReadModeAP

+ ReadModeSC ReadModeSC

+ Replica Replica

+ func (*ReadPolicy) Descriptor() ([]byte, []int)

+ func (*ReadPolicy) ProtoMessage()

+ func (x *ReadPolicy) GetReadModeAP() ReadModeAP

+ func (x *ReadPolicy) GetReadModeSC() ReadModeSC

+ func (x *ReadPolicy) GetReplica() Replica

+ func (x *ReadPolicy) ProtoReflect() protoreflect.Message

+ func (x *ReadPolicy) Reset()

+ func (x *ReadPolicy) String() string

+ type RecordExistsAction int32

+ const RecordExistsAction_CREATE_ONLY

+ const RecordExistsAction_REPLACE

+ const RecordExistsAction_REPLACE_ONLY

+ const RecordExistsAction_UPDATE

+ const RecordExistsAction_UPDATE_ONLY

+ func (RecordExistsAction) Descriptor() protoreflect.EnumDescriptor

+ func (RecordExistsAction) EnumDescriptor() ([]byte, []int)

+ func (RecordExistsAction) Type() protoreflect.EnumType

+ func (x RecordExistsAction) Enum() *RecordExistsAction

+ func (x RecordExistsAction) Number() protoreflect.EnumNumber

+ func (x RecordExistsAction) String() string

+ type Replica int32

+ const Replica_MASTER

+ const Replica_MASTER_PROLES

+ const Replica_PREFER_RACK

+ const Replica_RANDOM

+ const Replica_SEQUENCE

+ func (Replica) Descriptor() protoreflect.EnumDescriptor

+ func (Replica) EnumDescriptor() ([]byte, []int)

+ func (Replica) Type() protoreflect.EnumType

+ func (x Replica) Enum() *Replica

+ func (x Replica) Number() protoreflect.EnumNumber

+ func (x Replica) String() string

+ type ScanClient interface

+ Scan func(ctx context.Context, in *AerospikeRequestPayload, opts ...grpc.CallOption) (Scan_ScanClient, error)

+ ScanStreaming func(ctx context.Context, opts ...grpc.CallOption) (Scan_ScanStreamingClient, error)

+ func NewScanClient(cc grpc.ClientConnInterface) ScanClient

+ type ScanPolicy struct

+ Compress bool

+ ConcurrentNodes *bool

+ Expression []byte

+ IncludeBinData *bool

+ MaxConcurrentNodes *uint32

+ MaxRecords *uint64

+ ReadModeAP ReadModeAP

+ ReadModeSC ReadModeSC

+ RecordsPerSecond *uint32

+ Replica Replica

+ TotalTimeout *uint32

+ func (*ScanPolicy) Descriptor() ([]byte, []int)

+ func (*ScanPolicy) ProtoMessage()

+ func (x *ScanPolicy) GetCompress() bool

+ func (x *ScanPolicy) GetConcurrentNodes() bool

+ func (x *ScanPolicy) GetExpression() []byte

+ func (x *ScanPolicy) GetIncludeBinData() bool

+ func (x *ScanPolicy) GetMaxConcurrentNodes() uint32

+ func (x *ScanPolicy) GetMaxRecords() uint64

+ func (x *ScanPolicy) GetReadModeAP() ReadModeAP

+ func (x *ScanPolicy) GetReadModeSC() ReadModeSC

+ func (x *ScanPolicy) GetRecordsPerSecond() uint32

+ func (x *ScanPolicy) GetReplica() Replica

+ func (x *ScanPolicy) GetTotalTimeout() uint32

+ func (x *ScanPolicy) ProtoReflect() protoreflect.Message

+ func (x *ScanPolicy) Reset()

+ func (x *ScanPolicy) String() string

+ type ScanRequest struct

+ BinNames []string

+ Namespace string

+ PartitionFilter *PartitionFilter

+ ScanPolicy *ScanPolicy

+ SetName *string

+ func (*ScanRequest) Descriptor() ([]byte, []int)

+ func (*ScanRequest) ProtoMessage()

+ func (x *ScanRequest) GetBinNames() []string

+ func (x *ScanRequest) GetNamespace() string

+ func (x *ScanRequest) GetPartitionFilter() *PartitionFilter

+ func (x *ScanRequest) GetScanPolicy() *ScanPolicy

+ func (x *ScanRequest) GetSetName() string

+ func (x *ScanRequest) ProtoReflect() protoreflect.Message

+ func (x *ScanRequest) Reset()

+ func (x *ScanRequest) String() string

+ type ScanServer interface

+ Scan func(*AerospikeRequestPayload, Scan_ScanServer) error

+ ScanStreaming func(Scan_ScanStreamingServer) error

+ type Scan_ScanClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ type Scan_ScanServer interface

+ Send func(*AerospikeResponsePayload) error

+ type Scan_ScanStreamingClient interface

+ Recv func() (*AerospikeResponsePayload, error)

+ Send func(*AerospikeRequestPayload) error

+ type Scan_ScanStreamingServer interface

+ Recv func() (*AerospikeRequestPayload, error)

+ Send func(*AerospikeResponsePayload) error

+ type Statement struct

+ BinNames []string

+ Filter *Filter

+ FunctionArgs [][]byte

+ FunctionName string

+ IndexName *string

+ MaxRecords *uint64

+ Namespace string

+ Operations []*Operation

+ PackageName string

+ RecordsPerSecond *uint32

+ SetName *string

+ TaskId *int64

+ func (*Statement) Descriptor() ([]byte, []int)

+ func (*Statement) ProtoMessage()

+ func (x *Statement) GetBinNames() []string

+ func (x *Statement) GetFilter() *Filter

+ func (x *Statement) GetFunctionArgs() [][]byte

+ func (x *Statement) GetFunctionName() string

+ func (x *Statement) GetIndexName() string

+ func (x *Statement) GetMaxRecords() uint64

+ func (x *Statement) GetNamespace() string

+ func (x *Statement) GetOperations() []*Operation

+ func (x *Statement) GetPackageName() string

+ func (x *Statement) GetRecordsPerSecond() uint32

+ func (x *Statement) GetSetName() string

+ func (x *Statement) GetTaskId() int64

+ func (x *Statement) ProtoReflect() protoreflect.Message

+ func (x *Statement) Reset()

+ func (x *Statement) String() string

+ type UnimplementedAboutServer struct

+ func (UnimplementedAboutServer) Get(context.Context, *AboutRequest) (*AboutResponse, error)

+ type UnimplementedKVSServer struct

+ func (UnimplementedKVSServer) BatchOperate(*AerospikeRequestPayload, KVS_BatchOperateServer) error

+ func (UnimplementedKVSServer) BatchOperateStreaming(KVS_BatchOperateStreamingServer) error

+ func (UnimplementedKVSServer) Delete(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) DeleteStreaming(KVS_DeleteStreamingServer) error

+ func (UnimplementedKVSServer) Execute(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) ExecuteStreaming(KVS_ExecuteStreamingServer) error

+ func (UnimplementedKVSServer) Exists(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) ExistsStreaming(KVS_ExistsStreamingServer) error

+ func (UnimplementedKVSServer) GetHeader(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) GetHeaderStreaming(KVS_GetHeaderStreamingServer) error

+ func (UnimplementedKVSServer) Operate(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) OperateStreaming(KVS_OperateStreamingServer) error

+ func (UnimplementedKVSServer) Read(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) ReadStreaming(KVS_ReadStreamingServer) error

+ func (UnimplementedKVSServer) Touch(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) TouchStreaming(KVS_TouchStreamingServer) error

+ func (UnimplementedKVSServer) Write(context.Context, *AerospikeRequestPayload) (*AerospikeResponsePayload, error)

+ func (UnimplementedKVSServer) WriteStreaming(KVS_WriteStreamingServer) error

+ type UnimplementedQueryServer struct

+ func (UnimplementedQueryServer) BackgroundExecute(*AerospikeRequestPayload, Query_BackgroundExecuteServer) error

+ func (UnimplementedQueryServer) BackgroundExecuteStreaming(Query_BackgroundExecuteStreamingServer) error

+ func (UnimplementedQueryServer) BackgroundTaskStatus(*AerospikeRequestPayload, Query_BackgroundTaskStatusServer) error

+ func (UnimplementedQueryServer) BackgroundTaskStatusStreaming(Query_BackgroundTaskStatusStreamingServer) error

+ func (UnimplementedQueryServer) Query(*AerospikeRequestPayload, Query_QueryServer) error

+ func (UnimplementedQueryServer) QueryStreaming(Query_QueryStreamingServer) error

+ type UnimplementedScanServer struct

+ func (UnimplementedScanServer) Scan(*AerospikeRequestPayload, Scan_ScanServer) error

+ func (UnimplementedScanServer) ScanStreaming(Scan_ScanStreamingServer) error

+ type UnsafeAboutServer interface

+ type UnsafeKVSServer interface

+ type UnsafeQueryServer interface

+ type UnsafeScanServer interface

+ type WritePolicy struct

+ ReadModeAP ReadModeAP

+ ReadModeSC ReadModeSC

+ Replica Replica

+ func (*WritePolicy) Descriptor() ([]byte, []int)

+ func (*WritePolicy) ProtoMessage()

+ func (x *WritePolicy) GetReadModeAP() ReadModeAP

+ func (x *WritePolicy) GetReadModeSC() ReadModeSC

+ func (x *WritePolicy) GetReplica() Replica

+ func (x *WritePolicy) ProtoReflect() protoreflect.Message

+ func (x *WritePolicy) Reset()

+ func (x *WritePolicy) String() string

Other modules containing this package

github.com/aerospike/aerospike-client-go/v7