durable

type ChecksumRequestCmd struct {
}

type ChecksumRes struct {
	Index    uint64 // Index of the ChecksumRequestCmd itself
	Checksum uint32 // Computed checksum
}

type ChecksumVerifyCmd struct {
	Index    uint64 // Index of the corresponding ChecksumRequestCommand
	Checksum uint32 // Checksum to verify
}

type Command struct {
	Cmd interface{}
}

type NewPartitionCmd struct {
	CuratorID core.CuratorID
}

type NewPartitionRes struct {
	PartitionID core.PartitionID
	Err         core.Error
}

type RegisterCuratorCmd struct {
}

type RegisterTractserverCmd struct {
}

type SetReadOnlyModeCmd struct {
	ReadOnly bool
}

type State struct {
	// List of curators managing the assigned partitions.
	//
	// Note that we are currently assuming that:
	// 1. CuratorIDs never go away and
	// 2. CuratorIDs are never reused.
	//
	// Curators own metadata, and to lose a curator replica group entirely
	// would be a disaster that we would have to recover from by determining
	// which blobIDs were not managed by a curator. In this case, we might
	// as well use the same CuratorID. Also, we can change this decision later.
	//
	// The slice is indexed by the partition IDs and stores curator IDs.
	// Note that valid partition and curator IDs start from 1 and thus we
	// reserve the first spot. This layout optimizes the lookup from blob
	// (partition) to curator with O(1) cost but has O(n) cost for returning
	// the list of partitions owned by a given curator. An alternative is to
	// store the reversed mapping from curators to list of partitions, which
	// works best for the second query. We opt for this design because the
	// first query happens much more frequently than the second.
	Partitions []core.CuratorID

	// The next curator ID we assign.
	NextCuratorID core.CuratorID

	// The next tractserver ID we assign.
	NextTractserverID core.TractserverID

	// Are we currently read-only?
	ReadOnly bool
}

type StateConfig struct {
	raft.Config                `json:"Config"`            // Parameters for Raft core.
	raft.TransportConfig       `json:"TransportConfig"`   // Parameters for Raft transport.
	raftrpc.RPCTransportConfig `json:"RPCTransporConfig"` // Parameters for Raft RPC transport.
	raftfs.StorageConfig       `json:"StorageConfig"`     // Parameters for Raft storage.

	// The callback for newly elected leader. This function, if not-nil, is called
	// synchronously by Raft when a member becomes the leader of the replication group.
	OnLeader func()
}

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