rpc_replicated

Documentation

Index

• type RPCMachineContext
  • func NewRPCMachineContext(params []single.Param, me int, world []bftevent.BFTEventClient, seed int) RPCMachineContext
• type RPCMachineContextService
  • func (r *RPCMachineContextService) AddEventFromRPC(name string, from machine.MachineId, parameters []string, delay int)
  • func (r *RPCMachineContextService) AddEvents(events []events.Event)
  • func (r *RPCMachineContextService) Broadcast(event string, eventArgs []string)
  • func (r *RPCMachineContextService) GetEvents() []events.Event
  • func (r *RPCMachineContextService) GetMe() int
  • func (r *RPCMachineContextService) GetParams() []single.Param
  • func (r *RPCMachineContextService) GetWorld() []bftevent.BFTEventClient
  • func (r *RPCMachineContextService) HasEvent(name string, eventArgs []string) bool
  • func (r *RPCMachineContextService) RegisterEvent(event events.Event)
  • func (r *RPCMachineContextService) String() string
  • func (r *RPCMachineContextService) TestSetDropRate(dropRate float64)
  • func (r *RPCMachineContextService) TestSetRegularDelay(testRegularDelayMS int)

Types

type RPCMachineContext

type RPCMachineContext interface {
	// get / set
	GetParams() []single.Param
	GetMe() int
	GetWorld() []bftevent.BFTEventClient
	GetEvents() []events.Event
	// methods
	TestSetRegularDelay(testRegularDelayMS int)
	TestSetDropRate(dropRate float64)
	HasEvent(name string, eventArgs []string) bool
	RegisterEvent(event events.Event)
	AddEvents(events []events.Event)
	Broadcast(event string, eventArgs []string)
	AddEventFromRPC(name string, from machine.MachineId, parameters []string, delay int)

	String() string
}

func NewRPCMachineContext

func NewRPCMachineContext(params []single.Param, me int, world []bftevent.BFTEventClient, seed int) RPCMachineContext

type RPCMachineContextService

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

func (*RPCMachineContextService) AddEventFromRPC

func (r *RPCMachineContextService) AddEventFromRPC(name string, from machine.MachineId, parameters []string, delay int)

func (*RPCMachineContextService) AddEvents

func (r *RPCMachineContextService) AddEvents(events []events.Event)

func (*RPCMachineContextService) Broadcast

func (r *RPCMachineContextService) Broadcast(event string, eventArgs []string)

func (*RPCMachineContextService) GetEvents

func (r *RPCMachineContextService) GetEvents() []events.Event

func (*RPCMachineContextService) GetMe

func (r *RPCMachineContextService) GetMe() int

func (*RPCMachineContextService) GetParams

func (r *RPCMachineContextService) GetParams() []single.Param

func (*RPCMachineContextService) GetWorld

func (r *RPCMachineContextService) GetWorld() []bftevent.BFTEventClient

func (*RPCMachineContextService) HasEvent

func (r *RPCMachineContextService) HasEvent(name string, eventArgs []string) bool

func (*RPCMachineContextService) RegisterEvent

func (r *RPCMachineContextService) RegisterEvent(event events.Event)

func (*RPCMachineContextService) String

func (r *RPCMachineContextService) String() string

func (*RPCMachineContextService) TestSetDropRate

func (r *RPCMachineContextService) TestSetDropRate(dropRate float64)

func (*RPCMachineContextService) TestSetRegularDelay

func (r *RPCMachineContextService) TestSetRegularDelay(testRegularDelayMS int)