Versions in this module Expand all Collapse all v0 v0.1.0 Jun 4, 2019 Changes in this version + func NewDefendingValidator(core *validatorConfig, assDef protocol.AssertionDefender, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func NewValidatorConfig(address common.Address, config *valmessage.VMConfiguration, ...) *validatorConfig + type AttemptingAssertDefender struct + func (bot AttemptingAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot AttemptingAssertDefender) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c AttemptingAssertDefender) Clone() *validatorCore + func (c AttemptingAssertDefender) DeliverMessagesToVM() + func (c AttemptingAssertDefender) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c AttemptingAssertDefender) GetBalance() *protocol.BalanceTracker + func (c AttemptingAssertDefender) GetConfig() *validatorConfig + func (c AttemptingAssertDefender) GetCore() *validatorCore + func (c AttemptingAssertDefender) GetInbox() *protocol.Inbox + func (c AttemptingAssertDefender) GetMachine() *vm.Machine + func (c AttemptingAssertDefender) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c AttemptingAssertDefender) SendMessageToVM(msg protocol.Message) + func (c AttemptingAssertDefender) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type AttemptingOffchainClosing struct + func (bot AttemptingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot AttemptingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c AttemptingOffchainClosing) Clone() *validatorCore + func (c AttemptingOffchainClosing) DeliverMessagesToVM() + func (c AttemptingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c AttemptingOffchainClosing) GetBalance() *protocol.BalanceTracker + func (c AttemptingOffchainClosing) GetConfig() *validatorConfig + func (c AttemptingOffchainClosing) GetCore() *validatorCore + func (c AttemptingOffchainClosing) GetInbox() *protocol.Inbox + func (c AttemptingOffchainClosing) GetMachine() *vm.Machine + func (c AttemptingOffchainClosing) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c AttemptingOffchainClosing) SendMessageToVM(msg protocol.Message) + func (c AttemptingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type AttemptingUnanimousClosing struct + func (bot AttemptingUnanimousClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot AttemptingUnanimousClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c AttemptingUnanimousClosing) Clone() *validatorCore + func (c AttemptingUnanimousClosing) DeliverMessagesToVM() + func (c AttemptingUnanimousClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c AttemptingUnanimousClosing) GetBalance() *protocol.BalanceTracker + func (c AttemptingUnanimousClosing) GetConfig() *validatorConfig + func (c AttemptingUnanimousClosing) GetCore() *validatorCore + func (c AttemptingUnanimousClosing) GetInbox() *protocol.Inbox + func (c AttemptingUnanimousClosing) GetMachine() *vm.Machine + func (c AttemptingUnanimousClosing) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c AttemptingUnanimousClosing) SendMessageToVM(msg protocol.Message) + func (c AttemptingUnanimousClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type BisectedAssertDefender struct + func (bot BisectedAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot BisectedAssertDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c BisectedAssertDefender) GetConfig() *validatorConfig + type ContinuingChallenger struct + func (bot ContinuingChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot ContinuingChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c ContinuingChallenger) GetConfig() *validatorConfig + type Error struct + func (e *Error) Error() string + type FinalizingAssertObserver struct + ResultChan chan<- bool + func (bot FinalizingAssertObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot FinalizingAssertObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c FinalizingAssertObserver) Clone() *validatorCore + func (c FinalizingAssertObserver) DeliverMessagesToVM() + func (c FinalizingAssertObserver) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c FinalizingAssertObserver) GetBalance() *protocol.BalanceTracker + func (c FinalizingAssertObserver) GetConfig() *validatorConfig + func (c FinalizingAssertObserver) GetCore() *validatorCore + func (c FinalizingAssertObserver) GetInbox() *protocol.Inbox + func (c FinalizingAssertObserver) GetMachine() *vm.Machine + func (c FinalizingAssertObserver) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c FinalizingAssertObserver) SendMessageToVM(msg protocol.Message) + func (c FinalizingAssertObserver) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type FinalizingOffchainClosing struct + func (bot FinalizingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot FinalizingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c FinalizingOffchainClosing) Clone() *validatorCore + func (c FinalizingOffchainClosing) DeliverMessagesToVM() + func (c FinalizingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c FinalizingOffchainClosing) GetBalance() *protocol.BalanceTracker + func (c FinalizingOffchainClosing) GetConfig() *validatorConfig + func (c FinalizingOffchainClosing) GetCore() *validatorCore + func (c FinalizingOffchainClosing) GetInbox() *protocol.Inbox + func (c FinalizingOffchainClosing) GetMachine() *vm.Machine + func (c FinalizingOffchainClosing) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c FinalizingOffchainClosing) SendMessageToVM(msg protocol.Message) + func (c FinalizingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type OneStepChallengedAssertDefender struct + func (bot OneStepChallengedAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot OneStepChallengedAssertDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c OneStepChallengedAssertDefender) GetConfig() *validatorConfig + type TimedOutAsserterChallenger struct + func (bot TimedOutAsserterChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot TimedOutAsserterChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c TimedOutAsserterChallenger) GetConfig() *validatorConfig + type TimedOutAsserterDefender struct + func (bot TimedOutAsserterDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot TimedOutAsserterDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c TimedOutAsserterDefender) GetConfig() *validatorConfig + type TimedOutChallengerChallenger struct + func (bot TimedOutChallengerChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot TimedOutChallengerChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c TimedOutChallengerChallenger) GetConfig() *validatorConfig + type TimedOutChallengerDefender struct + func (bot TimedOutChallengerDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot TimedOutChallengerDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c TimedOutChallengerDefender) GetConfig() *validatorConfig + type Validator struct + Name string + func NewValidator(name string, address common.Address, inbox *protocol.Inbox, ...) *Validator + func (validator *Validator) CloseUnanimousAssertionRequest() <-chan bool + func (validator *Validator) ConfirmOffchainUnanimousAssertion(unanRequest valmessage.UnanimousRequestData, signatures []valmessage.Signature) (<-chan bool, <-chan error) + func (validator *Validator) HasPendingMessages() chan bool + func (validator *Validator) InitiateUnanimousRequest(length uint64, messages []protocol.Message, final bool) (<-chan valmessage.UnanimousRequest, <-chan valmessage.UnanimousUpdateResults, ...) + func (validator *Validator) RequestCall(msg protocol.Message) (<-chan value.Value, <-chan error) + func (validator *Validator) RequestDisputableAssertion(length uint64, includePendingMessages bool) <-chan bool + func (validator *Validator) RequestFollowUnanimous(request valmessage.UnanimousRequestData, messages []protocol.Message) (<-chan valmessage.UnanimousUpdateResults, <-chan error) + func (validator *Validator) RequestVMState() <-chan valmessage.VMStateData + func (validator *Validator) Run(recvChan <-chan valmessage.IncomingValidatorMessage, ...) + type WaitingAssertDefender struct + func (bot WaitingAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingAssertDefender) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c WaitingAssertDefender) Clone() *validatorCore + func (c WaitingAssertDefender) DeliverMessagesToVM() + func (c WaitingAssertDefender) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c WaitingAssertDefender) GetBalance() *protocol.BalanceTracker + func (c WaitingAssertDefender) GetConfig() *validatorConfig + func (c WaitingAssertDefender) GetCore() *validatorCore + func (c WaitingAssertDefender) GetInbox() *protocol.Inbox + func (c WaitingAssertDefender) GetMachine() *vm.Machine + func (c WaitingAssertDefender) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c WaitingAssertDefender) SendMessageToVM(msg protocol.Message) + func (c WaitingAssertDefender) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type WaitingAsserterTimeoutObserver struct + func (bot WaitingAsserterTimeoutObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingAsserterTimeoutObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingAsserterTimeoutObserver) GetConfig() *validatorConfig + type WaitingBisectedDefender struct + func (bot WaitingBisectedDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingBisectedDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingBisectedDefender) GetConfig() *validatorConfig + type WaitingBisectedObserver struct + func (bot WaitingBisectedObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingBisectedObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingBisectedObserver) GetConfig() *validatorConfig + type WaitingChallengeObserver struct + func (bot WaitingChallengeObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingChallengeObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingChallengeObserver) GetConfig() *validatorConfig + type WaitingChallengerTimeoutObserver struct + func (bot WaitingChallengerTimeoutObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingChallengerTimeoutObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingChallengerTimeoutObserver) GetConfig() *validatorConfig + type WaitingContinuingChallenger struct + func (bot WaitingContinuingChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingContinuingChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error) + func (c WaitingContinuingChallenger) GetConfig() *validatorConfig + type WaitingObserver struct + func NewWaitingObserver(config *validatorConfig, core *validatorCore) WaitingObserver + func (bot WaitingObserver) Clone() WaitingObserver + func (bot WaitingObserver) CloseUnanimous(retChan chan<- bool) (validatorState, []valmessage.OutgoingMessage, error) + func (bot WaitingObserver) FastCloseUnanimous() valmessage.SendUnanimousAssertMessage + func (bot WaitingObserver) FinalizePendingUnanimous(signatures []valmessage.Signature) (validatorState, *proposedUpdate, error) + func (bot WaitingObserver) GetCore() *validatorCore + func (bot WaitingObserver) OffchainContext(newMessages []protocol.Message, timeBounds protocol.TimeBounds, final bool) (*protocol.MessageQueue, protocol.TimeBounds, uint64) + func (bot WaitingObserver) OrigInbox() *protocol.Inbox + func (bot WaitingObserver) PreparePendingUnanimous(request valmessage.UnanimousUpdateRequest) (WaitingObserver, error) + func (bot WaitingObserver) ProposalResults() valmessage.UnanimousUpdateResults + func (bot WaitingObserver) ProposedInbox() *protocol.Inbox + func (bot WaitingObserver) SendMessageToVM(msg protocol.Message) + func (bot WaitingObserver) SlowCloseUnanimous() valmessage.SendProposeUnanimousAssertMessage + func (bot WaitingObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c WaitingObserver) GetConfig() *validatorConfig + type WaitingOffchainClosing struct + func (bot WaitingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot WaitingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c WaitingOffchainClosing) Clone() *validatorCore + func (c WaitingOffchainClosing) DeliverMessagesToVM() + func (c WaitingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c WaitingOffchainClosing) GetBalance() *protocol.BalanceTracker + func (c WaitingOffchainClosing) GetConfig() *validatorConfig + func (c WaitingOffchainClosing) GetCore() *validatorCore + func (c WaitingOffchainClosing) GetInbox() *protocol.Inbox + func (c WaitingOffchainClosing) GetMachine() *vm.Machine + func (c WaitingOffchainClosing) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c WaitingOffchainClosing) SendMessageToVM(msg protocol.Message) + func (c WaitingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool + type WatchingAssertionObserver struct + func (bot WatchingAssertionObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error) + func (bot WatchingAssertionObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error) + func (c WatchingAssertionObserver) Clone() *validatorCore + func (c WatchingAssertionObserver) DeliverMessagesToVM() + func (c WatchingAssertionObserver) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition + func (c WatchingAssertionObserver) GetBalance() *protocol.BalanceTracker + func (c WatchingAssertionObserver) GetConfig() *validatorConfig + func (c WatchingAssertionObserver) GetCore() *validatorCore + func (c WatchingAssertionObserver) GetInbox() *protocol.Inbox + func (c WatchingAssertionObserver) GetMachine() *vm.Machine + func (c WatchingAssertionObserver) OffchainAssert(mq *protocol.MessageQueue, timeBounds protocol.TimeBounds) (*validatorCore, *protocol.Assertion) + func (c WatchingAssertionObserver) SendMessageToVM(msg protocol.Message) + func (c WatchingAssertionObserver) ValidateAssertion(pre *protocol.Precondition, time uint64) bool
Go to main page