executor

Documentation

Overview

Package executor is the executor agent.

Index

• type Executor
  • func NewExecutor(chainIDs []uint32, addresses map[uint32]common.Address, ...) (*Executor, error)
  • func (e Executor) Start(ctx context.Context) error
  • func (e Executor) Stop(chainID uint32)

Types

type Executor

type Executor struct {

	// LogChans is a mapping from chain ID -> log channel.
	LogChans map[uint32]chan *types.Log
	// contains filtered or unexported fields
}

Executor is the executor agent.

func NewExecutor

func NewExecutor(chainIDs []uint32, addresses map[uint32]common.Address, scribeClient client.ScribeClient) (*Executor, error)

NewExecutor creates a new executor agent.

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.