ethereuminteraction

Documentation

Index

• Variables
• type DepositCheckoutProcessor
  • func NewDepositCheckoutProcessor(db *badger.DB, plasmaParent *ABI.PlasmaParent, ...) *DepositCheckoutProcessor
  • func (p *DepositCheckoutProcessor) Process(checkoutRequest *messageStructures.DepositIndexCheckoutRequest) (bool, error)
• type EthereumNetworkEventDispatcher
  • func NewEthereumNetworkEventDispatcher(connection, contractAddress string) *EthereumNetworkEventDispatcher
  • func (p *EthereumNetworkEventDispatcher) Run(fromBlockNumber int64, ...)
• type WithdrawChallengeProcessor
  • func NewWithdrawChallengeProcessor(plasmaParent *ABI.PlasmaParent, db *badger.DB) *WithdrawChallengeProcessor
  • func (p *WithdrawChallengeProcessor) Process(challengeRequest *messageStructures.WithdrawChallengeRequest) chan WithdrawChallengeResult
• type WithdrawChallengeResult
• type WithdrawStartedProcessor
  • func NewWithdrawStartedProcessor(db *badger.DB) *WithdrawStartedProcessor
  • func (p *WithdrawStartedProcessor) Process(event *messageStructures.WithdrawStartedInformation) (*messageStructures.WithdrawChallengeRequest, error)

Variables

var DepositIndexPrefix = []byte("deposit")

Types

type DepositCheckoutProcessor

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

func NewDepositCheckoutProcessor

func NewDepositCheckoutProcessor(db *badger.DB, plasmaParent *ABI.PlasmaParent, blockStorage *ABI.PlasmaBlockStorage) *DepositCheckoutProcessor

func (*DepositCheckoutProcessor) Process

func (p *DepositCheckoutProcessor) Process(checkoutRequest *messageStructures.DepositIndexCheckoutRequest) (bool, error)

type EthereumNetworkEventDispatcher

type EthereumNetworkEventDispatcher struct {
	ConnectionString     string
	Client               *ethclient.Client
	SignalChannel        chan int
	PlasmaParentContract *ABI.PlasmaParent
	BlockStorageContract *ABI.PlasmaBlockStorage
}

func NewEthereumNetworkEventDispatcher

func NewEthereumNetworkEventDispatcher(connection, contractAddress string) *EthereumNetworkEventDispatcher

func (*EthereumNetworkEventDispatcher) Run

func (p *EthereumNetworkEventDispatcher) Run(fromBlockNumber int64, blockProcessorLoopChannel chan<- *messageStructures.BlockInformation, withdrawProcessor *WithdrawStartedProcessor)

type WithdrawChallengeProcessor

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

func NewWithdrawChallengeProcessor

func NewWithdrawChallengeProcessor(plasmaParent *ABI.PlasmaParent, db *badger.DB) *WithdrawChallengeProcessor

func (*WithdrawChallengeProcessor) Process

func (p *WithdrawChallengeProcessor) Process(challengeRequest *messageStructures.WithdrawChallengeRequest) chan WithdrawChallengeResult

type WithdrawChallengeResult

type WithdrawChallengeResult struct {
	AlreadyChallenged bool
	Error             error
	ExitRecordHash    [22]byte
	ProofData         []byte
	TxData            []byte
	BlockNumber       uint32
	InputNumber       uint8
}

type WithdrawStartedProcessor

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

func NewWithdrawStartedProcessor

func NewWithdrawStartedProcessor(db *badger.DB) *WithdrawStartedProcessor

func (*WithdrawStartedProcessor) Process

func (p *WithdrawStartedProcessor) Process(event *messageStructures.WithdrawStartedInformation) (*messageStructures.WithdrawChallengeRequest, error)