message

Documentation

Index

• type GasOutputsProcessor
  • func NewGasOutputsProcessor(d *storage.Database, opener lens.APIOpener, leaseLength time.Duration, ...) *GasOutputsProcessor
  • func (p *GasOutputsProcessor) Run(ctx context.Context) error
• type MessageProcessor
  • func NewMessageProcessor(d *storage.Database, opener lens.APIOpener, leaseLength time.Duration, ...) *MessageProcessor
  • func (p *MessageProcessor) Run(ctx context.Context) error

Types

type GasOutputsProcessor

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

GasOutputsProcessor is a task that processes messages with receipts to determine gas outputs.

func NewGasOutputsProcessor

func NewGasOutputsProcessor(d *storage.Database, opener lens.APIOpener, leaseLength time.Duration, batchSize int, minHeight, maxHeight int64, useLeases bool) *GasOutputsProcessor

func (*GasOutputsProcessor) Run

func (p *GasOutputsProcessor) Run(ctx context.Context) error

Run starts processing batches of messages until the context is done or an error occurs.

type MessageProcessor

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

MessageProcessor is a task that processes blocks to detect messages and persists their details to the database.

func NewMessageProcessor

func NewMessageProcessor(d *storage.Database, opener lens.APIOpener, leaseLength time.Duration, batchSize int, parseMessages bool, minHeight, maxHeight int64) *MessageProcessor

func (*MessageProcessor) Run

func (p *MessageProcessor) Run(ctx context.Context) error

Run starts processing batches of tipsets and blocks until the context is done or an error occurs.