kpaxos

package

v0.0.0-...-6823d0b Latest Latest Go to latest Published: Dec 29, 2023 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Accept struct {
	Key paxi.Key
	paxos.P2a
}

Accept phase 2a

func (a Accept) String() string

type Accepted struct {
	Key paxi.Key
	paxos.P2b
}

Accepted phase 2b

func (a Accepted) String() string

type Commit struct {
	Key paxi.Key
	paxos.P3
}

Commit phase 3

func (c Commit) String() string

type LeaderChange struct {
	Key    paxi.Key
	To     paxi.ID
	From   paxi.ID
	Ballot paxi.Ballot
}

LeaderChange switch leader

func (l LeaderChange) String() string

type Prepare struct {
	Key paxi.Key
	paxos.P1a
}

Prepare phase 1a

func (p Prepare) String() string

type Promise struct {
	Key paxi.Key
	paxos.P1b
}

Promise phase 1b

func (p Promise) String() string

type Replica struct {
	paxi.Node
	// contains filtered or unexported fields
}

Replica KPaxos replica with Paxos instance for each key

func NewReplica(id paxi.ID) *Replica

func (r *Replica) Broadcast(msg interface{})

Broadcast overrides Socket interface in Node

func (r *Replica) Send(to paxi.ID, msg interface{})

Send overrides Socket interface in Node