raft

type GRPCConfig struct {
	KeepAliveMinTime     int
	WriteBufferSize      int
	ReadBufferSize       int
	MaxRecvMsgSize       int
	MaxSendMsgSize       int
	MaxConcurrentStreams uint32
}

type MoveTo struct {
	pb.UnimplementedMoveToServer
	// contains filtered or unexported fields
}

type RaftConfig struct {
	LogDir   string
	LogLevel zapcore.Level

	// 本机IP地址
	HostIP string

	// ReplicaId一旦生成不能变动
	ReplicaId uint64

	// 该节点被分配的shardIds
	ShardIds []uint64

	// raft通信地址
	RaftAddr string

	// 用于moveTo命令时对方raft节点的grpc端口
	GrpcPort uint16

	// raft shard的分组个数, 用于hashKey计算shardId
	MultiGroupSize uint32

	// 数据存储地址
	StorageDir string

	// 是否以join的方式加入raft集群
	Join map[uint64]map[uint64]bool

	// 此参数需注意的是:
	// 采用gossip方式启动时val是nodehostId, 详细参考dragonboat的文档,
	// 初次可以使用dragonboat id.NewNodeHostID(id uint64)来生成;
	// 若采用raftAddr固定不变的方式启动，val就是raftAddr
	// key: shardId, key:replicaId
	InitialMembers map[uint64]map[uint64]string

	// 如果raft集群采用gossip可变IP的方式启动需设置
	Gossip      bool
	GossipPort  uint16
	GossipSeeds []string

	// dragonboat 是否开启metrics
	Metrics bool

	// 自己内部的gossip配置
	GossipConfig gossip.GossipConfig
}

type RaftMetadata struct {
	// raft shard的分组个数, 用于hashKey计算shardId
	MultiGroupSize uint32 `json:"multiGroupSize"`

	// 本地的节点ID
	ReplicaId uint64 `json:"replicaId"`

	// raft节点的IP地址
	// 启动前需校验机器IP是否发生变化
	LocalIP string `json:"localIP"`

	// raft的通信端口号
	RaftPort uint16 `json:"raftPort"`

	// moveTo grpc端口号
	GrpcPort uint16 `json:"grpcPort"`

	// 是否采用gossip方式启动
	Gossip bool `json:"gossip"`

	// 节点shardId分配的版本号
	Revision int64 `json:"revision"`

	// 如果raft集群采用gossip可变IP的方式启动需设置
	GossipPort  uint16   `json:"gossipPort"`
	GossipSeeds []string `json:"gossipSeeds"`

	// dragonboat 是否开启metrics
	Metrics bool `json:"metrics"`

	// 自己内部的gossip配置
	GossipConfig gossip.GossipConfig `json:"gossipConfig"`
}

type RaftOpType uint8

type StateMachine struct {
	ShardId   uint64
	ReplicaID uint64
	// contains filtered or unexported fields
}

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