bully

Documentation

Index

• type Process
  • func New(e *communication.Emitter, heartbeatPause time.Duration) *Process
  • func (b *Process) Boot()
• type Setup
  • func (s Setup) Setup(c int, e *communication.Emitter, t time.Duration) map[string]server.Process

Types

type Process

type Process struct {
	server.Base
	NeighborServers map[string]*Process
	// contains filtered or unexported fields
}

Process extends Base to implement the bully algorithm

func New

func New(e *communication.Emitter, heartbeatPause time.Duration) *Process

New will create a new instance of a bully server

func (*Process) Boot

func (b *Process) Boot()

Boot brings up the server and runs main process. This function blocks while the process is active

type Setup

type Setup struct {
}

Setup is used in the cluster to create an array of servers of the bully type

func (Setup) Setup

func (s Setup) Setup(c int, e *communication.Emitter, t time.Duration) map[string]server.Process

Setup links together and creates the specified amount of bully election servers together