executor

Documentation

Overview

Package executor is the executor agent.

Index

• type ChainExecutor
• type Executor
  • func NewExecutor(config config.Config, executorDB db.ExecutorDB, ...) (*Executor, error)
  • func (e Executor) BuildTreeFromDB(ctx context.Context, chainID uint32, destination uint32) error
  • func (e Executor) GetRoot(ctx context.Context, nonce uint32, chainID uint32, destination uint32) ([32]byte, error)
  • func (e Executor) Listen(ctx context.Context, chainID uint32) error
  • func (e Executor) Start(ctx context.Context) error
  • func (e Executor) Stop(chainID uint32)

Types

type ChainExecutor

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

ChainExecutor is a struct that contains the necessary information for each chain level executor.

type Executor

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

Executor is the executor agent.

func NewExecutor

func NewExecutor(config config.Config, executorDB db.ExecutorDB, scribeClient client.ScribeClient) (*Executor, error)

NewExecutor creates a new executor agent.

func (Executor) BuildTreeFromDB

func (e Executor) BuildTreeFromDB(ctx context.Context, chainID uint32, destination uint32) error

BuildTreeFromDB builds the merkle tree from the database's messages. This function will reset the current merkle tree and replace it with the one built from the database. This function should also not be called while Start or Listen are running.

func (Executor) GetRoot

func (e Executor) GetRoot(ctx context.Context, nonce uint32, chainID uint32, destination uint32) ([32]byte, error)

GetRoot returns the merkle root at the given nonce.

func (Executor) Listen

func (e Executor) Listen(ctx context.Context, chainID uint32) error

Listen listens to the log channel and processes the logs. Requires Start to be called first.

func (Executor) Start

func (e Executor) Start(ctx context.Context) error

Start starts the executor agent. This uses gRPC to process the logs.

func (Executor) Stop

func (e Executor) Stop(chainID uint32)

Stop stops the executor agent.