memkv

type GetOptions struct {
	// Requires strong consistent read
	// Guarentees to see all the writes that happens before this read request in physical time
	Linearizability bool
	// The last seen LSN
	// By default session consistency is provided by connecting to the same replica
	// however, in case of failover, a provided SessionLSN will provide the same session
	// consistency guarentee by blocking the request until LSN has been observed by the replica
	// Session consistency provides the following guarentees: Read-your-write, Monotic Read, Read after write
	// Will be ignored if Linearizability is true
	SessionLSN *int64
}

type GetReq struct {
	Key     string
	Options GetOptions
}

type GetResp struct {
	LSN   int64 // the most recent LSN this request had been observed
	Exist bool
	Value []byte
}

type KVRequest struct {
	OriginNode string `protobuf:"bytes,1,opt,name=origin_node,json=originNode,proto3" json:"origin_node,omitempty"`
	// Types that are assignable to Request:
	//
	//	*KVRequest_Set
	Request isKVRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type KVRequest_Set struct {
	Set *SetRequest `protobuf:"bytes,2,opt,name=set,proto3,oneof"`
}

type KVStore interface {
	Set(req SetReq) (*SetResp, error)
	Get(req GetReq) (*GetResp, error)
}

type MemKvStore struct {
	// contains filtered or unexported fields
}

type SetOptions struct {
	// concurrency control
	// only proceed the operation if timestamp matches
	IfValueIs []byte
	IfLSNIs   *int64
	IfExistIs *bool
}

type SetReq struct {
	Key   string
	Value []byte
	// Set true to delete the value
	Delete  bool
	Options SetOptions
}

type SetRequest struct {
	RequestId  string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Key        string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value      []byte `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
	Delete     *bool  `protobuf:"varint,4,opt,name=delete,proto3,oneof" json:"delete,omitempty"`
	IfValueIs  []byte `protobuf:"bytes,5,opt,name=if_value_is,json=ifValueIs,proto3,oneof" json:"if_value_is,omitempty"`
	IfLsnIs    *int64 `protobuf:"varint,6,opt,name=if_lsn_is,json=ifLsnIs,proto3,oneof" json:"if_lsn_is,omitempty"`
	IfExistsIs *bool  `protobuf:"varint,7,opt,name=if_exists_is,json=ifExistsIs,proto3,oneof" json:"if_exists_is,omitempty"`
	// contains filtered or unexported fields
}

type SetResp struct {
	Success bool

	// current LSN
	LSN int64
}

type StoreConfig struct {
	DatafilePath   string
	DatafilePrefix string
}