raftlog

Documentation

Index

• Constants
• func New(thisReplica uint64, initialReplicas []uint64, db kv.DB, prefix []byte, ...) replication.LogReplicator

Constants

const (
	HARDSTATE_KEY    = "HS"
	CONFSTATE_KEY    = "CS"
	ENTRY_KEY_PREFIX = "E"
	COMMITTED_BUFFER = 10 // It's fine to let commit run asynchronously ahead of apply
)

Functions

func New

func New(
	thisReplica uint64, initialReplicas []uint64,
	db kv.DB, prefix []byte,
	clk clock.Clock, tickInterval time.Duration,
	server *grpc.Server, dial func(id uint64) proto.RaftClient,
) replication.LogReplicator

New initializes a replication.LogReplicator using an already open kv.DB and registers a raft service with server. It is the caller's responsibility to call Serve.