mpoolmonitor

Documentation

Index

• type MpoolMonitor
  • func NewMonitor(fullNode v1api.FullNode, mpoolAlertEpochs int64) *MpoolMonitor
  • func (mm *MpoolMonitor) Alerts(ctx context.Context) ([]cid.Cid, error)
  • func (mm *MpoolMonitor) PendingAll() ([]*TimeStampedMsg, error)
  • func (mm *MpoolMonitor) PendingLocal(ctx context.Context) ([]*TimeStampedMsg, error)
  • func (mm *MpoolMonitor) Start(ctx context.Context) error
  • func (mm *MpoolMonitor) Stop(ctx context.Context) error
• type TimeStampedMsg

Types

type MpoolMonitor

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

func NewMonitor

func NewMonitor(fullNode v1api.FullNode, mpoolAlertEpochs int64) *MpoolMonitor

func (*MpoolMonitor) Alerts

func (mm *MpoolMonitor) Alerts(ctx context.Context) ([]cid.Cid, error)

func (*MpoolMonitor) PendingAll

func (mm *MpoolMonitor) PendingAll() ([]*TimeStampedMsg, error)

func (*MpoolMonitor) PendingLocal

func (mm *MpoolMonitor) PendingLocal(ctx context.Context) ([]*TimeStampedMsg, error)

func (*MpoolMonitor) Start

func (mm *MpoolMonitor) Start(ctx context.Context) error

func (*MpoolMonitor) Stop

func (mm *MpoolMonitor) Stop(ctx context.Context) error

type TimeStampedMsg

type TimeStampedMsg struct {
	SignedMessage types.SignedMessage
	Added         abi.ChainEpoch // Epoch when message was first noticed in mpool
	AddedTime     time.Time
}

TimeStampedMsg wraps the pending msg with a chainEpoch