validator

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDefendingValidator 

func NewDefendingValidator(core *validatorConfig, assDef protocol.AssertionDefender, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func NewValidatorConfig 

func NewValidatorConfig(address common.Address, config *valmessage.VMConfiguration, challengeEverything bool) *validatorConfig

Types

type AttemptingAssertDefender 

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

func (AttemptingAssertDefender) Clone 

func (c AttemptingAssertDefender) Clone() *validatorCore

func (AttemptingAssertDefender) DeliverMessagesToVM 

func (c AttemptingAssertDefender) DeliverMessagesToVM()

func (AttemptingAssertDefender) GeneratePrecondition 

func (c AttemptingAssertDefender) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (AttemptingAssertDefender) GetBalance 

func (c AttemptingAssertDefender) GetBalance() *protocol.BalanceTracker

func (AttemptingAssertDefender) GetConfig 

func (c AttemptingAssertDefender) GetConfig() *validatorConfig

func (AttemptingAssertDefender) GetCore 

func (c AttemptingAssertDefender) GetCore() *validatorCore

func (AttemptingAssertDefender) GetInbox 

func (c AttemptingAssertDefender) GetInbox() *protocol.Inbox

func (AttemptingAssertDefender) GetMachine 

func (c AttemptingAssertDefender) GetMachine() *vm.Machine

func (AttemptingAssertDefender) OffchainAssert 

func (c AttemptingAssertDefender) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (AttemptingAssertDefender) SendMessageToVM 

func (c AttemptingAssertDefender) SendMessageToVM(msg protocol.Message)

func (AttemptingAssertDefender) UpdateState 

func (bot AttemptingAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (AttemptingAssertDefender) UpdateTime 

func (bot AttemptingAssertDefender) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (AttemptingAssertDefender) ValidateAssertion 

func (c AttemptingAssertDefender) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type AttemptingOffchainClosing 

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

func (AttemptingOffchainClosing) Clone 

func (c AttemptingOffchainClosing) Clone() *validatorCore

func (AttemptingOffchainClosing) DeliverMessagesToVM 

func (c AttemptingOffchainClosing) DeliverMessagesToVM()

func (AttemptingOffchainClosing) GeneratePrecondition 

func (c AttemptingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (AttemptingOffchainClosing) GetBalance 

func (c AttemptingOffchainClosing) GetBalance() *protocol.BalanceTracker

func (AttemptingOffchainClosing) GetConfig 

func (c AttemptingOffchainClosing) GetConfig() *validatorConfig

func (AttemptingOffchainClosing) GetCore 

func (c AttemptingOffchainClosing) GetCore() *validatorCore

func (AttemptingOffchainClosing) GetInbox 

func (c AttemptingOffchainClosing) GetInbox() *protocol.Inbox

func (AttemptingOffchainClosing) GetMachine 

func (c AttemptingOffchainClosing) GetMachine() *vm.Machine

func (AttemptingOffchainClosing) OffchainAssert 

func (c AttemptingOffchainClosing) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (AttemptingOffchainClosing) SendMessageToVM 

func (c AttemptingOffchainClosing) SendMessageToVM(msg protocol.Message)

func (AttemptingOffchainClosing) UpdateState 

func (bot AttemptingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (AttemptingOffchainClosing) UpdateTime 

func (bot AttemptingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (AttemptingOffchainClosing) ValidateAssertion 

func (c AttemptingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type AttemptingUnanimousClosing 

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

func (AttemptingUnanimousClosing) Clone 

func (c AttemptingUnanimousClosing) Clone() *validatorCore

func (AttemptingUnanimousClosing) DeliverMessagesToVM 

func (c AttemptingUnanimousClosing) DeliverMessagesToVM()

func (AttemptingUnanimousClosing) GeneratePrecondition 

func (c AttemptingUnanimousClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (AttemptingUnanimousClosing) GetBalance 

func (c AttemptingUnanimousClosing) GetBalance() *protocol.BalanceTracker

func (AttemptingUnanimousClosing) GetConfig 

func (c AttemptingUnanimousClosing) GetConfig() *validatorConfig

func (AttemptingUnanimousClosing) GetCore 

func (c AttemptingUnanimousClosing) GetCore() *validatorCore

func (AttemptingUnanimousClosing) GetInbox 

func (c AttemptingUnanimousClosing) GetInbox() *protocol.Inbox

func (AttemptingUnanimousClosing) GetMachine 

func (c AttemptingUnanimousClosing) GetMachine() *vm.Machine

func (AttemptingUnanimousClosing) OffchainAssert 

func (c AttemptingUnanimousClosing) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (AttemptingUnanimousClosing) SendMessageToVM 

func (c AttemptingUnanimousClosing) SendMessageToVM(msg protocol.Message)

func (AttemptingUnanimousClosing) UpdateState 

func (bot AttemptingUnanimousClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (AttemptingUnanimousClosing) UpdateTime 

func (bot AttemptingUnanimousClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (AttemptingUnanimousClosing) ValidateAssertion 

func (c AttemptingUnanimousClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type BisectedAssertDefender 

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

func (BisectedAssertDefender) GetConfig 

func (c BisectedAssertDefender) GetConfig() *validatorConfig

func (BisectedAssertDefender) UpdateState 

func (bot BisectedAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (BisectedAssertDefender) UpdateTime 

func (bot BisectedAssertDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type ContinuingChallenger 

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

func (ContinuingChallenger) GetConfig 

func (c ContinuingChallenger) GetConfig() *validatorConfig

func (ContinuingChallenger) UpdateState 

func (bot ContinuingChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (ContinuingChallenger) UpdateTime 

func (bot ContinuingChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type Error 

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

func (*Error) Error 

func (e *Error) Error() string

type FinalizingAssertObserver 

type FinalizingAssertObserver struct {
	ResultChan chan<- bool
	// contains filtered or unexported fields
}

func (FinalizingAssertObserver) Clone 

func (c FinalizingAssertObserver) Clone() *validatorCore

func (FinalizingAssertObserver) DeliverMessagesToVM 

func (c FinalizingAssertObserver) DeliverMessagesToVM()

func (FinalizingAssertObserver) GeneratePrecondition 

func (c FinalizingAssertObserver) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (FinalizingAssertObserver) GetBalance 

func (c FinalizingAssertObserver) GetBalance() *protocol.BalanceTracker

func (FinalizingAssertObserver) GetConfig 

func (c FinalizingAssertObserver) GetConfig() *validatorConfig

func (FinalizingAssertObserver) GetCore 

func (c FinalizingAssertObserver) GetCore() *validatorCore

func (FinalizingAssertObserver) GetInbox 

func (c FinalizingAssertObserver) GetInbox() *protocol.Inbox

func (FinalizingAssertObserver) GetMachine 

func (c FinalizingAssertObserver) GetMachine() *vm.Machine

func (FinalizingAssertObserver) OffchainAssert 

func (c FinalizingAssertObserver) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (FinalizingAssertObserver) SendMessageToVM 

func (c FinalizingAssertObserver) SendMessageToVM(msg protocol.Message)

func (FinalizingAssertObserver) UpdateState 

func (bot FinalizingAssertObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (FinalizingAssertObserver) UpdateTime 

func (bot FinalizingAssertObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (FinalizingAssertObserver) ValidateAssertion 

func (c FinalizingAssertObserver) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type FinalizingOffchainClosing 

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

func (FinalizingOffchainClosing) Clone 

func (c FinalizingOffchainClosing) Clone() *validatorCore

func (FinalizingOffchainClosing) DeliverMessagesToVM 

func (c FinalizingOffchainClosing) DeliverMessagesToVM()

func (FinalizingOffchainClosing) GeneratePrecondition 

func (c FinalizingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (FinalizingOffchainClosing) GetBalance 

func (c FinalizingOffchainClosing) GetBalance() *protocol.BalanceTracker

func (FinalizingOffchainClosing) GetConfig 

func (c FinalizingOffchainClosing) GetConfig() *validatorConfig

func (FinalizingOffchainClosing) GetCore 

func (c FinalizingOffchainClosing) GetCore() *validatorCore

func (FinalizingOffchainClosing) GetInbox 

func (c FinalizingOffchainClosing) GetInbox() *protocol.Inbox

func (FinalizingOffchainClosing) GetMachine 

func (c FinalizingOffchainClosing) GetMachine() *vm.Machine

func (FinalizingOffchainClosing) OffchainAssert 

func (c FinalizingOffchainClosing) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (FinalizingOffchainClosing) SendMessageToVM 

func (c FinalizingOffchainClosing) SendMessageToVM(msg protocol.Message)

func (FinalizingOffchainClosing) UpdateState 

func (bot FinalizingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (FinalizingOffchainClosing) UpdateTime 

func (bot FinalizingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (FinalizingOffchainClosing) ValidateAssertion 

func (c FinalizingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type OneStepChallengedAssertDefender 

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

func (OneStepChallengedAssertDefender) GetConfig 

func (c OneStepChallengedAssertDefender) GetConfig() *validatorConfig

func (OneStepChallengedAssertDefender) UpdateState 

func (bot OneStepChallengedAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (OneStepChallengedAssertDefender) UpdateTime 

func (bot OneStepChallengedAssertDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type TimedOutAsserterChallenger 

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

func (TimedOutAsserterChallenger) GetConfig 

func (c TimedOutAsserterChallenger) GetConfig() *validatorConfig

func (TimedOutAsserterChallenger) UpdateState 

func (bot TimedOutAsserterChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (TimedOutAsserterChallenger) UpdateTime 

func (bot TimedOutAsserterChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type TimedOutAsserterDefender 

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

func (TimedOutAsserterDefender) GetConfig 

func (c TimedOutAsserterDefender) GetConfig() *validatorConfig

func (TimedOutAsserterDefender) UpdateState 

func (bot TimedOutAsserterDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (TimedOutAsserterDefender) UpdateTime 

func (bot TimedOutAsserterDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type TimedOutChallengerChallenger 

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

func (TimedOutChallengerChallenger) GetConfig 

func (c TimedOutChallengerChallenger) GetConfig() *validatorConfig

func (TimedOutChallengerChallenger) UpdateState 

func (bot TimedOutChallengerChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (TimedOutChallengerChallenger) UpdateTime 

func (bot TimedOutChallengerChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type TimedOutChallengerDefender 

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

func (TimedOutChallengerDefender) GetConfig 

func (c TimedOutChallengerDefender) GetConfig() *validatorConfig

func (TimedOutChallengerDefender) UpdateState 

func (bot TimedOutChallengerDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (TimedOutChallengerDefender) UpdateTime 

func (bot TimedOutChallengerDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type Validator 

type Validator struct {
	Name string
	// contains filtered or unexported fields
}

func NewValidator 

func NewValidator(name string, address common.Address, inbox *protocol.Inbox, balance *protocol.BalanceTracker, config *valmessage.VMConfiguration, machine *vm.Machine, challengeEverything bool) *Validator

func (*Validator) CloseUnanimousAssertionRequest 

func (validator *Validator) CloseUnanimousAssertionRequest() <-chan bool

func (*Validator) ConfirmOffchainUnanimousAssertion 

func (validator *Validator) ConfirmOffchainUnanimousAssertion(
	unanRequest valmessage.UnanimousRequestData,
	signatures []valmessage.Signature,
) (<-chan bool, <-chan error)

func (*Validator) HasPendingMessages 

func (validator *Validator) HasPendingMessages() chan bool

func (*Validator) InitiateUnanimousRequest 

func (validator *Validator) InitiateUnanimousRequest(
	length uint64,
	messages []protocol.Message,
	final bool,
) (
	<-chan valmessage.UnanimousRequest,
	<-chan valmessage.UnanimousUpdateResults,
	<-chan error,
)

func (*Validator) RequestCall 

func (validator *Validator) RequestCall(msg protocol.Message) (<-chan value.Value, <-chan error)

func (*Validator) RequestDisputableAssertion 

func (validator *Validator) RequestDisputableAssertion(length uint64, includePendingMessages bool) <-chan bool

func (*Validator) RequestFollowUnanimous 

func (validator *Validator) RequestFollowUnanimous(
	request valmessage.UnanimousRequestData,
	messages []protocol.Message,
) (<-chan valmessage.UnanimousUpdateResults, <-chan error)

func (*Validator) RequestVMState 

func (validator *Validator) RequestVMState() <-chan valmessage.VMStateData

func (*Validator) Run 

func (validator *Validator) Run(recvChan <-chan valmessage.IncomingValidatorMessage, sendChan chan<- valmessage.OutgoingMessage)

type WaitingAssertDefender 

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

func (WaitingAssertDefender) Clone 

func (c WaitingAssertDefender) Clone() *validatorCore

func (WaitingAssertDefender) DeliverMessagesToVM 

func (c WaitingAssertDefender) DeliverMessagesToVM()

func (WaitingAssertDefender) GeneratePrecondition 

func (c WaitingAssertDefender) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (WaitingAssertDefender) GetBalance 

func (c WaitingAssertDefender) GetBalance() *protocol.BalanceTracker

func (WaitingAssertDefender) GetConfig 

func (c WaitingAssertDefender) GetConfig() *validatorConfig

func (WaitingAssertDefender) GetCore 

func (c WaitingAssertDefender) GetCore() *validatorCore

func (WaitingAssertDefender) GetInbox 

func (c WaitingAssertDefender) GetInbox() *protocol.Inbox

func (WaitingAssertDefender) GetMachine 

func (c WaitingAssertDefender) GetMachine() *vm.Machine

func (WaitingAssertDefender) OffchainAssert 

func (c WaitingAssertDefender) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (WaitingAssertDefender) SendMessageToVM 

func (c WaitingAssertDefender) SendMessageToVM(msg protocol.Message)

func (WaitingAssertDefender) UpdateState 

func (bot WaitingAssertDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (WaitingAssertDefender) UpdateTime 

func (bot WaitingAssertDefender) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (WaitingAssertDefender) ValidateAssertion 

func (c WaitingAssertDefender) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type WaitingAsserterTimeoutObserver 

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

func (WaitingAsserterTimeoutObserver) GetConfig 

func (c WaitingAsserterTimeoutObserver) GetConfig() *validatorConfig

func (WaitingAsserterTimeoutObserver) UpdateState 

func (bot WaitingAsserterTimeoutObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingAsserterTimeoutObserver) UpdateTime 

func (bot WaitingAsserterTimeoutObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingBisectedDefender 

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

func (WaitingBisectedDefender) GetConfig 

func (c WaitingBisectedDefender) GetConfig() *validatorConfig

func (WaitingBisectedDefender) UpdateState 

func (bot WaitingBisectedDefender) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingBisectedDefender) UpdateTime 

func (bot WaitingBisectedDefender) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingBisectedObserver 

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

func (WaitingBisectedObserver) GetConfig 

func (c WaitingBisectedObserver) GetConfig() *validatorConfig

func (WaitingBisectedObserver) UpdateState 

func (bot WaitingBisectedObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingBisectedObserver) UpdateTime 

func (bot WaitingBisectedObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingChallengeObserver 

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

func (WaitingChallengeObserver) GetConfig 

func (c WaitingChallengeObserver) GetConfig() *validatorConfig

func (WaitingChallengeObserver) UpdateState 

func (bot WaitingChallengeObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingChallengeObserver) UpdateTime 

func (bot WaitingChallengeObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingChallengerTimeoutObserver 

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

func (WaitingChallengerTimeoutObserver) GetConfig 

func (c WaitingChallengerTimeoutObserver) GetConfig() *validatorConfig

func (WaitingChallengerTimeoutObserver) UpdateState 

func (bot WaitingChallengerTimeoutObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingChallengerTimeoutObserver) UpdateTime 

func (bot WaitingChallengerTimeoutObserver) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingContinuingChallenger 

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

func (WaitingContinuingChallenger) GetConfig 

func (c WaitingContinuingChallenger) GetConfig() *validatorConfig

func (WaitingContinuingChallenger) UpdateState 

func (bot WaitingContinuingChallenger) UpdateState(ev valmessage.IncomingMessage, time uint64) (challengeState, []valmessage.OutgoingMessage, error)

func (WaitingContinuingChallenger) UpdateTime 

func (bot WaitingContinuingChallenger) UpdateTime(time uint64) (challengeState, []valmessage.OutgoingMessage, error)

type WaitingObserver 

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

func NewWaitingObserver 

func NewWaitingObserver(config *validatorConfig, core *validatorCore) WaitingObserver

func (WaitingObserver) Clone 

func (bot WaitingObserver) Clone() WaitingObserver

func (WaitingObserver) CloseUnanimous 

func (bot WaitingObserver) CloseUnanimous(retChan chan<- bool) (validatorState, []valmessage.OutgoingMessage, error)

func (WaitingObserver) FastCloseUnanimous 

func (bot WaitingObserver) FastCloseUnanimous() valmessage.SendUnanimousAssertMessage

func (WaitingObserver) FinalizePendingUnanimous 

func (bot WaitingObserver) FinalizePendingUnanimous(signatures []valmessage.Signature) (validatorState, *proposedUpdate, error)

func (WaitingObserver) GetConfig 

func (c WaitingObserver) GetConfig() *validatorConfig

func (WaitingObserver) GetCore 

func (bot WaitingObserver) GetCore() *validatorCore

func (WaitingObserver) OffchainContext 

func (bot WaitingObserver) OffchainContext(
	newMessages []protocol.Message,
	timeBounds protocol.TimeBounds,
	final bool,
) (*protocol.MessageQueue, protocol.TimeBounds, uint64)

func (WaitingObserver) OrigInbox 

func (bot WaitingObserver) OrigInbox() *protocol.Inbox

func (WaitingObserver) PreparePendingUnanimous 

func (bot WaitingObserver) PreparePendingUnanimous(request valmessage.UnanimousUpdateRequest) (WaitingObserver, error)

func (WaitingObserver) ProposalResults 

func (bot WaitingObserver) ProposalResults() valmessage.UnanimousUpdateResults

func (WaitingObserver) ProposedInbox 

func (bot WaitingObserver) ProposedInbox() *protocol.Inbox

func (WaitingObserver) SendMessageToVM 

func (bot WaitingObserver) SendMessageToVM(msg protocol.Message)

func (WaitingObserver) SlowCloseUnanimous 

func (bot WaitingObserver) SlowCloseUnanimous() valmessage.SendProposeUnanimousAssertMessage

func (WaitingObserver) UpdateState 

func (bot WaitingObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (WaitingObserver) UpdateTime 

func (bot WaitingObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

type WaitingOffchainClosing 

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

func (WaitingOffchainClosing) Clone 

func (c WaitingOffchainClosing) Clone() *validatorCore

func (WaitingOffchainClosing) DeliverMessagesToVM 

func (c WaitingOffchainClosing) DeliverMessagesToVM()

func (WaitingOffchainClosing) GeneratePrecondition 

func (c WaitingOffchainClosing) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (WaitingOffchainClosing) GetBalance 

func (c WaitingOffchainClosing) GetBalance() *protocol.BalanceTracker

func (WaitingOffchainClosing) GetConfig 

func (c WaitingOffchainClosing) GetConfig() *validatorConfig

func (WaitingOffchainClosing) GetCore 

func (c WaitingOffchainClosing) GetCore() *validatorCore

func (WaitingOffchainClosing) GetInbox 

func (c WaitingOffchainClosing) GetInbox() *protocol.Inbox

func (WaitingOffchainClosing) GetMachine 

func (c WaitingOffchainClosing) GetMachine() *vm.Machine

func (WaitingOffchainClosing) OffchainAssert 

func (c WaitingOffchainClosing) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (WaitingOffchainClosing) SendMessageToVM 

func (c WaitingOffchainClosing) SendMessageToVM(msg protocol.Message)

func (WaitingOffchainClosing) UpdateState 

func (bot WaitingOffchainClosing) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (WaitingOffchainClosing) UpdateTime 

func (bot WaitingOffchainClosing) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (WaitingOffchainClosing) ValidateAssertion 

func (c WaitingOffchainClosing) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

type WatchingAssertionObserver 

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

func (WatchingAssertionObserver) Clone 

func (c WatchingAssertionObserver) Clone() *validatorCore

func (WatchingAssertionObserver) DeliverMessagesToVM 

func (c WatchingAssertionObserver) DeliverMessagesToVM()

func (WatchingAssertionObserver) GeneratePrecondition 

func (c WatchingAssertionObserver) GeneratePrecondition(beginTime, endTime uint64, includePendingMessages bool) *protocol.Precondition

func (WatchingAssertionObserver) GetBalance 

func (c WatchingAssertionObserver) GetBalance() *protocol.BalanceTracker

func (WatchingAssertionObserver) GetConfig 

func (c WatchingAssertionObserver) GetConfig() *validatorConfig

func (WatchingAssertionObserver) GetCore 

func (c WatchingAssertionObserver) GetCore() *validatorCore

func (WatchingAssertionObserver) GetInbox 

func (c WatchingAssertionObserver) GetInbox() *protocol.Inbox

func (WatchingAssertionObserver) GetMachine 

func (c WatchingAssertionObserver) GetMachine() *vm.Machine

func (WatchingAssertionObserver) OffchainAssert 

func (c WatchingAssertionObserver) OffchainAssert(
	mq *protocol.MessageQueue,
	timeBounds protocol.TimeBounds,
) (*validatorCore, *protocol.Assertion)

func (WatchingAssertionObserver) SendMessageToVM 

func (c WatchingAssertionObserver) SendMessageToVM(msg protocol.Message)

func (WatchingAssertionObserver) UpdateState 

func (bot WatchingAssertionObserver) UpdateState(ev valmessage.IncomingMessage, time uint64) (validatorState, challengeState, []valmessage.OutgoingMessage, error)

func (WatchingAssertionObserver) UpdateTime 

func (bot WatchingAssertionObserver) UpdateTime(time uint64) (validatorState, []valmessage.OutgoingMessage, error)

func (WatchingAssertionObserver) ValidateAssertion 

func (c WatchingAssertionObserver) ValidateAssertion(pre *protocol.Precondition, time uint64) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.