inputter

Documentation

Index

• type InputterWorker
  • func (w *InputterWorker) ReadPastInputs(ctx context.Context, client *ethclient.Client, inputBox *contracts.InputBox, ...) error
  • func (w InputterWorker) Start(ctx context.Context, ready chan<- struct{}) error
  • func (w InputterWorker) String() string
• type Model

Types

type InputterWorker

type InputterWorker struct {
	Model              Model
	Provider           string
	InputBoxAddress    common.Address
	InputBoxBlock      uint64
	ApplicationAddress common.Address
	Repository         cRepos.InputRepository
}

This worker reads inputs from Ethereum and puts them in the model.

func (*InputterWorker) ReadPastInputs

func (w *InputterWorker) ReadPastInputs(
	ctx context.Context,
	client *ethclient.Client,
	inputBox *contracts.InputBox,
	startBlockNumber uint64,
	endBlockNumber *uint64,
) error

Read inputs starting from the input box deployment block until the latest block.

func (InputterWorker) Start

func (w InputterWorker) Start(ctx context.Context, ready chan<- struct{}) error

func (InputterWorker) String

func (w InputterWorker) String() string

type Model

type Model interface {
	AddAdvanceInput(
		sender common.Address,
		payload []byte,
		blockNumber uint64,
		timestamp time.Time,
		index int,
	) error
}