execution

Documentation

Index

• Constants
• type Peer
  • func New(ctx context.Context, log logrus.FieldLogger, nodeRecord string, ...) (*Peer, error)
  • func (p *Peer) ExportTransactions(ctx context.Context, items []*TransactionHashItem) error
  • func (p *Peer) Start(ctx context.Context) (<-chan error, error)
  • func (p *Peer) Stop(ctx context.Context) error
  • func (p *Peer) Type() string
• type TransactionExporter
  • func NewTransactionExporter(log logrus.FieldLogger, ...) (TransactionExporter, error)
  • func (t TransactionExporter) ExportItems(ctx context.Context, items []*TransactionHashItem) error
  • func (t TransactionExporter) Shutdown(ctx context.Context) error
• type TransactionHashItem

Constants

const PeerType = "execution"

Types

type Peer

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

func New

func New(ctx context.Context, log logrus.FieldLogger, nodeRecord string, handlers *handler.Peer, captureDelay time.Duration, sharedCache *coordCache.SharedCache) (*Peer, error)

func (*Peer) ExportTransactions

func (p *Peer) ExportTransactions(ctx context.Context, items []*TransactionHashItem) error

func (*Peer) Start

func (p *Peer) Start(ctx context.Context) (<-chan error, error)

func (*Peer) Stop

func (p *Peer) Stop(ctx context.Context) error

func (*Peer) Type

func (p *Peer) Type() string

type TransactionExporter

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

func NewTransactionExporter

func NewTransactionExporter(log logrus.FieldLogger, handler func(ctx context.Context, items []*TransactionHashItem) error) (TransactionExporter, error)

func (TransactionExporter) ExportItems

func (t TransactionExporter) ExportItems(ctx context.Context, items []*TransactionHashItem) error

func (TransactionExporter) Shutdown

func (t TransactionExporter) Shutdown(ctx context.Context) error

type TransactionHashItem

type TransactionHashItem struct {
	Hash common.Hash
	Seen time.Time
}