processor

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 15, 2021 License: Apache-2.0, MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source
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"
)

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL