components

Documentation

Index

• Constants
• type Acceptor
  • func NewAcceptor(exchange v1.MessageExchange) *Acceptor
  • func (accp *Acceptor) Run()
• type Client
  • func NewClient(exchange v1.MessageExchange, interval time.Duration) *Client
  • func (c *Client) Run()
  • func (c *Client) Stop()
• type Commander
  • func NewCommander(exchange v1.MessageExchange, leader v1.Addr, acceptors []v1.Addr, ...) *Commander
  • func (cmdr *Commander) Run()
• type Leader
  • func NewLeader(exchange v1.MessageExchange, acceptors []v1.Addr) *Leader
  • func (leader *Leader) Run()
• type Replica
  • func NewReplica(exchange v1.MessageExchange, leaders []v1.Addr) *Replica
  • func (r *Replica) Run()
• type Scout
  • func NewScout(exchange v1.MessageExchange, leader v1.Addr, acceptors []v1.Addr, ...) *Scout
  • func (scout *Scout) Run()

Constants

const (
	Window             types.Slot = 5
	InitialSlotID      types.Slot = 1
	InitialRequestSize            = 100
)

Types

type Acceptor

type Acceptor struct {
	v1.Process

	// Set of PValues accepted so far
	Accepted types.PValues

	// Last Adopted ballot number
	BN *types.BallotNumber
	// contains filtered or unexported fields
}

func NewAcceptor

func NewAcceptor(exchange v1.MessageExchange) *Acceptor

func (*Acceptor) Run

func (accp *Acceptor) Run()

type Client

type Client struct {
	v1.Process
	// contains filtered or unexported fields
}

func NewClient

func NewClient(exchange v1.MessageExchange, interval time.Duration) *Client

func (*Client) Run

func (c *Client) Run()

func (*Client) Stop

func (c *Client) Stop()

type Commander

type Commander struct {
	v1.Process
	// contains filtered or unexported fields
}

func NewCommander

func NewCommander(exchange v1.MessageExchange, leader v1.Addr, acceptors []v1.Addr, pvalue types.PValue) *Commander

func (*Commander) Run

func (cmdr *Commander) Run()

type Leader

type Leader struct {
	v1.Process
	// contains filtered or unexported fields
}

func NewLeader

func NewLeader(exchange v1.MessageExchange, acceptors []v1.Addr) *Leader

func (*Leader) Run

func (leader *Leader) Run()

type Replica

type Replica struct {
	v1.Process
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(exchange v1.MessageExchange, leaders []v1.Addr) *Replica

func (*Replica) Run

func (r *Replica) Run()

type Scout

type Scout struct {
	v1.Process
	// contains filtered or unexported fields
}

func NewScout

func NewScout(exchange v1.MessageExchange, leader v1.Addr, acceptors []v1.Addr, number types.BallotNumber) *Scout

func (*Scout) Run

func (scout *Scout) Run()