Types & classes — github.com/aQuaYi/MIT-6.824-Distributed-Systems

CodeHub MCPcopy Create free account

hub / github.com/aQuaYi/MIT-6.824-Distributed-Systems / types & classes

Types & classes96 in github.com/aQuaYi/MIT-6.824-Distributed-Systems

⨍ Functions 473◇ Types & classes 96

↓ 9 callersFuncTypefsmHandler

func(*Raft, interface{}) fsmState

src/raft/fsm.go:7

↓ 4 callersTypeAliasfsmEvent

src/raft/fsm.go:6

↓ 2 callersTypeAliasbitset

src/linearizability/bitset.go:3

↓ 1 callersTypeAliasbyTime

src/linearizability/linearizability.go:23

StructAppendEntriesArgs

AppendEntriesArgs 是添加 log 的参数

src/raft/rpc_appendEntries.go:8

StructAppendEntriesReply

AppendEntriesReply 是 flower 回复 leader 的内容

src/raft/rpc_appendEntries.go:25

ApplyMsg 是发送消息 as each Raft peer becomes aware that successive log entries are committed, the peer should send an ApplyMsg to the service (or tester)

src/raft/applyMsg.go:19

src/shardmaster/client.go:12

src/kvraft/client.go:8

src/shardkv/client.go:38

StructClientEnd

src/labrpc/labrpc.go:75

A configuration -- an assignment of shards to groups. Please don't change this.

src/shardmaster/common.go:25

src/labgob/test_test.go:149

StructDoTaskArgs

What follows are RPC types and methods. Field names must start with capital letters, otherwise RPC will break. DoTaskArgs holds the arguments that are

src/mapreduce/common_rpc.go:13

src/shardmaster/common.go:35

src/kvraft/common.go:8

src/shardkv/common.go:18

Err 定义错误类型

Lectures/LEC02/kv/kv.go:86

src/linearizability/model.go:17

TypeAliasEventKind

src/linearizability/model.go:10

InterfaceFetcher

Fetcher Fetcher 接口

Lectures/LEC02/crawler/crawler.go:159

src/kvraft/common.go:25

src/shardkv/common.go:36

GetArgs : Get 命令输入参数

Lectures/LEC02/kv/kv.go:89

src/kvraft/common.go:30

src/shardkv/common.go:41

GetReply : Get 命令返回结果的结构体

Lectures/LEC02/kv/kv.go:94

StructInstallSnapshotArgs

InstallSnapshotArgs is

src/raft/rpc_snapshot.go:9

StructInstallSnapshotReply

InstallSnapshotReply is

src/raft/rpc_snapshot.go:18

src/shardmaster/common.go:37

StructJoinReply

src/shardmaster/common.go:41

src/labrpc/test_test.go:10

StructJunkReply

src/labrpc/test_test.go:13

StructJunkServer

src/labrpc/test_test.go:17

Server KV 是键值对其实例会在 rpc 中注册，供客户端远程访问

Lectures/LEC02/kv/kv.go:44

src/kvraft/server.go:26

KeyValue is a type used to hold the key/value pairs passed to the map and reduce functions.

src/mapreduce/common.go:29

src/linearizability/models.go:5

src/linearizability/models.go:11

StructLabDecoder

src/labgob/labgob.go:42

StructLabEncoder

src/labgob/labgob.go:22

StructLeaveArgs

src/shardmaster/common.go:46

StructLeaveReply

src/shardmaster/common.go:50

LogEntry is log entry

src/raft/logEntry.go:4

Master holds all the state that the master needs to keep track of.

src/mapreduce/master.go:14

src/linearizability/model.go:23

src/shardmaster/common.go:55

StructMoveReply

src/shardmaster/common.go:60

src/labrpc/labrpc.go:116

src/shardmaster/server.go:19

src/kvraft/server.go:20

src/shardkv/server.go:9

StructOperation

src/linearizability/model.go:3

StructParallelism

Parallelism track whether workers executed in parallel.

src/mapreduce/worker.go:18

StructPersister

src/raft/persister.go:15

StructPutAppendArgs

src/kvraft/common.go:11

StructPutAppendArgs

src/shardkv/common.go:21

StructPutAppendReply

src/kvraft/common.go:20

StructPutAppendReply

src/shardkv/common.go:31

PutArgs : Put 输入命令参数

Lectures/LEC02/kv/kv.go:118

PutReply : Put 命令返回结果的结构体

Lectures/LEC02/kv/kv.go:124

StructQueryArgs

src/shardmaster/common.go:65

StructQueryReply

src/shardmaster/common.go:69

Raft implements a single Raft peer.

src/raft/raft_new.go:11

StructRegisterArgs

RegisterArgs is the argument passed when a worker registers with the master.

src/mapreduce/common_rpc.go:32

StructRequestVoteArgs

RequestVoteArgs 获取投票参数 example RequestVote RPC arguments structure. field names must start with capital letters!

src/raft/rpc_requestVote.go:11

StructRequestVoteReply

RequestVoteReply 投票回复 example RequestVote RPC reply structure. field names must start with capital letters!

src/raft/rpc_requestVote.go:29

a server is a collection of services, all sharing the same rpc dispatcher. so that e.g. both a Raft and a k/v server can listen to the same rpc endpo

src/labrpc/labrpc.go:369

an object with methods that can be called via RPC. a single server may have more than one Service.

src/labrpc/labrpc.go:422

src/shardkv/server.go:15

StructShardMaster

src/shardmaster/server.go:8

StructShutdownReply

ShutdownReply is the response to a WorkerShutdown. It holds the number of tasks this worker has processed since it was started.

src/mapreduce/common_rpc.go:27

src/labgob/test_test.go:7

src/labgob/test_test.go:14

src/labgob/test_test.go:20

src/labgob/test_test.go:110

Worker holds the state for a server waiting for DoTask or Shutdown RPCs

src/mapreduce/worker.go:25

src/raft/applyMsg_test.go:6

StructcacheEntry

src/linearizability/linearizability.go:128

StructcallsEntry

src/linearizability/linearizability.go:142

src/shardmaster/config.go:34

src/kvraft/config.go:44

src/raft/config.go:37

src/shardkv/config.go:53

src/linearizability/linearizability.go:16

TypeAliasentryKind

src/linearizability/linearizability.go:9

TypeAliasfakeFetcher

fakeFetcher is Fetcher that returns canned results.

Lectures/LEC02/crawler/crawler.go:165

StructfakeResult

Lectures/LEC02/crawler/crawler.go:167

StructfetchState

Concurrent crawler with shared state and Mutex fetchState 管理抓取时候的状态

Lectures/LEC02/crawler/crawler.go:45

TypeAliasfsmState

src/raft/fsm.go:5

src/shardkv/config.go:45

TypeAliasjobPhase

jobPhase indicates whether a task is scheduled as a map or reduce task.

src/mapreduce/common.go:20

src/linearizability/linearizability.go:51

src/labrpc/labrpc.go:70

src/labrpc/labrpc.go:62

StructtoFollowerArgs

src/raft/fsm_handlers.go:252