Documentation
¶
Index ¶
Constants ¶
const ( OK = "OK" ErrNoKey = "ErrNoKey" )
const Debug = 0
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Clerk ¶
type Clerk struct {
// contains filtered or unexported fields
}
func (*Clerk) Get ¶
fetch the current value for a key. returns "" if the key does not exist. keeps trying forever in the face of all other errors.
you can send an RPC with code like this: ok := ck.servers[i].Call("RaftKV.Get", &args, &reply)
the types of args and reply (including whether they are pointers) must match the declared types of the RPC handler function's arguments. and reply must be passed as a pointer.
func (*Clerk) PutAppend ¶
shared by Put and Append.
you can send an RPC with code like this: ok := ck.servers[i].Call("RaftKV.PutAppend", &args, &reply)
the types of args and reply (including whether they are pointers) must match the declared types of the RPC handler function's arguments. and reply must be passed as a pointer.
type PutAppendArgs ¶
type PutAppendArgs struct {
// You'll have to add definitions here.
Key string
Value string
Op string // "Put" or "Append"
ClientID int64
ReqID int
}
Put or Append
func (PutAppendArgs) String ¶
func (obj PutAppendArgs) String() string
type PutAppendReply ¶
func (PutAppendReply) String ¶
func (obj PutAppendReply) String() string
type RaftKV ¶
type RaftKV struct {
// contains filtered or unexported fields
}
func StartKVServer ¶
func StartKVServer(servers []labrpc.Client, me int, persister *raft.Persister, maxraftstate int) *RaftKV
servers[] contains the ports of the set of servers that will cooperate via Raft to form the fault-tolerant key/value service. me is the index of the current server in servers[]. the k/v server should store snapshots with persister.SaveSnapshot(), and Raft should save its state (including log) with persister.SaveRaftState(). the k/v server should snapshot when Raft's saved state exceeds maxraftstate bytes, in order to allow Raft to garbage-collect its log. if maxraftstate is -1, you don't need to snapshot. StartKVServer() must return quickly, so it should start goroutines for any long-running work.
func (*RaftKV) AppendEntryToLog ¶
func (*RaftKV) Kill ¶
func (kv *RaftKV) Kill()
the tester calls Kill() when a RaftKV instance won't be needed again. you are not required to do anything in Kill(), but it might be convenient to (for example) turn off debug output from this instance.
func (*RaftKV) PutAppend ¶
func (kv *RaftKV) PutAppend(args *PutAppendArgs, reply *PutAppendReply) error
Source Files