Documentation
¶
Index ¶
- Constants
- func DPrintf(format string, a ...interface{}) (n int, err error)
- type Clerk
- type Err
- type GetArgs
- type GetReply
- type Op
- type OpReply
- type PutAppendArgs
- type PutAppendReply
- type ReConfigArgs
- type ReConfigReply
- type ShardKV
- func (kv *ShardKV) FetchShards(args *TransferShardArgs, reply *TransferShardReply)
- func (kv *ShardKV) Get(args *GetArgs, reply *GetReply)
- func (kv *ShardKV) Kill()
- func (kv *ShardKV) PutAppend(args *PutAppendArgs, reply *PutAppendReply)
- func (kv *ShardKV) ReConfig(args *ReConfigArgs, reply *ReConfigReply)
- type TransferShardArgs
- type TransferShardReply
Constants ¶
const ( OK = "OK" ErrNoKey = "ErrNoKey" ErrWrongGroup = "ErrWrongGroup" TimeOut = "TimeOut" Error = "Error" Get = "Get" Put = "Put" Append = "Append" Transfer = "Transfer" ReConfig = "ReConfig" NotReady = "NotReady" )
const Debug = 0
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Clerk ¶
type Clerk struct {
// contains filtered or unexported fields
}
func MakeClerk ¶
the tester calls MakeClerk.
masters[] is needed to call shardmaster.MakeClerk().
make_end(servername) turns a server name from a Config.Groups[gid][i] into a labrpc.ClientEnd on which you can send RPCs.
type Op ¶
type Op struct {
// Your definitions here.
// Field names must start with capital letters,
// otherwise RPC will break.
Action string
Args interface{}
}
type PutAppendArgs ¶
type PutAppendArgs struct {
// You'll have to add definitions here.
Key string
Value string
Op string // "Put" or "Append"
// You'll have to add definitions here.
// Field names must start with capital letters,
// otherwise RPC will break.
Cid int64
Seq int64
}
Put or Append
type PutAppendReply ¶
type ReConfigArgs ¶
type ReConfigArgs struct {
// You'll have to add definitions here.
Kvs [shardmaster.NShards]map[string]string
ClientRequests map[int64]int64
NewConfig shardmaster.Config
}
type ReConfigReply ¶
type ReConfigReply struct {
Err Err
}
type ShardKV ¶
type ShardKV struct {
// contains filtered or unexported fields
}
func StartServer ¶
func StartServer(servers []*labrpc.ClientEnd, me int, persister *raft.Persister, maxraftstate int, gid int, masters []*labrpc.ClientEnd, make_end func(string) *labrpc.ClientEnd) *ShardKV
servers[] contains the ports of the servers in this group.
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.
gid is this group's GID, for interacting with the shardmaster.
pass masters[] to shardmaster.MakeClerk() so you can send RPCs to the shardmaster.
make_end(servername) turns a server name from a Config.Groups[gid][i] into a labrpc.ClientEnd on which you can send RPCs. You'll need this to send RPCs to other groups.
look at client.go for examples of how to use masters[] and make_end() to send RPCs to the group owning a specific shard.
StartServer() must return quickly, so it should start goroutines for any long-running work.
func (*ShardKV) FetchShards ¶
func (kv *ShardKV) FetchShards(args *TransferShardArgs, reply *TransferShardReply)
func (*ShardKV) Kill ¶
func (kv *ShardKV) Kill()
the tester calls Kill() when a ShardKV 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 (*ShardKV) PutAppend ¶
func (kv *ShardKV) PutAppend(args *PutAppendArgs, reply *PutAppendReply)
func (*ShardKV) ReConfig ¶
func (kv *ShardKV) ReConfig(args *ReConfigArgs, reply *ReConfigReply)
Source Files