executor

Documentation

Overview

Package executor is the executor agent.

Index

• type Executor
  • func NewExecutor(config config.Config, scribeClient client.ScribeClient) (*Executor, error)
  • func (e Executor) GetRoot(index uint64, 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 Executor

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

Executor is the executor agent.

func NewExecutor

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

NewExecutor creates a new executor agent.

func (Executor) GetRoot

func (e Executor) GetRoot(index uint64, chainID uint32, destination uint32) ([32]byte, error)

GetRoot returns the merkle root at the given index.

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.