common

type Block ¶

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

type BlockTracker ¶

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

BlockTracker keeps a database record of the latest block that has been indexed for a contract address and allows the user to increase the value.

func NewBlockTracker(
	ctx context.Context,
	client blockchain.ChainClient,
	address common.Address,
	queries *queries.Queries,
	deploymentBlock uint64,
) (*BlockTracker, error)

func (bt *BlockTracker) GetLatestBlock() (uint64, []byte)

func (bt *BlockTracker) UpdateLatestBlock(
	ctx context.Context,
	block uint64,
	hashBytes []byte,
) error

type IBlockTracker ¶

type IBlockTracker interface {
	GetLatestBlock() (uint64, []byte)
	UpdateLatestBlock(ctx context.Context, block uint64, hash []byte) error
}

IBlockTracker tracks the latest block number and hash for a contract.

type IContract ¶

type IContract interface {
	IBlockTracker
	IReorgHandler
	ILogStorer
	Address() common.Address
	Topics() []common.Hash
	Logger() *zap.Logger
}

IContract is a contract that can be indexed.

type ILogStorer ¶

type ILogStorer interface {
	StoreLog(ctx context.Context, event types.Log) re.RetryableError
}

ILogStorer takes a log event and stores it, returning either an error that may be retriable, non-retriable, or nil.

type ILogStreamer ¶

type ILogStreamer interface {
	GetEventChannel(id string) <-chan types.Log
	Start() error
	Stop()
}

An ILogStreamer streams logs from a source through a channel.

type IReorgHandler ¶

type IReorgHandler interface {
	HandleLog(ctx context.Context, event types.Log) re.RetryableError
}

IReorgHandler handles reorgs.