processor

Documentation

Index

• Constants
• type ActorTips
• type MinerSectorsEvent
• type PartitionStatus
• type Processor
  • func NewProcessor(ctx context.Context, db *sql.DB, node api.FullNode, batch int) *Processor
  • func (p *Processor) HandleCommonActorsChanges(ctx context.Context, actors map[cid.Cid]ActorTips) error
  • func (p *Processor) HandleMarketChanges(ctx context.Context, marketTips ActorTips) error
  • func (p *Processor) HandleMessageChanges(ctx context.Context, blocks map[cid.Cid]*types.BlockHeader) error
  • func (p *Processor) HandleMinerChanges(ctx context.Context, minerTips ActorTips) error
  • func (p *Processor) HandlePowerChanges(ctx context.Context, powerTips ActorTips) error
  • func (p *Processor) HandleRewardChanges(ctx context.Context, rewardTips ActorTips, nullRounds []types.TipSetKey) error
  • func (p *Processor) Start(ctx context.Context)
• type SectorDealEvent
• type SectorLifecycleEvent
• type UpdateAddresses

Constants

const (
	PreCommitAdded   = "PRECOMMIT_ADDED"
	PreCommitExpired = "PRECOMMIT_EXPIRED"

	CommitCapacityAdded = "COMMIT_CAPACITY_ADDED"

	SectorAdded      = "SECTOR_ADDED"
	SectorExpired    = "SECTOR_EXPIRED"
	SectorExtended   = "SECTOR_EXTENDED"
	SectorFaulted    = "SECTOR_FAULTED"
	SectorRecovering = "SECTOR_RECOVERING"
	SectorRecovered  = "SECTOR_RECOVERED"
	SectorTerminated = "SECTOR_TERMINATED"
)

Types

type ActorTips

type ActorTips map[types.TipSetKey][]actorInfo

type MinerSectorsEvent

type MinerSectorsEvent struct {
	MinerID   address.Address
	SectorIDs []uint64
	StateRoot cid.Cid
	Event     SectorLifecycleEvent
}

type PartitionStatus

type PartitionStatus struct {
	Terminated bitfield.BitField
	Expired    bitfield.BitField
	Faulted    bitfield.BitField
	InRecovery bitfield.BitField
	Recovered  bitfield.BitField
}

type Processor

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

func NewProcessor

func NewProcessor(ctx context.Context, db *sql.DB, node api.FullNode, batch int) *Processor

func (*Processor) HandleCommonActorsChanges

func (p *Processor) HandleCommonActorsChanges(ctx context.Context, actors map[cid.Cid]ActorTips) error

func (*Processor) HandleMarketChanges

func (p *Processor) HandleMarketChanges(ctx context.Context, marketTips ActorTips) error

func (*Processor) HandleMessageChanges

func (p *Processor) HandleMessageChanges(ctx context.Context, blocks map[cid.Cid]*types.BlockHeader) error

func (*Processor) HandleMinerChanges

func (p *Processor) HandleMinerChanges(ctx context.Context, minerTips ActorTips) error

func (*Processor) HandlePowerChanges

func (p *Processor) HandlePowerChanges(ctx context.Context, powerTips ActorTips) error

func (*Processor) HandleRewardChanges

func (p *Processor) HandleRewardChanges(ctx context.Context, rewardTips ActorTips, nullRounds []types.TipSetKey) error

func (*Processor) Start

func (p *Processor) Start(ctx context.Context)

type SectorDealEvent

type SectorDealEvent struct {
	MinerID  address.Address
	SectorID uint64
	DealIDs  []abi.DealID
}

type SectorLifecycleEvent

type SectorLifecycleEvent string

type UpdateAddresses

type UpdateAddresses struct {
	Old state.AddressPair
	New state.AddressPair
}