serverpb

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
}

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
}

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
}

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
}

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
}

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)
}

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)
}

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)
}

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)
}

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)
}

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)
}

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

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

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)
}

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)
}

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)
}

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)
}

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

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

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
}

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
}

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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

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
}

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
}

type ReadConsistency int32

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
}

type RegionStatus int32

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
}

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
}

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
}

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
}

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
}

type TrxnRecord_TrxnType int32

type UnimplementedDKVBackupRestoreServer struct {
}

type UnimplementedDKVClusterServer struct {
}

type UnimplementedDKVDiscoveryNodeServer struct {
}

type UnimplementedDKVDiscoveryServer struct {
}

type UnimplementedDKVReplicationServer struct {
}

type UnimplementedDKVServer struct {
}

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

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

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

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

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

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

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
}