lily

package
v0.17.6 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2024 License: Apache-2.0, MIT Imports: 46 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FullBlock added in v0.12.0 

type FullBlock struct {
	Header       *types.BlockHeader
	BlsMessages  []*types.Message
	SecpMessages []*types.SignedMessage
}

type FullTipSet added in v0.12.0 

type FullTipSet struct {
	Blocks []*FullBlock
	TipSet *types.TipSet

	HasMessages bool
	HasState    bool
	HasReceipts bool
}

func TryLoadFullTipSet added in v0.12.0 

func TryLoadFullTipSet(ctx context.Context, m *LilyNodeAPI, ts *types.TipSet) *FullTipSet

type LilyAPI 

type LilyAPI interface {
	AuthVerify(ctx context.Context, token string) ([]auth.Permission, error)

	LilyIndex(ctx context.Context, cfg *LilyIndexConfig) (interface{}, error)
	LilyWatch(ctx context.Context, cfg *LilyWatchConfig) (*schedule.JobSubmitResult, error)
	LilyWalk(ctx context.Context, cfg *LilyWalkConfig) (*schedule.JobSubmitResult, error)
	LilySurvey(ctx context.Context, cfg *LilySurveyConfig) (*schedule.JobSubmitResult, error)

	LilyIndexNotify(ctx context.Context, cfg *LilyIndexNotifyConfig) (interface{}, error)
	LilyWatchNotify(ctx context.Context, cfg *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)
	LilyWalkNotify(ctx context.Context, cfg *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)

	LilyJobStart(ctx context.Context, ID schedule.JobID) error
	LilyJobStop(ctx context.Context, ID schedule.JobID) error
	LilyJobWait(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error)
	LilyJobList(ctx context.Context) ([]schedule.JobListResult, error)

	LilyGapFind(ctx context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error)
	LilyGapFill(ctx context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error)
	LilyGapFillNotify(ctx context.Context, cfg *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error)

	// SyncState returns the current status of the chain sync system.
	SyncState(context.Context) (*api.SyncState, error) //perm:read

	ChainHead(context.Context) (*types.TipSet, error)                                                            //perm:read
	ChainGetBlock(context.Context, cid.Cid) (*types.BlockHeader, error)                                          //perm:read
	ChainReadObj(context.Context, cid.Cid) ([]byte, error)                                                       //perm:read
	ChainStatObj(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error)                                         //perm:read
	ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)                                      //perm:read
	ChainGetTipSetByHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)              //perm:read
	ChainGetTipSetAfterHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)           //perm:read
	ChainGetBlockMessages(context.Context, cid.Cid) (*api.BlockMessages, error)                                  //perm:read
	ChainGetParentReceipts(context.Context, cid.Cid) ([]*types.MessageReceipt, error)                            //perm:read
	ChainGetParentMessages(context.Context, cid.Cid) ([]api.Message, error)                                      //perm:read
	ChainSetHead(context.Context, types.TipSetKey) error                                                         //perm:read
	ChainGetGenesis(context.Context) (*types.TipSet, error)                                                      //perm:read
	ChainPrune(ctx context.Context, opts api.PruneOpts) error                                                    //perm:read
	ChainHotGC(ctx context.Context, opts api.HotGCOpts) error                                                    //perm:read
	EthGetBlockByHash(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error) //perm:read
	EthGetTransactionReceipt(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)            //perm:read
	ChainGetMessagesInTipset(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)                    //perm:read
	EthGetTransactionByHash(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)              //perm:read
	StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                         //perm:read

	// SyncIncomingBlocks returns a channel streaming incoming, potentially not
	// yet synced block headers.
	SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error) //perm:read

	// trigger graceful shutdown
	Shutdown(context.Context) error

	// LogList returns a list of loggers
	LogList(context.Context) ([]string, error)                       //perm:write
	LogSetLevel(context.Context, string, string) error               //perm:write
	LogSetLevelRegex(ctx context.Context, regex, level string) error //perm:write

	// ID returns peerID of libp2p node backing this API
	ID(context.Context) (peer.ID, error) //perm:read
	NetAutoNatStatus(ctx context.Context) (i api.NatInfo, err error)
	NetPeers(context.Context) ([]peer.AddrInfo, error)
	NetAddrsListen(context.Context) (peer.AddrInfo, error)
	NetPubsubScores(context.Context) ([]api.PubsubScore, error)
	NetAgentVersion(ctx context.Context, p peer.ID) (string, error)
	NetPeerInfo(context.Context, peer.ID) (*api.ExtendedPeerInfo, error)
	NetConnect(context.Context, peer.AddrInfo) error
	NetDisconnect(context.Context, peer.ID) error

	StartTipSetWorker(ctx context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error)

	FindOldestState(ctx context.Context, limit int64) ([]*StateReport, error)
	StateCompute(ctx context.Context, tsk types.TipSetKey) (interface{}, error)
}

type LilyAPIStruct 

type LilyAPIStruct struct {
	// authentication
	// TODO: avoid importing CommonStruct, split out into separate lily structs
	v0api.CommonStruct

	Internal struct {
		Store func() adt.Store `perm:"read"`

		LilyIndex  func(ctx context.Context, config *LilyIndexConfig) (interface{}, error)     `perm:"read"`
		LilyWatch  func(context.Context, *LilyWatchConfig) (*schedule.JobSubmitResult, error)  `perm:"read"`
		LilyWalk   func(context.Context, *LilyWalkConfig) (*schedule.JobSubmitResult, error)   `perm:"read"`
		LilySurvey func(context.Context, *LilySurveyConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		LilyIndexNotify   func(ctx context.Context, config *LilyIndexNotifyConfig) (interface{}, error)                 `perm:"read"`
		LilyWatchNotify   func(ctx context.Context, config *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)   `perm:"read"`
		LilyWalkNotify    func(ctx context.Context, config *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)    `perm:"read"`
		LilyGapFillNotify func(ctx context.Context, config *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		LilyJobStart func(ctx context.Context, ID schedule.JobID) error                            `perm:"read"`
		LilyJobStop  func(ctx context.Context, ID schedule.JobID) error                            `perm:"read"`
		LilyJobWait  func(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error) `perm:"read"`
		LilyJobList  func(ctx context.Context) ([]schedule.JobListResult, error)                   `perm:"read"`

		LilyGapFind func(ctx context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error) `perm:"read"`
		LilyGapFill func(ctx context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		Shutdown func(context.Context) error `perm:"read"`

		SyncState func(ctx context.Context) (*api.SyncState, error) `perm:"read"`

		ChainHead                 func(context.Context) (*types.TipSet, error)                                                    `perm:"read"`
		ChainGetBlock             func(context.Context, cid.Cid) (*types.BlockHeader, error)                                      `perm:"read"`
		ChainReadObj              func(context.Context, cid.Cid) ([]byte, error)                                                  `perm:"read"`
		ChainStatObj              func(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error)                                    `perm:"read"`
		ChainGetTipSet            func(context.Context, types.TipSetKey) (*types.TipSet, error)                                   `perm:"read"`
		ChainGetTipSetByHeight    func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)                   `perm:"read"`
		ChainGetBlockMessages     func(context.Context, cid.Cid) (*api.BlockMessages, error)                                      `perm:"read"`
		ChainGetParentReceipts    func(context.Context, cid.Cid) ([]*types.MessageReceipt, error)                                 `perm:"read"`
		ChainGetParentMessages    func(context.Context, cid.Cid) ([]api.Message, error)                                           `perm:"read"`
		ChainGetTipSetAfterHeight func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)                   `perm:"read"`
		ChainSetHead              func(context.Context, types.TipSetKey) error                                                    `perm:"read"`
		ChainGetGenesis           func(context.Context) (*types.TipSet, error)                                                    `perm:"read"`
		ChainPrune                func(ctx context.Context, opts api.PruneOpts) error                                             `perm:"read"`
		ChainHotGC                func(ctx context.Context, opts api.HotGCOpts) error                                             `perm:"read"`
		EthGetBlockByHash         func(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error) `perm:"read"`
		EthGetTransactionReceipt  func(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)                   `perm:"read"`
		ChainGetMessagesInTipset  func(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)                           `perm:"read"`
		EthGetTransactionByHash   func(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)                    `perm:"read"`
		StateListActors           func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                       `perm:"read"`

		// SyncIncomingBlocks returns a channel streaming incoming, potentially not
		// yet synced block headers.
		SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`

		LogList          func(context.Context) ([]string, error)     `perm:"read"`
		LogSetLevel      func(context.Context, string, string) error `perm:"read"`
		LogSetLevelRegex func(context.Context, string, string) error `perm:"read"`

		ID               func(context.Context) (peer.ID, error)                        `perm:"read"`
		NetAutoNatStatus func(context.Context) (api.NatInfo, error)                    `perm:"read"`
		NetPeers         func(context.Context) ([]peer.AddrInfo, error)                `perm:"read"`
		NetAddrsListen   func(context.Context) (peer.AddrInfo, error)                  `perm:"read"`
		NetPubsubScores  func(context.Context) ([]api.PubsubScore, error)              `perm:"read"`
		NetAgentVersion  func(context.Context, peer.ID) (string, error)                `perm:"read"`
		NetPeerInfo      func(context.Context, peer.ID) (*api.ExtendedPeerInfo, error) `perm:"read"`
		NetConnect       func(context.Context, peer.AddrInfo) error                    `perm:"read"`
		NetDisconnect    func(context.Context, peer.ID) error                          `perm:"read"`

		StartTipSetWorker func(ctx context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		FindOldestState func(ctx context.Context, limit int64) ([]*StateReport, error)      `perm:"read"`
		StateCompute    func(ctx context.Context, tsk types.TipSetKey) (interface{}, error) `perm:"read"`
	}
}

func (*LilyAPIStruct) ChainGetBlock 

func (s *LilyAPIStruct) ChainGetBlock(ctx context.Context, c cid.Cid) (*types.BlockHeader, error)

func (*LilyAPIStruct) ChainGetBlockMessages 

func (s *LilyAPIStruct) ChainGetBlockMessages(ctx context.Context, blockCid cid.Cid) (*api.BlockMessages, error)

func (*LilyAPIStruct) ChainGetGenesis added in v0.8.2 

func (s *LilyAPIStruct) ChainGetGenesis(ctx context.Context) (*types.TipSet, error)

func (*LilyAPIStruct) ChainGetMessagesInTipset added in v0.17.0 

func (s *LilyAPIStruct) ChainGetMessagesInTipset(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)

func (*LilyAPIStruct) ChainGetParentMessages 

func (s *LilyAPIStruct) ChainGetParentMessages(ctx context.Context, blockCid cid.Cid) ([]api.Message, error)

func (*LilyAPIStruct) ChainGetParentReceipts 

func (s *LilyAPIStruct) ChainGetParentReceipts(ctx context.Context, blockCid cid.Cid) ([]*types.MessageReceipt, error)

func (*LilyAPIStruct) ChainGetTipSet 

func (s *LilyAPIStruct) ChainGetTipSet(ctx context.Context, key types.TipSetKey) (*types.TipSet, error)

func (*LilyAPIStruct) ChainGetTipSetAfterHeight 

func (s *LilyAPIStruct) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)

func (*LilyAPIStruct) ChainGetTipSetByHeight 

func (s *LilyAPIStruct) ChainGetTipSetByHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)

func (*LilyAPIStruct) ChainHead 

func (s *LilyAPIStruct) ChainHead(ctx context.Context) (*types.TipSet, error)

func (*LilyAPIStruct) ChainHotGC added in v0.16.0 

func (s *LilyAPIStruct) ChainHotGC(ctx context.Context, opts api.HotGCOpts) error

func (*LilyAPIStruct) ChainPrune added in v0.16.0 

func (s *LilyAPIStruct) ChainPrune(ctx context.Context, opts api.PruneOpts) error

func (*LilyAPIStruct) ChainReadObj 

func (s *LilyAPIStruct) ChainReadObj(ctx context.Context, c cid.Cid) ([]byte, error)

func (*LilyAPIStruct) ChainSetHead added in v0.8.2 

func (s *LilyAPIStruct) ChainSetHead(ctx context.Context, key types.TipSetKey) error

func (*LilyAPIStruct) ChainStatObj 

func (s *LilyAPIStruct) ChainStatObj(ctx context.Context, c cid.Cid, c2 cid.Cid) (api.ObjStat, error)

func (*LilyAPIStruct) EthGetBlockByHash added in v0.17.0 

func (s *LilyAPIStruct) EthGetBlockByHash(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error)

func (*LilyAPIStruct) EthGetTransactionByHash added in v0.17.0 

func (s *LilyAPIStruct) EthGetTransactionByHash(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)

func (*LilyAPIStruct) EthGetTransactionReceipt added in v0.17.0 

func (s *LilyAPIStruct) EthGetTransactionReceipt(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)

func (*LilyAPIStruct) FindOldestState added in v0.12.0 

func (s *LilyAPIStruct) FindOldestState(ctx context.Context, limit int64) ([]*StateReport, error)

func (*LilyAPIStruct) ID 

func (s *LilyAPIStruct) ID(ctx context.Context) (peer.ID, error)

func (*LilyAPIStruct) LilyGapFill 

func (s *LilyAPIStruct) LilyGapFill(ctx context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyGapFillNotify added in v0.10.0 

func (s *LilyAPIStruct) LilyGapFillNotify(ctx context.Context, cfg *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyGapFind 

func (s *LilyAPIStruct) LilyGapFind(ctx context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyIndex added in v0.9.0 

func (s *LilyAPIStruct) LilyIndex(ctx context.Context, cfg *LilyIndexConfig) (interface{}, error)

func (*LilyAPIStruct) LilyIndexNotify added in v0.10.0 

func (s *LilyAPIStruct) LilyIndexNotify(ctx context.Context, cfg *LilyIndexNotifyConfig) (interface{}, error)

func (*LilyAPIStruct) LilyJobList 

func (s *LilyAPIStruct) LilyJobList(ctx context.Context) ([]schedule.JobListResult, error)

func (*LilyAPIStruct) LilyJobStart 

func (s *LilyAPIStruct) LilyJobStart(ctx context.Context, ID schedule.JobID) error

func (*LilyAPIStruct) LilyJobStop 

func (s *LilyAPIStruct) LilyJobStop(ctx context.Context, ID schedule.JobID) error

func (*LilyAPIStruct) LilyJobWait added in v0.8.6 

func (s *LilyAPIStruct) LilyJobWait(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error)

func (*LilyAPIStruct) LilySurvey added in v0.8.2 

func (s *LilyAPIStruct) LilySurvey(ctx context.Context, cfg *LilySurveyConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyWalk 

func (s *LilyAPIStruct) LilyWalk(ctx context.Context, cfg *LilyWalkConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyWalkNotify added in v0.10.0 

func (s *LilyAPIStruct) LilyWalkNotify(ctx context.Context, cfg *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyWatch 

func (s *LilyAPIStruct) LilyWatch(ctx context.Context, cfg *LilyWatchConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LilyWatchNotify added in v0.10.0 

func (s *LilyAPIStruct) LilyWatchNotify(ctx context.Context, cfg *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) LogList 

func (s *LilyAPIStruct) LogList(ctx context.Context) ([]string, error)

func (*LilyAPIStruct) LogSetLevel 

func (s *LilyAPIStruct) LogSetLevel(ctx context.Context, subsystem, level string) error

func (*LilyAPIStruct) LogSetLevelRegex added in v0.8.6 

func (s *LilyAPIStruct) LogSetLevelRegex(ctx context.Context, regex, level string) error

func (*LilyAPIStruct) NetAddrsListen 

func (s *LilyAPIStruct) NetAddrsListen(ctx context.Context) (peer.AddrInfo, error)

func (*LilyAPIStruct) NetAgentVersion 

func (s *LilyAPIStruct) NetAgentVersion(ctx context.Context, p peer.ID) (string, error)

func (*LilyAPIStruct) NetAutoNatStatus 

func (s *LilyAPIStruct) NetAutoNatStatus(ctx context.Context) (api.NatInfo, error)

func (*LilyAPIStruct) NetConnect added in v0.14.0 

func (s *LilyAPIStruct) NetConnect(ctx context.Context, p peer.AddrInfo) error

func (*LilyAPIStruct) NetDisconnect added in v0.14.0 

func (s *LilyAPIStruct) NetDisconnect(ctx context.Context, id peer.ID) error

func (*LilyAPIStruct) NetPeerInfo 

func (s *LilyAPIStruct) NetPeerInfo(ctx context.Context, p peer.ID) (*api.ExtendedPeerInfo, error)

func (*LilyAPIStruct) NetPeers 

func (s *LilyAPIStruct) NetPeers(ctx context.Context) ([]peer.AddrInfo, error)

func (*LilyAPIStruct) NetPubsubScores 

func (s *LilyAPIStruct) NetPubsubScores(ctx context.Context) ([]api.PubsubScore, error)

func (*LilyAPIStruct) Shutdown 

func (s *LilyAPIStruct) Shutdown(ctx context.Context) error

func (*LilyAPIStruct) StartTipSetWorker added in v0.10.0 

func (s *LilyAPIStruct) StartTipSetWorker(ctx context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error)

func (*LilyAPIStruct) StateCompute added in v0.12.0 

func (s *LilyAPIStruct) StateCompute(ctx context.Context, tsk types.TipSetKey) (interface{}, error)

func (*LilyAPIStruct) StateListActors added in v0.17.1 

func (s *LilyAPIStruct) StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (*LilyAPIStruct) Store 

func (s *LilyAPIStruct) Store() adt.Store

func (*LilyAPIStruct) SyncIncomingBlocks added in v0.17.2 

func (s *LilyAPIStruct) SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error)

func (*LilyAPIStruct) SyncState 

func (s *LilyAPIStruct) SyncState(ctx context.Context) (*api.SyncState, error)

type LilyGapFillConfig 

type LilyGapFillConfig struct {
	JobConfig LilyJobConfig

	To   int64
	From int64
}

type LilyGapFillNotifyConfig added in v0.10.0 

type LilyGapFillNotifyConfig struct {
	GapFillConfig LilyGapFillConfig

	Queue string
}

type LilyGapFindConfig 

type LilyGapFindConfig struct {
	JobConfig LilyJobConfig

	To   int64
	From int64
}

type LilyIndexConfig added in v0.9.0 

type LilyIndexConfig struct {
	JobConfig LilyJobConfig

	TipSet types.TipSetKey
}

type LilyIndexNotifyConfig added in v0.10.0 

type LilyIndexNotifyConfig struct {
	IndexConfig LilyIndexConfig

	Queue string
}

type LilyJobConfig added in v0.10.0 

type LilyJobConfig struct {
	// Name is the name of the job.
	Name string
	// Tasks are executed by the job.
	Tasks []string
	// Window after which if an execution of the job is not complete it will be canceled.
	Window time.Duration
	// RestartOnFailure when true will restart the job if it encounters an error.
	RestartOnFailure bool
	// RestartOnCompletion when true will restart the job when it completes.
	RestartOnCompletion bool
	// RestartOnCompletion when true will restart the job when it completes.
	StopOnError bool
	// RestartDelay configures how long to wait before restarting the job.
	RestartDelay time.Duration
	// Storage is the name of the storage system the job will use, may be empty.
	Storage string
}

type LilyNodeAPI 

type LilyNodeAPI struct {
	fx.In `ignore-unexported:"true"`

	net.NetAPI
	full.ChainAPI
	full.StateAPI
	full.SyncAPI
	full.EthModuleAPI
	common.CommonAPI
	Events    *events.Events
	Scheduler *schedule.Scheduler

	ExecMonitor stmgr.ExecMonitor
	CacheConfig *util.CacheConfig

	StorageCatalog *storage.Catalog
	QueueCatalog   *distributed.Catalog
	// contains filtered or unexported fields
}

func (*LilyNodeAPI) BurnFundsFn added in v0.12.0 

func (m *LilyNodeAPI) BurnFundsFn(ctx context.Context, ts *types.TipSet) (lens.ShouldBurnFn, error)

func (*LilyNodeAPI) ChainGetMessagesInTipset added in v0.17.0 

func (m *LilyNodeAPI) ChainGetMessagesInTipset(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)

func (*LilyNodeAPI) ChainGetTipSetAfterHeight 

func (m *LilyNodeAPI) ChainGetTipSetAfterHeight(ctx context.Context, epoch abi.ChainEpoch, key types.TipSetKey) (*types.TipSet, error)

func (*LilyNodeAPI) CirculatingSupply added in v0.9.0 

func (m *LilyNodeAPI) CirculatingSupply(ctx context.Context, key types.TipSetKey) (api.CirculatingSupply, error)

func (*LilyNodeAPI) ComputeBaseFee added in v0.12.0 

func (m *LilyNodeAPI) ComputeBaseFee(ctx context.Context, ts *types.TipSet) (abi.TokenAmount, error)

ComputeBaseFee calculates the base-fee of the specified tipset.

func (*LilyNodeAPI) EthGetBlockByHash added in v0.17.0 

func (m *LilyNodeAPI) EthGetBlockByHash(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error)

func (*LilyNodeAPI) EthGetTransactionByHash added in v0.17.0 

func (m *LilyNodeAPI) EthGetTransactionByHash(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)

func (*LilyNodeAPI) EthGetTransactionReceipt added in v0.17.0 

func (m *LilyNodeAPI) EthGetTransactionReceipt(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)

func (*LilyNodeAPI) FindOldestState added in v0.12.0 

func (m *LilyNodeAPI) FindOldestState(ctx context.Context, limit int64) ([]*StateReport, error)

func (*LilyNodeAPI) GetMessageExecutionsForTipSet 

func (m *LilyNodeAPI) GetMessageExecutionsForTipSet(ctx context.Context, next *types.TipSet, current *types.TipSet) ([]*lens.MessageExecution, error)

func (*LilyNodeAPI) Host added in v0.12.0 

func (m *LilyNodeAPI) Host() host.Host

func (*LilyNodeAPI) LilyGapFill 

func (m *LilyNodeAPI) LilyGapFill(_ context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyGapFillNotify added in v0.10.0 

func (m *LilyNodeAPI) LilyGapFillNotify(_ context.Context, cfg *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyGapFind 

func (m *LilyNodeAPI) LilyGapFind(_ context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyIndex added in v0.9.0 

func (m *LilyNodeAPI) LilyIndex(_ context.Context, cfg *LilyIndexConfig) (interface{}, error)

func (*LilyNodeAPI) LilyIndexNotify added in v0.10.0 

func (m *LilyNodeAPI) LilyIndexNotify(_ context.Context, cfg *LilyIndexNotifyConfig) (interface{}, error)

func (*LilyNodeAPI) LilyJobList 

func (m *LilyNodeAPI) LilyJobList(_ context.Context) ([]schedule.JobListResult, error)

func (*LilyNodeAPI) LilyJobStart 

func (m *LilyNodeAPI) LilyJobStart(_ context.Context, ID schedule.JobID) error

func (*LilyNodeAPI) LilyJobStop 

func (m *LilyNodeAPI) LilyJobStop(_ context.Context, ID schedule.JobID) error

func (*LilyNodeAPI) LilyJobWait added in v0.8.6 

func (m *LilyNodeAPI) LilyJobWait(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error)

func (*LilyNodeAPI) LilySurvey added in v0.8.2 

func (m *LilyNodeAPI) LilySurvey(_ context.Context, cfg *LilySurveyConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyWalk 

func (m *LilyNodeAPI) LilyWalk(_ context.Context, cfg *LilyWalkConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyWalkNotify added in v0.10.0 

func (m *LilyNodeAPI) LilyWalkNotify(_ context.Context, cfg *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyWatch 

func (m *LilyNodeAPI) LilyWatch(_ context.Context, cfg *LilyWatchConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LilyWatchNotify added in v0.10.0 

func (m *LilyNodeAPI) LilyWatchNotify(_ context.Context, cfg *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) LogList 

func (m *LilyNodeAPI) LogList(_ context.Context) ([]string, error)

func (*LilyNodeAPI) LogSetLevel 

func (m *LilyNodeAPI) LogSetLevel(_ context.Context, subsystem, level string) error

func (*LilyNodeAPI) LogSetLevelRegex added in v0.8.6 

func (m *LilyNodeAPI) LogSetLevelRegex(_ context.Context, regex, level string) error

func (*LilyNodeAPI) MessagesForTipSetBlocks added in v0.12.0 

func (m *LilyNodeAPI) MessagesForTipSetBlocks(ctx context.Context, ts *types.TipSet) ([]*lens.BlockMessages, error)

MessagesForTipSetBlocks returns messages stored in the blocks of the specified tipset, messages may be duplicated across the returned set of BlockMessages.

func (*LilyNodeAPI) MessagesWithDeduplicationForTipSet added in v0.17.2 

func (m *LilyNodeAPI) MessagesWithDeduplicationForTipSet(ctx context.Context, ts *types.TipSet) (map[cid.Cid]types.ChainMsg, error)

func (*LilyNodeAPI) Shutdown 

func (m *LilyNodeAPI) Shutdown(_ context.Context) error

func (*LilyNodeAPI) StartTipSetWorker added in v0.10.0 

func (m *LilyNodeAPI) StartTipSetWorker(_ context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error)

func (*LilyNodeAPI) StateCompute added in v0.12.0 

func (m *LilyNodeAPI) StateCompute(ctx context.Context, key types.TipSetKey) (interface{}, error)

func (*LilyNodeAPI) StateGetReceipt 

func (m *LilyNodeAPI) StateGetReceipt(ctx context.Context, msg cid.Cid, from types.TipSetKey) (*types.MessageReceipt, error)

func (*LilyNodeAPI) StateListActors added in v0.17.1 

func (m *LilyNodeAPI) StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)

func (*LilyNodeAPI) Store 

func (m *LilyNodeAPI) Store() adt.Store

func (*LilyNodeAPI) TipSetMessageReceipts added in v0.12.0 

func (m *LilyNodeAPI) TipSetMessageReceipts(ctx context.Context, ts, pts *types.TipSet) ([]*lens.BlockMessageReceipts, error)

TipSetMessageReceipts returns the blocks and messages in `pts` and their corresponding receipts from `ts` matching block order in tipset (`pts`).

type LilySurveyConfig added in v0.8.2 

type LilySurveyConfig struct {
	JobConfig LilyJobConfig

	Interval time.Duration
}

type LilyTipSetWorkerConfig added in v0.10.0 

type LilyTipSetWorkerConfig struct {
	JobConfig LilyJobConfig

	// Queue is the name of the queueing system the worker will consume work from.
	Queue string
}

type LilyWalkConfig 

type LilyWalkConfig struct {
	JobConfig LilyJobConfig

	From     int64
	To       int64
	Interval int
}

type LilyWalkNotifyConfig added in v0.10.0 

type LilyWalkNotifyConfig struct {
	WalkConfig LilyWalkConfig

	Queue string
}

type LilyWatchConfig 

type LilyWatchConfig struct {
	JobConfig LilyJobConfig

	BufferSize int // number of tipsets to buffer from notifier service
	Confidence int
	Workers    int // number of indexing jobs that can run in parallel
	Interval   int
}

type LilyWatchNotifyConfig added in v0.10.0 

type LilyWatchNotifyConfig struct {
	JobConfig LilyJobConfig

	BufferSize int // number of tipsets to buffer from notifier service
	Confidence int
	Queue      string
}

type LogQueryHook 

type LogQueryHook struct{}

used for debugging querries, call ORM.AddHook and this will print all queries.

func (*LogQueryHook) AfterQuery 

func (l *LogQueryHook) AfterQuery(_ context.Context, _ *pg.QueryEvent) error

func (*LogQueryHook) BeforeQuery 

func (l *LogQueryHook) BeforeQuery(ctx context.Context, evt *pg.QueryEvent) (context.Context, error)

type StateReport added in v0.12.0 

type StateReport struct {
	Height      int64
	TipSet      *types.TipSet
	HasMessages bool
	HasReceipts bool
	HasState    bool
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.