replica

package

v0.0.0-...-d00d6e8 Latest Latest Go to latest Published: Jun 1, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewReplica(pid int, storage *storage.InMemory) *Replica

func (r *Replica) Accept(
	sender int,
	request *rpc.AcceptRequest,
) (*rpc.AcceptResponse, error)

func (r *Replica) Apply(
	sender int,
	request *rpc.ApplyRequest,
) error

func (r *Replica) Commit(
	sender int,
	request *rpc.CommitRequest,
) error

func (r *Replica) Pid() int

func (r *Replica) PreAccept(
	sender int,
	request *rpc.PreAcceptRequest,
) (*rpc.PreAcceptResponse, error)

func (r *Replica) Read(
	sender int,
	request *rpc.ReadRequest,
) (map[string]string, error)

func (r *Replica) Snapshot() (map[string]string, error)

type State int

const (
	StateRunning State = iota
	StatePaused
	StateStopped
)