lotus

package

v0.7.7 Latest Latest Go to latest Published: Aug 24, 2021 License: Apache-2.0, MIT Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/filecoin-project/sentinel-visor

Links

Open Source Insights

Documentation ¶

Index ¶

type APIOpener
- func NewAPIOpener(cctx *cli.Context, cacheSize int) (*APIOpener, lens.APICloser, error)
- func (o *APIOpener) Daemonized() bool
- func (o *APIOpener) Open(ctx context.Context) (lens.API, lens.APICloser, error)
type APIWrapper
- func NewAPIWrapper(node v0api.FullNode, store adt.Store) *APIWrapper
type CacheCtxStore
- func NewCacheCtxStore(ctx context.Context, api v0api.FullNode, cache *lru.ARCCache) (*CacheCtxStore, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type APIOpener ¶ added in v0.3.0

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

func NewAPIOpener ¶ added in v0.3.0

func NewAPIOpener(cctx *cli.Context, cacheSize int) (*APIOpener, lens.APICloser, error)

func (*APIOpener) Daemonized ¶ added in v0.7.5

func (o *APIOpener) Daemonized() bool

func (*APIOpener) Open ¶ added in v0.3.0

func (o *APIOpener) Open(ctx context.Context) (lens.API, lens.APICloser, error)

type APIWrapper ¶

type APIWrapper struct {
	v0api.FullNode
	// contains filtered or unexported fields
}

func NewAPIWrapper ¶

func NewAPIWrapper(node v0api.FullNode, store adt.Store) *APIWrapper

func (*APIWrapper) ChainGetBlock ¶

func (aw *APIWrapper) ChainGetBlock(ctx context.Context, msg cid.Cid) (*types.BlockHeader, error)

func (*APIWrapper) ChainGetBlockMessages ¶

func (aw *APIWrapper) ChainGetBlockMessages(ctx context.Context, msg cid.Cid) (*api.BlockMessages, error)

func (*APIWrapper) ChainGetGenesis ¶

func (aw *APIWrapper) ChainGetGenesis(ctx context.Context) (*types.TipSet, error)

func (*APIWrapper) ChainGetParentMessages ¶

func (aw *APIWrapper) ChainGetParentMessages(ctx context.Context, bcid cid.Cid) ([]api.Message, error)

func (*APIWrapper) ChainGetParentReceipts ¶

func (aw *APIWrapper) ChainGetParentReceipts(ctx context.Context, bcid cid.Cid) ([]*types.MessageReceipt, error)

func (*APIWrapper) ChainGetTipSet ¶

func (aw *APIWrapper) ChainGetTipSet(ctx context.Context, tsk types.TipSetKey) (*types.TipSet, error)

func (*APIWrapper) ChainGetTipSetAfterHeight ¶ added in v0.7.7

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

func (*APIWrapper) ChainNotify ¶

func (aw *APIWrapper) ChainNotify(ctx context.Context) (<-chan []*api.HeadChange, error)

func (*APIWrapper) ChainReadObj ¶

func (aw *APIWrapper) ChainReadObj(ctx context.Context, obj cid.Cid) ([]byte, error)

func (*APIWrapper) GetExecutedAndBlockMessagesForTipset ¶ added in v0.6.3

func (aw *APIWrapper) GetExecutedAndBlockMessagesForTipset(ctx context.Context, ts, pts *types.TipSet) (*lens.TipSetMessages, error)

GetExecutedAndBlockMessagesForTipset returns a list of messages sent as part of pts (parent) with receipts found in ts (child). No attempt at deduplication of messages is made. A list of blocks with their corresponding messages is also returned - it contains all messages in the block regardless if they were applied during the state change.

func (*APIWrapper) GetMessageExecutionsForTipSet ¶ added in v0.7.5

func (aw *APIWrapper) GetMessageExecutionsForTipSet(ctx context.Context, ts, pts *types.TipSet) ([]*lens.MessageExecution, error)

func (*APIWrapper) StateChangedActors ¶

func (aw *APIWrapper) StateChangedActors(ctx context.Context, old cid.Cid, new cid.Cid) (map[string]types.Actor, error)

func (*APIWrapper) StateGetActor ¶

func (aw *APIWrapper) StateGetActor(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*types.Actor, error)

func (*APIWrapper) StateGetReceipt ¶ added in v0.3.0

func (aw *APIWrapper) StateGetReceipt(ctx context.Context, bcid cid.Cid, tsk types.TipSetKey) (*types.MessageReceipt, error)

func (*APIWrapper) StateListActors ¶

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

func (*APIWrapper) StateMarketDeals ¶

func (aw *APIWrapper) StateMarketDeals(ctx context.Context, tsk types.TipSetKey) (map[string]api.MarketDeal, error)

func (*APIWrapper) StateMinerPower ¶

func (aw *APIWrapper) StateMinerPower(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*api.MinerPower, error)

func (*APIWrapper) StateReadState ¶

func (aw *APIWrapper) StateReadState(ctx context.Context, actor address.Address, tsk types.TipSetKey) (*api.ActorState, error)

func (*APIWrapper) StateVMCirculatingSupplyInternal ¶ added in v0.3.0

func (aw *APIWrapper) StateVMCirculatingSupplyInternal(ctx context.Context, tsk types.TipSetKey) (api.CirculatingSupply, error)

func (*APIWrapper) Store ¶

func (aw *APIWrapper) Store() adt.Store

type CacheCtxStore ¶

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

func NewCacheCtxStore ¶

func NewCacheCtxStore(ctx context.Context, api v0api.FullNode, cache *lru.ARCCache) (*CacheCtxStore, error)

func (*CacheCtxStore) Context ¶

func (cs *CacheCtxStore) Context() context.Context

func (*CacheCtxStore) Get ¶

func (cs *CacheCtxStore) Get(ctx context.Context, c cid.Cid, out interface{}) error

func (*CacheCtxStore) Put ¶

func (cs *CacheCtxStore) Put(ctx context.Context, v interface{}) (cid.Cid, error)

Source Files ¶

View all Source files

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