Class Raft

ZezeJava/ZezeJavaTest/src/SimpleRaft/Raft.java:8–488

import org.jetbrains.annotations.Nullable;

public class Raft {
	public static class Log {
		final long key; // log的唯一key. 防止重复. 由客户端填写
		long index; // 每条log的索引. 在log序列中顺序排列. 由leader填写
		long term; // 每条log的term值. 由leader填写

		public Log(long key) {
			this.key = key;
		}

		public long getKey() {
			return key;
		}

		public final long getIndex() {
			return index;
		}

		protected void execute() {
		}

		@Override
		public @NotNull String toString() {
			return "Log{" + "index=" + index + ", term=" + term + '}';
		}
	}

	public interface Env {
		long getCurTime();

		int random(int max); // return [0, max)

		@Nullable Object recvEvent(); // return null if no event

		void sendEvent(int id, @NotNull Object obj);

		void sendClientEvent(@NotNull Object obj);

		long getLogCount();

		Log getLog(long index); // return null if not exist

		@NotNull Log @NotNull [] getLogs(long indexBegin, long indexEnd); // [indexBegin, indexEnd)

		@Nullable Log getLogByKey(long key); // return null if not exist

		boolean appendLog(@NotNull Log log); // return false if this log(key) is already appended

		void appendLogs(@NotNull Log @NotNull [] logs); // ignore already appended log(key)s

		void truncateLogs(long logCount);

		void traceInfo(@NotNull String format);
	}

	private static final class RequestVote {
		final long term;
		final int candidateId;