message

Documentation

Index

• func ParseMsg(m *types.Message, ts *types.TipSet, destCode string) (*messagemodel.ParsedMessage, error)
• 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

Functions

func ParseMsg

func ParseMsg(m *types.Message, ts *types.TipSet, destCode string) (*messagemodel.ParsedMessage, error)

ParseMsg extracts message parameters and encodes them as JSON by looking at the messages destination actor type.

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.