serverpb

package
v0.0.0-...-1aaebbc Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 (
	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 File_pkg_serverpb_api_proto protoreflect.FileDescriptor

Functions

func RegisterDKVBackupRestoreServer 

func RegisterDKVBackupRestoreServer(s *grpc.Server, srv DKVBackupRestoreServer)

func RegisterDKVClusterServer 

func RegisterDKVClusterServer(s *grpc.Server, srv DKVClusterServer)

func RegisterDKVReplicationServer 

func RegisterDKVReplicationServer(s *grpc.Server, srv DKVReplicationServer)

func RegisterDKVServer 

func RegisterDKVServer(s *grpc.Server, 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"`
	// contains filtered or unexported fields
}

func (*CompareAndSetRequest) Descriptor deprecated 

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

Deprecated: Use CompareAndSetRequest.ProtoReflect.Descriptor instead.

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://godoc.org/google.golang.org/grpc#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.

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)
	// 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://godoc.org/google.golang.org/grpc#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 *empty.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://godoc.org/google.golang.org/grpc#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, *empty.Empty) (*ListNodesResponse, error)
}

DKVClusterServer is the server API for DKVCluster service.

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://godoc.org/google.golang.org/grpc#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.

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)
	// 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.

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 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"`
	// contains filtered or unexported fields
}

func (*KVPair) Descriptor deprecated 

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

Deprecated: Use KVPair.ProtoReflect.Descriptor instead.

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]string `` /* 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]string

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 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 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 can 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 can 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, *empty.Empty) (*ListNodesResponse, error)

func (*UnimplementedDKVClusterServer) RemoveNode 

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

type UnimplementedDKVReplicationServer 

type UnimplementedDKVReplicationServer struct {
}

UnimplementedDKVReplicationServer can 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 can 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) Put 

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

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.