serverpb

package
v0.0.0-...-db32783 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 13, 2024 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RegionStatus_name = map[int32]string{
		0: "INACTIVE",
		1: "LEADER",
		2: "PRIMARY_FOLLOWER",
		3: "SECONDARY_FOLLOWER",
		4: "ACTIVE_SLAVE",
	}
	RegionStatus_value = map[string]int32{
		"INACTIVE":           0,
		"LEADER":             1,
		"PRIMARY_FOLLOWER":   2,
		"SECONDARY_FOLLOWER": 3,
		"ACTIVE_SLAVE":       4,
	}
)

Enum value maps for RegionStatus.

View Source 
var (
	TrxnRecord_TrxnType_name = map[int32]string{
		0: "Unknown",
		1: "Put",
		2: "Delete",
	}
	TrxnRecord_TrxnType_value = map[string]int32{
		"Unknown": 0,
		"Put":     1,
		"Delete":  2,
	}
)

Enum value maps for TrxnRecord_TrxnType.

View Source 
var (
	ReadConsistency_name = map[int32]string{
		0: "SEQUENTIAL",
		1: "LINEARIZABLE",
	}
	ReadConsistency_value = map[string]int32{
		"SEQUENTIAL":   0,
		"LINEARIZABLE": 1,
	}
)

Enum value maps for ReadConsistency.

View Source 
var DKVBackupRestore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKVBackupRestore",
	HandlerType: (*DKVBackupRestoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Backup",
			Handler:    _DKVBackupRestore_Backup_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _DKVBackupRestore_Restore_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/serverpb/admin.proto",
}

DKVBackupRestore_ServiceDesc is the grpc.ServiceDesc for DKVBackupRestore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DKVCluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKVCluster",
	HandlerType: (*DKVClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddNode",
			Handler:    _DKVCluster_AddNode_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _DKVCluster_RemoveNode_Handler,
		},
		{
			MethodName: "ListNodes",
			Handler:    _DKVCluster_ListNodes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/serverpb/admin.proto",
}

DKVCluster_ServiceDesc is the grpc.ServiceDesc for DKVCluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DKVDiscoveryNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKVDiscoveryNode",
	HandlerType: (*DKVDiscoveryNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetStatus",
			Handler:    _DKVDiscoveryNode_GetStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/serverpb/admin.proto",
}

DKVDiscoveryNode_ServiceDesc is the grpc.ServiceDesc for DKVDiscoveryNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DKVDiscovery_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKVDiscovery",
	HandlerType: (*DKVDiscoveryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateStatus",
			Handler:    _DKVDiscovery_UpdateStatus_Handler,
		},
		{
			MethodName: "GetClusterInfo",
			Handler:    _DKVDiscovery_GetClusterInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/serverpb/admin.proto",
}

DKVDiscovery_ServiceDesc is the grpc.ServiceDesc for DKVDiscovery service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DKVReplication_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKVReplication",
	HandlerType: (*DKVReplicationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetChanges",
			Handler:    _DKVReplication_GetChanges_Handler,
		},
		{
			MethodName: "AddReplica",
			Handler:    _DKVReplication_AddReplica_Handler,
		},
		{
			MethodName: "RemoveReplica",
			Handler:    _DKVReplication_RemoveReplica_Handler,
		},
		{
			MethodName: "GetReplicas",
			Handler:    _DKVReplication_GetReplicas_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/serverpb/admin.proto",
}

DKVReplication_ServiceDesc is the grpc.ServiceDesc for DKVReplication service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DKV_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dkv.serverpb.DKV",
	HandlerType: (*DKVServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Put",
			Handler:    _DKV_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _DKV_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _DKV_Get_Handler,
		},
		{
			MethodName: "MultiGet",
			Handler:    _DKV_MultiGet_Handler,
		},
		{
			MethodName: "MultiPut",
			Handler:    _DKV_MultiPut_Handler,
		},
		{
			MethodName: "CompareAndSet",
			Handler:    _DKV_CompareAndSet_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Iterate",
			Handler:       _DKV_Iterate_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/serverpb/api.proto",
}

DKV_ServiceDesc is the grpc.ServiceDesc for DKV service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_serverpb_admin_proto protoreflect.FileDescriptor
View Source 
var File_pkg_serverpb_api_proto protoreflect.FileDescriptor

Functions

func RegisterDKVBackupRestoreServer 

func RegisterDKVBackupRestoreServer(s grpc.ServiceRegistrar, srv DKVBackupRestoreServer)

func RegisterDKVClusterServer 

func RegisterDKVClusterServer(s grpc.ServiceRegistrar, srv DKVClusterServer)

func RegisterDKVDiscoveryNodeServer 

func RegisterDKVDiscoveryNodeServer(s grpc.ServiceRegistrar, srv DKVDiscoveryNodeServer)

func RegisterDKVDiscoveryServer 

func RegisterDKVDiscoveryServer(s grpc.ServiceRegistrar, srv DKVDiscoveryServer)

func RegisterDKVReplicationServer 

func RegisterDKVReplicationServer(s grpc.ServiceRegistrar, srv DKVReplicationServer)

func RegisterDKVServer 

func RegisterDKVServer(s grpc.ServiceRegistrar, srv DKVServer)

Types

type AddNodeRequest 

type AddNodeRequest struct {

	// NodeUrl represents the URL for the Nexus service running on
	// the node that needs to be added to the cluster. Other Nexus
	// peers communicate with this node on this service.
	NodeUrl string `protobuf:"bytes,1,opt,name=nodeUrl,proto3" json:"nodeUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeRequest) Descriptor deprecated 

func (*AddNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddNodeRequest.ProtoReflect.Descriptor instead.

func (*AddNodeRequest) GetNodeUrl 

func (x *AddNodeRequest) GetNodeUrl() string

func (*AddNodeRequest) ProtoMessage 

func (*AddNodeRequest) ProtoMessage()

func (*AddNodeRequest) ProtoReflect 

func (x *AddNodeRequest) ProtoReflect() protoreflect.Message

func (*AddNodeRequest) Reset 

func (x *AddNodeRequest) Reset()

func (*AddNodeRequest) String 

func (x *AddNodeRequest) String() string

type BackupRequest 

type BackupRequest struct {

	// BackupPath indicates a filesystem folder or file used for backing up the keyspace.
	BackupPath string `protobuf:"bytes,1,opt,name=backupPath,proto3" json:"backupPath,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRequest) Descriptor deprecated 

func (*BackupRequest) Descriptor() ([]byte, []int)

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetBackupPath 

func (x *BackupRequest) GetBackupPath() string

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

func (x *BackupRequest) ProtoReflect() protoreflect.Message

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) String 

func (x *BackupRequest) String() string

type ChangeRecord 

type ChangeRecord struct {

	// SerialisedForm is the internal byte array representation of this change record.
	SerialisedForm []byte `protobuf:"bytes,1,opt,name=serialisedForm,proto3" json:"serialisedForm,omitempty"`
	// ChangeNumber indicates the change number of this change record.
	ChangeNumber uint64 `protobuf:"varint,2,opt,name=changeNumber,proto3" json:"changeNumber,omitempty"`
	// NumberOfTrxns indicates the number of transactions associated with this change record.
	NumberOfTrxns uint32 `protobuf:"varint,3,opt,name=numberOfTrxns,proto3" json:"numberOfTrxns,omitempty"`
	// Trxns is the collection of transaction records associated with this change record.
	Trxns []*TrxnRecord `protobuf:"bytes,4,rep,name=trxns,proto3" json:"trxns,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeRecord) Descriptor deprecated 

func (*ChangeRecord) Descriptor() ([]byte, []int)

Deprecated: Use ChangeRecord.ProtoReflect.Descriptor instead.

func (*ChangeRecord) GetChangeNumber 

func (x *ChangeRecord) GetChangeNumber() uint64

func (*ChangeRecord) GetNumberOfTrxns 

func (x *ChangeRecord) GetNumberOfTrxns() uint32

func (*ChangeRecord) GetSerialisedForm 

func (x *ChangeRecord) GetSerialisedForm() []byte

func (*ChangeRecord) GetTrxns 

func (x *ChangeRecord) GetTrxns() []*TrxnRecord

func (*ChangeRecord) ProtoMessage 

func (*ChangeRecord) ProtoMessage()

func (*ChangeRecord) ProtoReflect 

func (x *ChangeRecord) ProtoReflect() protoreflect.Message

func (*ChangeRecord) Reset 

func (x *ChangeRecord) Reset()

func (*ChangeRecord) String 

func (x *ChangeRecord) String() string

type CompareAndSetRequest 

type CompareAndSetRequest struct {

	// Key is the given key that is involved with this CAS request.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// OldValue is the expected value for comparison.
	OldValue []byte `protobuf:"bytes,2,opt,name=oldValue,proto3" json:"oldValue,omitempty"`
	// NewValue is the value set once the comparison is successful.
	NewValue []byte `protobuf:"bytes,3,opt,name=newValue,proto3" json:"newValue,omitempty"`
	//expireTS
	ExpireTS uint64 `protobuf:"varint,4,opt,name=expireTS,proto3" json:"expireTS,omitempty"`
	// contains filtered or unexported fields
}

func (*CompareAndSetRequest) Descriptor deprecated 

func (*CompareAndSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use CompareAndSetRequest.ProtoReflect.Descriptor instead.

func (*CompareAndSetRequest) GetExpireTS 

func (x *CompareAndSetRequest) GetExpireTS() uint64

func (*CompareAndSetRequest) GetKey 

func (x *CompareAndSetRequest) GetKey() []byte

func (*CompareAndSetRequest) GetNewValue 

func (x *CompareAndSetRequest) GetNewValue() []byte

func (*CompareAndSetRequest) GetOldValue 

func (x *CompareAndSetRequest) GetOldValue() []byte

func (*CompareAndSetRequest) ProtoMessage 

func (*CompareAndSetRequest) ProtoMessage()

func (*CompareAndSetRequest) ProtoReflect 

func (x *CompareAndSetRequest) ProtoReflect() protoreflect.Message

func (*CompareAndSetRequest) Reset 

func (x *CompareAndSetRequest) Reset()

func (*CompareAndSetRequest) String 

func (x *CompareAndSetRequest) String() string

type CompareAndSetResponse 

type CompareAndSetResponse struct {

	// Status indicates the result of the compare and set operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Updated indicates if the given new value was overwritten following
	// a successful comparison with the given old value.
	Updated bool `protobuf:"varint,2,opt,name=updated,proto3" json:"updated,omitempty"`
	// contains filtered or unexported fields
}

func (*CompareAndSetResponse) Descriptor deprecated 

func (*CompareAndSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use CompareAndSetResponse.ProtoReflect.Descriptor instead.

func (*CompareAndSetResponse) GetStatus 

func (x *CompareAndSetResponse) GetStatus() *Status

func (*CompareAndSetResponse) GetUpdated 

func (x *CompareAndSetResponse) GetUpdated() bool

func (*CompareAndSetResponse) ProtoMessage 

func (*CompareAndSetResponse) ProtoMessage()

func (*CompareAndSetResponse) ProtoReflect 

func (x *CompareAndSetResponse) ProtoReflect() protoreflect.Message

func (*CompareAndSetResponse) Reset 

func (x *CompareAndSetResponse) Reset()

func (*CompareAndSetResponse) String 

func (x *CompareAndSetResponse) String() string

type DKVBackupRestoreClient 

type DKVBackupRestoreClient interface {
	// Backup backs up the entire keyspace into the given filesystem location.
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*Status, error)
	// Restore restores the entire keyspace from an existing backup at the
	// given filesystem location.
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*Status, error)
}

DKVBackupRestoreClient is the client API for DKVBackupRestore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVBackupRestoreClient 

func NewDKVBackupRestoreClient(cc grpc.ClientConnInterface) DKVBackupRestoreClient

type DKVBackupRestoreServer 

type DKVBackupRestoreServer interface {
	// Backup backs up the entire keyspace into the given filesystem location.
	Backup(context.Context, *BackupRequest) (*Status, error)
	// Restore restores the entire keyspace from an existing backup at the
	// given filesystem location.
	Restore(context.Context, *RestoreRequest) (*Status, error)
}

DKVBackupRestoreServer is the server API for DKVBackupRestore service. All implementations should embed UnimplementedDKVBackupRestoreServer for forward compatibility

type DKVClient 

type DKVClient interface {
	// Put puts the given key into the key value store.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Delete deletes the given key from the key value store.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Get gets the value associated with the given key from the key value store.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// MultiGet gets the values associated with given keys from the key value store.
	MultiGet(ctx context.Context, in *MultiGetRequest, opts ...grpc.CallOption) (*MultiGetResponse, error)
	// MultiPut puts the given keys into the key value store.
	MultiPut(ctx context.Context, in *MultiPutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Iterate iterates through the entire keyspace in no particular order and
	// returns the results as a stream of key value pairs.
	Iterate(ctx context.Context, in *IterateRequest, opts ...grpc.CallOption) (DKV_IterateClient, error)
	// CompareAndSet offers the standard CAS style transaction over a given
	// key. Intended to be used in concurrent workloads with less contention.
	CompareAndSet(ctx context.Context, in *CompareAndSetRequest, opts ...grpc.CallOption) (*CompareAndSetResponse, error)
}

DKVClient is the client API for DKV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVClient 

func NewDKVClient(cc grpc.ClientConnInterface) DKVClient

type DKVClusterClient 

type DKVClusterClient interface {
	// AddNode adds the given DKV node to the cluster that the
	// current node is a member of.
	AddNode(ctx context.Context, in *AddNodeRequest, opts ...grpc.CallOption) (*Status, error)
	// RemoveNode removes the given DKV node from the cluster that
	// the current node is a member of.
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*Status, error)
	// ListNodes retrieves the current set of DKV nodes from
	// the Nexus cluster.
	ListNodes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListNodesResponse, error)
}

DKVClusterClient is the client API for DKVCluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVClusterClient 

func NewDKVClusterClient(cc grpc.ClientConnInterface) DKVClusterClient

type DKVClusterServer 

type DKVClusterServer interface {
	// AddNode adds the given DKV node to the cluster that the
	// current node is a member of.
	AddNode(context.Context, *AddNodeRequest) (*Status, error)
	// RemoveNode removes the given DKV node from the cluster that
	// the current node is a member of.
	RemoveNode(context.Context, *RemoveNodeRequest) (*Status, error)
	// ListNodes retrieves the current set of DKV nodes from
	// the Nexus cluster.
	ListNodes(context.Context, *emptypb.Empty) (*ListNodesResponse, error)
}

DKVClusterServer is the server API for DKVCluster service. All implementations should embed UnimplementedDKVClusterServer for forward compatibility

type DKVDiscoveryClient 

type DKVDiscoveryClient interface {
	// Update status of the given database and vBucket
	UpdateStatus(ctx context.Context, in *UpdateStatusRequest, opts ...grpc.CallOption) (*Status, error)
	// Retrieve all active nodes in cluster with their status after filtering based on request params
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
}

DKVDiscoveryClient is the client API for DKVDiscovery service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVDiscoveryClient 

func NewDKVDiscoveryClient(cc grpc.ClientConnInterface) DKVDiscoveryClient

type DKVDiscoveryNodeClient 

type DKVDiscoveryNodeClient interface {
	// Get status of region
	GetStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RegionInfo, error)
}

DKVDiscoveryNodeClient is the client API for DKVDiscoveryNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVDiscoveryNodeClient 

func NewDKVDiscoveryNodeClient(cc grpc.ClientConnInterface) DKVDiscoveryNodeClient

type DKVDiscoveryNodeServer 

type DKVDiscoveryNodeServer interface {
	// Get status of region
	GetStatus(context.Context, *emptypb.Empty) (*RegionInfo, error)
}

DKVDiscoveryNodeServer is the server API for DKVDiscoveryNode service. All implementations should embed UnimplementedDKVDiscoveryNodeServer for forward compatibility

type DKVDiscoveryServer 

type DKVDiscoveryServer interface {
	// Update status of the given database and vBucket
	UpdateStatus(context.Context, *UpdateStatusRequest) (*Status, error)
	// Retrieve all active nodes in cluster with their status after filtering based on request params
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
}

DKVDiscoveryServer is the server API for DKVDiscovery service. All implementations should embed UnimplementedDKVDiscoveryServer for forward compatibility

type DKVReplicationClient 

type DKVReplicationClient interface {
	// GetChanges retrieves all changes from a given change number.
	GetChanges(ctx context.Context, in *GetChangesRequest, opts ...grpc.CallOption) (*GetChangesResponse, error)
	// AddReplica registers a new replica with the current master.
	AddReplica(ctx context.Context, in *Replica, opts ...grpc.CallOption) (*Status, error)
	// RemoveReplica deregisters given replica from the current master.
	RemoveReplica(ctx context.Context, in *Replica, opts ...grpc.CallOption) (*Status, error)
	// GetReplicas retrieves all the replicas of the current master.
	GetReplicas(ctx context.Context, in *GetReplicasRequest, opts ...grpc.CallOption) (*GetReplicasResponse, error)
}

DKVReplicationClient is the client API for DKVReplication service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDKVReplicationClient 

func NewDKVReplicationClient(cc grpc.ClientConnInterface) DKVReplicationClient

type DKVReplicationServer 

type DKVReplicationServer interface {
	// GetChanges retrieves all changes from a given change number.
	GetChanges(context.Context, *GetChangesRequest) (*GetChangesResponse, error)
	// AddReplica registers a new replica with the current master.
	AddReplica(context.Context, *Replica) (*Status, error)
	// RemoveReplica deregisters given replica from the current master.
	RemoveReplica(context.Context, *Replica) (*Status, error)
	// GetReplicas retrieves all the replicas of the current master.
	GetReplicas(context.Context, *GetReplicasRequest) (*GetReplicasResponse, error)
}

DKVReplicationServer is the server API for DKVReplication service. All implementations should embed UnimplementedDKVReplicationServer for forward compatibility

type DKVServer 

type DKVServer interface {
	// Put puts the given key into the key value store.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Delete deletes the given key from the key value store.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Get gets the value associated with the given key from the key value store.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// MultiGet gets the values associated with given keys from the key value store.
	MultiGet(context.Context, *MultiGetRequest) (*MultiGetResponse, error)
	// MultiPut puts the given keys into the key value store.
	MultiPut(context.Context, *MultiPutRequest) (*PutResponse, error)
	// Iterate iterates through the entire keyspace in no particular order and
	// returns the results as a stream of key value pairs.
	Iterate(*IterateRequest, DKV_IterateServer) error
	// CompareAndSet offers the standard CAS style transaction over a given
	// key. Intended to be used in concurrent workloads with less contention.
	CompareAndSet(context.Context, *CompareAndSetRequest) (*CompareAndSetResponse, error)
}

DKVServer is the server API for DKV service. All implementations should embed UnimplementedDKVServer for forward compatibility

type DKV_IterateClient 

type DKV_IterateClient interface {
	Recv() (*IterateResponse, error)
	grpc.ClientStream
}

type DKV_IterateServer 

type DKV_IterateServer interface {
	Send(*IterateResponse) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {

	// Key is the key, in bytes, to delete from the key value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

func (*DeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() []byte

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {

	// Status indicates the result of the Delete operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

func (*DeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetStatus 

func (x *DeleteResponse) GetStatus() *Status

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type GetChangesRequest 

type GetChangesRequest struct {

	// FromChangeNumber is the starting change number from which to retrieve changes.
	FromChangeNumber uint64 `protobuf:"varint,1,opt,name=fromChangeNumber,proto3" json:"fromChangeNumber,omitempty"`
	// MaxNumberOfChanges is the maximum number of changes to return from this invocation.
	MaxNumberOfChanges uint32 `protobuf:"varint,2,opt,name=maxNumberOfChanges,proto3" json:"maxNumberOfChanges,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChangesRequest) Descriptor deprecated 

func (*GetChangesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetChangesRequest.ProtoReflect.Descriptor instead.

func (*GetChangesRequest) GetFromChangeNumber 

func (x *GetChangesRequest) GetFromChangeNumber() uint64

func (*GetChangesRequest) GetMaxNumberOfChanges 

func (x *GetChangesRequest) GetMaxNumberOfChanges() uint32

func (*GetChangesRequest) ProtoMessage 

func (*GetChangesRequest) ProtoMessage()

func (*GetChangesRequest) ProtoReflect 

func (x *GetChangesRequest) ProtoReflect() protoreflect.Message

func (*GetChangesRequest) Reset 

func (x *GetChangesRequest) Reset()

func (*GetChangesRequest) String 

func (x *GetChangesRequest) String() string

type GetChangesResponse 

type GetChangesResponse struct {

	// Status indicates the result of the GetChanges operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// MasterChangeNumber indicates the latest change number on master node.
	MasterChangeNumber uint64 `protobuf:"varint,2,opt,name=masterChangeNumber,proto3" json:"masterChangeNumber,omitempty"`
	// NumberOfChanges indicates the number of change records in the response.
	NumberOfChanges uint32 `protobuf:"varint,3,opt,name=numberOfChanges,proto3" json:"numberOfChanges,omitempty"`
	// Changes is the collection of change records.
	Changes []*ChangeRecord `protobuf:"bytes,4,rep,name=changes,proto3" json:"changes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChangesResponse) Descriptor deprecated 

func (*GetChangesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetChangesResponse.ProtoReflect.Descriptor instead.

func (*GetChangesResponse) GetChanges 

func (x *GetChangesResponse) GetChanges() []*ChangeRecord

func (*GetChangesResponse) GetMasterChangeNumber 

func (x *GetChangesResponse) GetMasterChangeNumber() uint64

func (*GetChangesResponse) GetNumberOfChanges 

func (x *GetChangesResponse) GetNumberOfChanges() uint32

func (*GetChangesResponse) GetStatus 

func (x *GetChangesResponse) GetStatus() *Status

func (*GetChangesResponse) ProtoMessage 

func (*GetChangesResponse) ProtoMessage()

func (*GetChangesResponse) ProtoReflect 

func (x *GetChangesResponse) ProtoReflect() protoreflect.Message

func (*GetChangesResponse) Reset 

func (x *GetChangesResponse) Reset()

func (*GetChangesResponse) String 

func (x *GetChangesResponse) String() string

type GetClusterInfoRequest 

type GetClusterInfoRequest struct {

	// Identifier of datacenter / availability zone
	DcID *string `protobuf:"bytes,1,opt,name=dcID,proto3,oneof" json:"dcID,omitempty"`
	// Database identifier
	Database *string `protobuf:"bytes,2,opt,name=database,proto3,oneof" json:"database,omitempty"`
	// Shard / vBucket identifier
	VBucket *string `protobuf:"bytes,3,opt,name=vBucket,proto3,oneof" json:"vBucket,omitempty"`
	// contains filtered or unexported fields
}

Get cluster info filtered on request params

func (*GetClusterInfoRequest) Descriptor deprecated 

func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*GetClusterInfoRequest) GetDatabase 

func (x *GetClusterInfoRequest) GetDatabase() string

func (*GetClusterInfoRequest) GetDcID 

func (x *GetClusterInfoRequest) GetDcID() string

func (*GetClusterInfoRequest) GetVBucket 

func (x *GetClusterInfoRequest) GetVBucket() string

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) ProtoReflect 

func (x *GetClusterInfoRequest) ProtoReflect() protoreflect.Message

func (*GetClusterInfoRequest) Reset 

func (x *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) String 

func (x *GetClusterInfoRequest) String() string

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	RegionInfos []*RegionInfo `protobuf:"bytes,1,rep,name=regionInfos,proto3" json:"regionInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterInfoResponse) Descriptor deprecated 

func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetClusterInfoResponse.ProtoReflect.Descriptor instead.

func (*GetClusterInfoResponse) GetRegionInfos 

func (x *GetClusterInfoResponse) GetRegionInfos() []*RegionInfo

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) ProtoReflect 

func (x *GetClusterInfoResponse) ProtoReflect() protoreflect.Message

func (*GetClusterInfoResponse) Reset 

func (x *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) String 

func (x *GetClusterInfoResponse) String() string

type GetReplicasRequest 

type GetReplicasRequest struct {

	// Zone identifier to use for looking up replicas of the current master.
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicasRequest) Descriptor deprecated 

func (*GetReplicasRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetReplicasRequest.ProtoReflect.Descriptor instead.

func (*GetReplicasRequest) GetZone 

func (x *GetReplicasRequest) GetZone() string

func (*GetReplicasRequest) ProtoMessage 

func (*GetReplicasRequest) ProtoMessage()

func (*GetReplicasRequest) ProtoReflect 

func (x *GetReplicasRequest) ProtoReflect() protoreflect.Message

func (*GetReplicasRequest) Reset 

func (x *GetReplicasRequest) Reset()

func (*GetReplicasRequest) String 

func (x *GetReplicasRequest) String() string

type GetReplicasResponse 

type GetReplicasResponse struct {

	// Replicas are all the replicas of the current master.
	Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplicasResponse) Descriptor deprecated 

func (*GetReplicasResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetReplicasResponse.ProtoReflect.Descriptor instead.

func (*GetReplicasResponse) GetReplicas 

func (x *GetReplicasResponse) GetReplicas() []*Replica

func (*GetReplicasResponse) ProtoMessage 

func (*GetReplicasResponse) ProtoMessage()

func (*GetReplicasResponse) ProtoReflect 

func (x *GetReplicasResponse) ProtoReflect() protoreflect.Message

func (*GetReplicasResponse) Reset 

func (x *GetReplicasResponse) Reset()

func (*GetReplicasResponse) String 

func (x *GetReplicasResponse) String() string

type GetRequest 

type GetRequest struct {

	// Key is the key, in bytes, whose associated value is loaded from the key value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Desired read consistency level for this GET request.
	ReadConsistency ReadConsistency `protobuf:"varint,2,opt,name=readConsistency,proto3,enum=dkv.serverpb.ReadConsistency" json:"readConsistency,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) GetReadConsistency 

func (x *GetRequest) GetReadConsistency() ReadConsistency

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {

	// Status indicates the result of the Get operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Value is the value, in bytes, that is associated with the given key in the key value store.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetStatus 

func (x *GetResponse) GetStatus() *Status

func (*GetResponse) GetValue 

func (x *GetResponse) GetValue() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type IterateRequest 

type IterateRequest struct {

	// KeyPrefix can be used to iterate through keys that have this prefix.
	KeyPrefix []byte `protobuf:"bytes,1,opt,name=keyPrefix,proto3" json:"keyPrefix,omitempty"`
	// StartKey can be used to begin the iteration from the specified key.
	StartKey []byte `protobuf:"bytes,2,opt,name=startKey,proto3" json:"startKey,omitempty"`
	// contains filtered or unexported fields
}

func (*IterateRequest) Descriptor deprecated 

func (*IterateRequest) Descriptor() ([]byte, []int)

Deprecated: Use IterateRequest.ProtoReflect.Descriptor instead.

func (*IterateRequest) GetKeyPrefix 

func (x *IterateRequest) GetKeyPrefix() []byte

func (*IterateRequest) GetStartKey 

func (x *IterateRequest) GetStartKey() []byte

func (*IterateRequest) ProtoMessage 

func (*IterateRequest) ProtoMessage()

func (*IterateRequest) ProtoReflect 

func (x *IterateRequest) ProtoReflect() protoreflect.Message

func (*IterateRequest) Reset 

func (x *IterateRequest) Reset()

func (*IterateRequest) String 

func (x *IterateRequest) String() string

type IterateResponse 

type IterateResponse struct {

	// Status captures any errors with the current iteration.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Key of the current iteration.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Value of the current iteration.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*IterateResponse) Descriptor deprecated 

func (*IterateResponse) Descriptor() ([]byte, []int)

Deprecated: Use IterateResponse.ProtoReflect.Descriptor instead.

func (*IterateResponse) GetKey 

func (x *IterateResponse) GetKey() []byte

func (*IterateResponse) GetStatus 

func (x *IterateResponse) GetStatus() *Status

func (*IterateResponse) GetValue 

func (x *IterateResponse) GetValue() []byte

func (*IterateResponse) ProtoMessage 

func (*IterateResponse) ProtoMessage()

func (*IterateResponse) ProtoReflect 

func (x *IterateResponse) ProtoReflect() protoreflect.Message

func (*IterateResponse) Reset 

func (x *IterateResponse) Reset()

func (*IterateResponse) String 

func (x *IterateResponse) String() string

type KVPair 

type KVPair struct {

	// Key is the DKV key
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value is the value associated with a given key
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	//expireTS
	ExpireTS uint64 `protobuf:"varint,3,opt,name=expireTS,proto3" json:"expireTS,omitempty"`
	// contains filtered or unexported fields
}

func (*KVPair) Descriptor deprecated 

func (*KVPair) Descriptor() ([]byte, []int)

Deprecated: Use KVPair.ProtoReflect.Descriptor instead.

func (*KVPair) GetExpireTS 

func (x *KVPair) GetExpireTS() uint64

func (*KVPair) GetKey 

func (x *KVPair) GetKey() []byte

func (*KVPair) GetValue 

func (x *KVPair) GetValue() []byte

func (*KVPair) ProtoMessage 

func (*KVPair) ProtoMessage()

func (*KVPair) ProtoReflect 

func (x *KVPair) ProtoReflect() protoreflect.Message

func (*KVPair) Reset 

func (x *KVPair) Reset()

func (*KVPair) String 

func (x *KVPair) String() string

type ListNodesResponse 

type ListNodesResponse struct {

	// Status indicates the status of the list nodes operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Leader represents the identifier of the leader node.
	Leader uint64 `protobuf:"varint,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// Nodes represents the members of the cluster identified by
	// their respective identifier and the Nexus URL.
	Nodes map[uint64]*models.NodeInfo `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListNodesResponse) Descriptor deprecated 

func (*ListNodesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetLeader 

func (x *ListNodesResponse) GetLeader() uint64

func (*ListNodesResponse) GetNodes 

func (x *ListNodesResponse) GetNodes() map[uint64]*models.NodeInfo

func (*ListNodesResponse) GetStatus 

func (x *ListNodesResponse) GetStatus() *Status

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

func (x *ListNodesResponse) ProtoReflect() protoreflect.Message

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type MultiGetRequest 

type MultiGetRequest struct {

	// Keys is the collection of keys whose values are returned from the bulk Get operation.
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Desired read consistency level for this MultiGet request.
	ReadConsistency ReadConsistency `protobuf:"varint,2,opt,name=readConsistency,proto3,enum=dkv.serverpb.ReadConsistency" json:"readConsistency,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiGetRequest) Descriptor deprecated 

func (*MultiGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use MultiGetRequest.ProtoReflect.Descriptor instead.

func (*MultiGetRequest) GetKeys 

func (x *MultiGetRequest) GetKeys() [][]byte

func (*MultiGetRequest) GetReadConsistency 

func (x *MultiGetRequest) GetReadConsistency() ReadConsistency

func (*MultiGetRequest) ProtoMessage 

func (*MultiGetRequest) ProtoMessage()

func (*MultiGetRequest) ProtoReflect 

func (x *MultiGetRequest) ProtoReflect() protoreflect.Message

func (*MultiGetRequest) Reset 

func (x *MultiGetRequest) Reset()

func (*MultiGetRequest) String 

func (x *MultiGetRequest) String() string

type MultiGetResponse 

type MultiGetResponse struct {

	// Status indicates the result of the bulk Get operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Association of keys and values of the bulk Get operation.
	KeyValues []*KVPair `protobuf:"bytes,2,rep,name=keyValues,proto3" json:"keyValues,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiGetResponse) Descriptor deprecated 

func (*MultiGetResponse) Descriptor() ([]byte, []int)

Deprecated: Use MultiGetResponse.ProtoReflect.Descriptor instead.

func (*MultiGetResponse) GetKeyValues 

func (x *MultiGetResponse) GetKeyValues() []*KVPair

func (*MultiGetResponse) GetStatus 

func (x *MultiGetResponse) GetStatus() *Status

func (*MultiGetResponse) ProtoMessage 

func (*MultiGetResponse) ProtoMessage()

func (*MultiGetResponse) ProtoReflect 

func (x *MultiGetResponse) ProtoReflect() protoreflect.Message

func (*MultiGetResponse) Reset 

func (x *MultiGetResponse) Reset()

func (*MultiGetResponse) String 

func (x *MultiGetResponse) String() string

type MultiPutRequest 

type MultiPutRequest struct {
	PutRequest []*PutRequest `protobuf:"bytes,1,rep,name=putRequest,proto3" json:"putRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiPutRequest) Descriptor deprecated 

func (*MultiPutRequest) Descriptor() ([]byte, []int)

Deprecated: Use MultiPutRequest.ProtoReflect.Descriptor instead.

func (*MultiPutRequest) GetPutRequest 

func (x *MultiPutRequest) GetPutRequest() []*PutRequest

func (*MultiPutRequest) ProtoMessage 

func (*MultiPutRequest) ProtoMessage()

func (*MultiPutRequest) ProtoReflect 

func (x *MultiPutRequest) ProtoReflect() protoreflect.Message

func (*MultiPutRequest) Reset 

func (x *MultiPutRequest) Reset()

func (*MultiPutRequest) String 

func (x *MultiPutRequest) String() string

type PutRequest 

type PutRequest struct {

	// Key is the key, in bytes, to put into the key value store.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value is the value, in bytes, to associate with the key in the key value store.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// expireTS is the epoch seconds value, in int64 to associate with the key in the key value store.
	ExpireTS uint64 `protobuf:"varint,3,opt,name=expireTS,proto3" json:"expireTS,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

func (*PutRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetExpireTS 

func (x *PutRequest) GetExpireTS() uint64

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {

	// Status indicates the result of the Put operation.
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

func (*PutResponse) Descriptor() ([]byte, []int)

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetStatus 

func (x *PutResponse) GetStatus() *Status

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

func (x *PutResponse) ProtoReflect() protoreflect.Message

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type ReadConsistency 

type ReadConsistency int32

ReadConsistency indicates the desired level of consistency for read requests. 

const (
	// Sequential or timeline consistency - fetches results from local node storage.
	ReadConsistency_SEQUENTIAL ReadConsistency = 0
	// Linearizable consistency - fetches results from local node storage only after
	// ensuring quorum with other DKV nodes.
	ReadConsistency_LINEARIZABLE ReadConsistency = 1
)

func (ReadConsistency) Descriptor 

func (ReadConsistency) Descriptor() protoreflect.EnumDescriptor

func (ReadConsistency) Enum 

func (x ReadConsistency) Enum() *ReadConsistency

func (ReadConsistency) EnumDescriptor deprecated 

func (ReadConsistency) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReadConsistency.Descriptor instead.

func (ReadConsistency) Number 

func (x ReadConsistency) Number() protoreflect.EnumNumber

func (ReadConsistency) String 

func (x ReadConsistency) String() string

func (ReadConsistency) Type 

func (ReadConsistency) Type() protoreflect.EnumType

type RegionInfo 

type RegionInfo struct {

	// Identifier of datacenter / availability zone
	// Slaves will prefer to select master within same dcId ,
	// Local DC followers will be created for every unique dcId
	DcID string `protobuf:"bytes,1,opt,name=dcID,proto3" json:"dcID,omitempty"`
	// Address to communicate with this node
	// Should be equal to listen-addr used for the node whose status is being updated
	NodeAddress string `protobuf:"bytes,2,opt,name=nodeAddress,proto3" json:"nodeAddress,omitempty"`
	// Database identifier
	Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// Shard / vBucket identifier
	VBucket string `protobuf:"bytes,4,opt,name=vBucket,proto3" json:"vBucket,omitempty"`
	// Status of the region
	Status RegionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=dkv.serverpb.RegionStatus" json:"status,omitempty"`
	// Master host of the region whose status is being updated
	// Applicable only for slaves. Used to load balance among various possible masters
	MasterHost *string `protobuf:"bytes,6,opt,name=masterHost,proto3,oneof" json:"masterHost,omitempty"`
	// Nexus cluster url of the region
	// Will be used by new followers to discover the raft cluster
	NexusClusterUrl *string `protobuf:"bytes,7,opt,name=nexusClusterUrl,proto3,oneof" json:"nexusClusterUrl,omitempty"`
	// http listener of the node.
	// http endpoint is useful for admin API interactions
	HttpAddress string `protobuf:"bytes,8,opt,name=httpAddress,proto3" json:"httpAddress,omitempty"`
	// contains filtered or unexported fields
}

func (*RegionInfo) Descriptor deprecated 

func (*RegionInfo) Descriptor() ([]byte, []int)

Deprecated: Use RegionInfo.ProtoReflect.Descriptor instead.

func (*RegionInfo) GetDatabase 

func (x *RegionInfo) GetDatabase() string

func (*RegionInfo) GetDcID 

func (x *RegionInfo) GetDcID() string

func (*RegionInfo) GetHttpAddress 

func (x *RegionInfo) GetHttpAddress() string

func (*RegionInfo) GetMasterHost 

func (x *RegionInfo) GetMasterHost() string

func (*RegionInfo) GetNexusClusterUrl 

func (x *RegionInfo) GetNexusClusterUrl() string

func (*RegionInfo) GetNodeAddress 

func (x *RegionInfo) GetNodeAddress() string

func (*RegionInfo) GetStatus 

func (x *RegionInfo) GetStatus() RegionStatus

func (*RegionInfo) GetVBucket 

func (x *RegionInfo) GetVBucket() string

func (*RegionInfo) ProtoMessage 

func (*RegionInfo) ProtoMessage()

func (*RegionInfo) ProtoReflect 

func (x *RegionInfo) ProtoReflect() protoreflect.Message

func (*RegionInfo) Reset 

func (x *RegionInfo) Reset()

func (*RegionInfo) String 

func (x *RegionInfo) String() string

type RegionStatus 

type RegionStatus int32
const (
	// A node in this status isn't supposed to be serving any requests - both for clients and servers (slaves)
	// When committed entry of master - node > X, node being brought up / down, node is partitioned from cluster, etc
	// Applicable for both slaves and members of raft quorum.
	RegionStatus_INACTIVE RegionStatus = 0
	// Master of the raft quorum - 1 node within the shard
	RegionStatus_LEADER RegionStatus = 1
	// Member of the raft quorum which is elected to serve sequentially consistent reads within the DC
	// 1 node within a shard in a DC
	RegionStatus_PRIMARY_FOLLOWER RegionStatus = 2
	// All other members of the raft quorum which are not master / primary follower.
	// Serving eventually consistent reads
	RegionStatus_SECONDARY_FOLLOWER RegionStatus = 3
	// Slave with committed entry within some bound of its master and able to serve read requests
	RegionStatus_ACTIVE_SLAVE RegionStatus = 4
)

func (RegionStatus) Descriptor 

func (RegionStatus) Descriptor() protoreflect.EnumDescriptor

func (RegionStatus) Enum 

func (x RegionStatus) Enum() *RegionStatus

func (RegionStatus) EnumDescriptor deprecated 

func (RegionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use RegionStatus.Descriptor instead.

func (RegionStatus) Number 

func (x RegionStatus) Number() protoreflect.EnumNumber

func (RegionStatus) String 

func (x RegionStatus) String() string

func (RegionStatus) Type 

func (RegionStatus) Type() protoreflect.EnumType

type RemoveNodeRequest 

type RemoveNodeRequest struct {

	// NodeUrl represents the URL for the Nexus service running on
	// the node that needs to be removed from the cluster.
	NodeUrl string `protobuf:"bytes,1,opt,name=nodeUrl,proto3" json:"nodeUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveNodeRequest) Descriptor deprecated 

func (*RemoveNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveNodeRequest) GetNodeUrl 

func (x *RemoveNodeRequest) GetNodeUrl() string

func (*RemoveNodeRequest) ProtoMessage 

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) ProtoReflect 

func (x *RemoveNodeRequest) ProtoReflect() protoreflect.Message

func (*RemoveNodeRequest) Reset 

func (x *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) String 

func (x *RemoveNodeRequest) String() string

type Replica 

type Replica struct {

	// Zone identifier of the replica.
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// Hostname of the replica.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// GRPC port of the replica.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Replica) Descriptor deprecated 

func (*Replica) Descriptor() ([]byte, []int)

Deprecated: Use Replica.ProtoReflect.Descriptor instead.

func (*Replica) GetHostname 

func (x *Replica) GetHostname() string

func (*Replica) GetPort 

func (x *Replica) GetPort() uint32

func (*Replica) GetZone 

func (x *Replica) GetZone() string

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) ProtoReflect 

func (x *Replica) ProtoReflect() protoreflect.Message

func (*Replica) Reset 

func (x *Replica) Reset()

func (*Replica) String 

func (x *Replica) String() string

type RestoreRequest 

type RestoreRequest struct {

	// RestorePath indicates a filesystem folder or file used for restoring the keyspace.
	RestorePath string `protobuf:"bytes,1,opt,name=restorePath,proto3" json:"restorePath,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreRequest) Descriptor deprecated 

func (*RestoreRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.

func (*RestoreRequest) GetRestorePath 

func (x *RestoreRequest) GetRestorePath() string

func (*RestoreRequest) ProtoMessage 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) ProtoReflect 

func (x *RestoreRequest) ProtoReflect() protoreflect.Message

func (*RestoreRequest) Reset 

func (x *RestoreRequest) Reset()

func (*RestoreRequest) String 

func (x *RestoreRequest) String() string

type Status 

type Status struct {

	// Code captures the error code of the underlying operation.
	// A non zero error code is considered to be a failure.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Message captures if any the error message of the failed operation.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type TrxnRecord 

type TrxnRecord struct {

	// Type indicates the type of this transaction - Put, Delete, etc.
	Type TrxnRecord_TrxnType `protobuf:"varint,1,opt,name=type,proto3,enum=dkv.serverpb.TrxnRecord_TrxnType" json:"type,omitempty"`
	// Key is the byte array representation of the key associated with this transaction.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Value is the byte array representation of the value associated with this transaction.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// expireTS is the epoch seconds value, in int64 to associate with the key in the key value store.
	ExpireTS uint64 `protobuf:"varint,4,opt,name=expireTS,proto3" json:"expireTS,omitempty"`
	// contains filtered or unexported fields
}

func (*TrxnRecord) Descriptor deprecated 

func (*TrxnRecord) Descriptor() ([]byte, []int)

Deprecated: Use TrxnRecord.ProtoReflect.Descriptor instead.

func (*TrxnRecord) GetExpireTS 

func (x *TrxnRecord) GetExpireTS() uint64

func (*TrxnRecord) GetKey 

func (x *TrxnRecord) GetKey() []byte

func (*TrxnRecord) GetType 

func (x *TrxnRecord) GetType() TrxnRecord_TrxnType

func (*TrxnRecord) GetValue 

func (x *TrxnRecord) GetValue() []byte

func (*TrxnRecord) ProtoMessage 

func (*TrxnRecord) ProtoMessage()

func (*TrxnRecord) ProtoReflect 

func (x *TrxnRecord) ProtoReflect() protoreflect.Message

func (*TrxnRecord) Reset 

func (x *TrxnRecord) Reset()

func (*TrxnRecord) String 

func (x *TrxnRecord) String() string

type TrxnRecord_TrxnType 

type TrxnRecord_TrxnType int32
const (
	TrxnRecord_Unknown TrxnRecord_TrxnType = 0
	TrxnRecord_Put     TrxnRecord_TrxnType = 1
	TrxnRecord_Delete  TrxnRecord_TrxnType = 2
)

func (TrxnRecord_TrxnType) Descriptor 

func (TrxnRecord_TrxnType) Descriptor() protoreflect.EnumDescriptor

func (TrxnRecord_TrxnType) Enum 

func (x TrxnRecord_TrxnType) Enum() *TrxnRecord_TrxnType

func (TrxnRecord_TrxnType) EnumDescriptor deprecated 

func (TrxnRecord_TrxnType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TrxnRecord_TrxnType.Descriptor instead.

func (TrxnRecord_TrxnType) Number 

func (x TrxnRecord_TrxnType) Number() protoreflect.EnumNumber

func (TrxnRecord_TrxnType) String 

func (x TrxnRecord_TrxnType) String() string

func (TrxnRecord_TrxnType) Type 

func (TrxnRecord_TrxnType) Type() protoreflect.EnumType

type UnimplementedDKVBackupRestoreServer 

type UnimplementedDKVBackupRestoreServer struct {
}

UnimplementedDKVBackupRestoreServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVBackupRestoreServer) Backup 

func (UnimplementedDKVBackupRestoreServer) Backup(context.Context, *BackupRequest) (*Status, error)

func (UnimplementedDKVBackupRestoreServer) Restore 

func (UnimplementedDKVBackupRestoreServer) Restore(context.Context, *RestoreRequest) (*Status, error)

type UnimplementedDKVClusterServer 

type UnimplementedDKVClusterServer struct {
}

UnimplementedDKVClusterServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVClusterServer) AddNode 

func (UnimplementedDKVClusterServer) AddNode(context.Context, *AddNodeRequest) (*Status, error)

func (UnimplementedDKVClusterServer) ListNodes 

func (UnimplementedDKVClusterServer) ListNodes(context.Context, *emptypb.Empty) (*ListNodesResponse, error)

func (UnimplementedDKVClusterServer) RemoveNode 

func (UnimplementedDKVClusterServer) RemoveNode(context.Context, *RemoveNodeRequest) (*Status, error)

type UnimplementedDKVDiscoveryNodeServer 

type UnimplementedDKVDiscoveryNodeServer struct {
}

UnimplementedDKVDiscoveryNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVDiscoveryNodeServer) GetStatus 

func (UnimplementedDKVDiscoveryNodeServer) GetStatus(context.Context, *emptypb.Empty) (*RegionInfo, error)

type UnimplementedDKVDiscoveryServer 

type UnimplementedDKVDiscoveryServer struct {
}

UnimplementedDKVDiscoveryServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVDiscoveryServer) GetClusterInfo 

func (UnimplementedDKVDiscoveryServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (UnimplementedDKVDiscoveryServer) UpdateStatus 

func (UnimplementedDKVDiscoveryServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*Status, error)

type UnimplementedDKVReplicationServer 

type UnimplementedDKVReplicationServer struct {
}

UnimplementedDKVReplicationServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVReplicationServer) AddReplica 

func (UnimplementedDKVReplicationServer) AddReplica(context.Context, *Replica) (*Status, error)

func (UnimplementedDKVReplicationServer) GetChanges 

func (UnimplementedDKVReplicationServer) GetChanges(context.Context, *GetChangesRequest) (*GetChangesResponse, error)

func (UnimplementedDKVReplicationServer) GetReplicas 

func (UnimplementedDKVReplicationServer) GetReplicas(context.Context, *GetReplicasRequest) (*GetReplicasResponse, error)

func (UnimplementedDKVReplicationServer) RemoveReplica 

func (UnimplementedDKVReplicationServer) RemoveReplica(context.Context, *Replica) (*Status, error)

type UnimplementedDKVServer 

type UnimplementedDKVServer struct {
}

UnimplementedDKVServer should be embedded to have forward compatible implementations.

func (UnimplementedDKVServer) CompareAndSet 

func (UnimplementedDKVServer) CompareAndSet(context.Context, *CompareAndSetRequest) (*CompareAndSetResponse, error)

func (UnimplementedDKVServer) Delete 

func (UnimplementedDKVServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedDKVServer) Get 

func (UnimplementedDKVServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedDKVServer) Iterate 

func (UnimplementedDKVServer) Iterate(*IterateRequest, DKV_IterateServer) error

func (UnimplementedDKVServer) MultiGet 

func (UnimplementedDKVServer) MultiGet(context.Context, *MultiGetRequest) (*MultiGetResponse, error)

func (UnimplementedDKVServer) MultiPut 

func (UnimplementedDKVServer) MultiPut(context.Context, *MultiPutRequest) (*PutResponse, error)

func (UnimplementedDKVServer) Put 

func (UnimplementedDKVServer) Put(context.Context, *PutRequest) (*PutResponse, error)

type UnsafeDKVBackupRestoreServer 

type UnsafeDKVBackupRestoreServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVBackupRestoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVBackupRestoreServer will result in compilation errors.

type UnsafeDKVClusterServer 

type UnsafeDKVClusterServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVClusterServer will result in compilation errors.

type UnsafeDKVDiscoveryNodeServer 

type UnsafeDKVDiscoveryNodeServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVDiscoveryNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVDiscoveryNodeServer will result in compilation errors.

type UnsafeDKVDiscoveryServer 

type UnsafeDKVDiscoveryServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVDiscoveryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVDiscoveryServer will result in compilation errors.

type UnsafeDKVReplicationServer 

type UnsafeDKVReplicationServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVReplicationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVReplicationServer will result in compilation errors.

type UnsafeDKVServer 

type UnsafeDKVServer interface {
	// contains filtered or unexported methods
}

UnsafeDKVServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DKVServer will result in compilation errors.

type UpdateStatusRequest 

type UpdateStatusRequest struct {
	RegionInfo *RegionInfo `protobuf:"bytes,1,opt,name=regionInfo,proto3" json:"regionInfo,omitempty"`
	// Time at which the status was sent from the respective node
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStatusRequest) Descriptor deprecated 

func (*UpdateStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateStatusRequest) GetRegionInfo 

func (x *UpdateStatusRequest) GetRegionInfo() *RegionInfo

func (*UpdateStatusRequest) GetTimestamp 

func (x *UpdateStatusRequest) GetTimestamp() uint64

func (*UpdateStatusRequest) ProtoMessage 

func (*UpdateStatusRequest) ProtoMessage()

func (*UpdateStatusRequest) ProtoReflect 

func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateStatusRequest) Reset 

func (x *UpdateStatusRequest) Reset()

func (*UpdateStatusRequest) String 

func (x *UpdateStatusRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.