wankeeper

package
v0.0.0-...-6823d0b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 29, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Ack

type Ack struct {
	Ballot paxi.Ballot
	ID     paxi.ID
	Slot   int
	Key    paxi.Key
}

Ack from follower to leader

func (Ack) String

func (m Ack) String() string

type Commit

type Commit struct {
	Ballot  paxi.Ballot
	Slot    int
	Command paxi.Command
}

Commit phase 3

func (Commit) String

func (c Commit) String() string

type NewBallot

type NewBallot struct {
	Ballot paxi.Ballot
}

NewBallot message starts a new leader election

type NewLeader

type NewLeader struct {
	Ballot paxi.Ballot
}

NewLeader message actives leader

func (NewLeader) String

func (m NewLeader) String() string

type Proposal

type Proposal struct {
	Ballot  paxi.Ballot
	Slot    int
	Command paxi.Command
}

Proposal from leader to followers

func (Proposal) String

func (m Proposal) String() string

type Replica

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

func NewReplica

func NewReplica(id paxi.ID) *Replica

NewReplica creates new replica object for wankeeper

func (*Replica) Run

func (r *Replica) Run()

Run overrides Node.Run() function to start leader election

type Revoke

type Revoke struct {
	Key paxi.Key
}

Revoke tokens

type Token

type Token struct {
	Key paxi.Key
}

Token sending between regions

type Vote

type Vote struct {
	Ballot paxi.Ballot
	ID     paxi.ID
}

Vote message acks NewBallot election

func (Vote) String

func (m Vote) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL