util

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2022 License: Apache-2.0, MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ActorRegistry *vm.ActorRegistry
View Source 
var DefaultNetwork = NewNetwork(filcns.DefaultUpgradeSchedule(), build.NewestNetworkVersion)

DefaultNetwork is the filecoing network this version of lily has been built against

Functions

func ActorNameAndFamilyFromCode 

func ActorNameAndFamilyFromCode(c cid.Cid) (name string, family string, err error)

func GetExecutedAndBlockMessagesForTipset 

func GetExecutedAndBlockMessagesForTipset(ctx context.Context, cs *store.ChainStore, sm *stmgr.StateManager, current, executed *types.TipSet) (*lens.TipSetMessages, error)

GetMessagesForTipset 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 MakeGetActorCodeFunc 

func MakeGetActorCodeFunc(ctx context.Context, store adt.Store, next, current *types.TipSet) (func(a address.Address) (cid.Cid, bool), error)

func MarshalWithOverrides added in v0.8.6 

func MarshalWithOverrides(v interface{}, overrides map[reflect.Type]marshaller) (out []byte, err error)

func MethodAndParamsForMessage 

func MethodAndParamsForMessage(m *types.Message, destCode cid.Cid) (string, string, error)

func ParseParams added in v0.8.6 

func ParseParams(params []byte, method abi.MethodNum, actCode cid.Cid) (string, string, error)

Types

type CacheConfig added in v0.8.6 

type CacheConfig struct {
	BlockstoreCacheSize uint
	StatestoreCacheSize uint
}

type CachingBlockstore added in v0.8.6 

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

func NewCachingBlockstore added in v0.8.6 

func NewCachingBlockstore(blocks blockstore.Blockstore, cacheSize int) (*CachingBlockstore, error)

func (*CachingBlockstore) AllKeysChan added in v0.8.6 

func (cs *CachingBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

func (*CachingBlockstore) DeleteBlock added in v0.8.6 

func (cs *CachingBlockstore) DeleteBlock(ctx context.Context, c cid.Cid) error

func (*CachingBlockstore) DeleteMany added in v0.8.6 

func (cs *CachingBlockstore) DeleteMany(ctx context.Context, cids []cid.Cid) error

func (*CachingBlockstore) Get added in v0.8.6 

func (cs *CachingBlockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)

func (*CachingBlockstore) GetSize added in v0.8.6 

func (cs *CachingBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

func (*CachingBlockstore) Has added in v0.8.6 

func (cs *CachingBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

func (*CachingBlockstore) HashOnRead added in v0.8.6 

func (cs *CachingBlockstore) HashOnRead(enabled bool)

func (*CachingBlockstore) Put added in v0.8.6 

func (cs *CachingBlockstore) Put(ctx context.Context, blk blocks.Block) error

func (*CachingBlockstore) PutMany added in v0.8.6 

func (cs *CachingBlockstore) PutMany(ctx context.Context, blks []blocks.Block) error

func (*CachingBlockstore) View added in v0.8.6 

func (cs *CachingBlockstore) View(ctx context.Context, c cid.Cid, callback func([]byte) error) error

type CachingStateStore added in v0.8.6 

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

func NewCachingStateStore added in v0.8.6 

func NewCachingStateStore(blocks blockstore.Blockstore, cacheSize int) (*CachingStateStore, error)

func (*CachingStateStore) Context added in v0.8.6 

func (cas *CachingStateStore) Context() context.Context

func (*CachingStateStore) Get added in v0.8.6 

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

func (*CachingStateStore) Put added in v0.8.6 

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

type Network 

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

Network holds properties of the filecoin network

func NewNetwork 

func NewNetwork(us stmgr.UpgradeSchedule, current network.Version) *Network

func (*Network) Version 

func (n *Network) Version(ctx context.Context, height abi.ChainEpoch) network.Version

type ProxyingBlockstore 

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

func NewCachingStore 

func NewCachingStore(backing blockstore.Blockstore) *ProxyingBlockstore

func (*ProxyingBlockstore) AllKeysChan 

func (pb *ProxyingBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

func (*ProxyingBlockstore) DeleteBlock 

func (pb *ProxyingBlockstore) DeleteBlock(ctx context.Context, c cid.Cid) error

func (*ProxyingBlockstore) DeleteMany 

func (pb *ProxyingBlockstore) DeleteMany(ctx context.Context, keys []cid.Cid) error

func (*ProxyingBlockstore) Get 

func (pb *ProxyingBlockstore) Get(ctx context.Context, c cid.Cid) (blocks.Block, error)

func (*ProxyingBlockstore) GetCount 

func (pb *ProxyingBlockstore) GetCount() int64

func (*ProxyingBlockstore) GetSize 

func (pb *ProxyingBlockstore) GetSize(ctx context.Context, c cid.Cid) (int, error)

func (*ProxyingBlockstore) Has 

func (pb *ProxyingBlockstore) Has(ctx context.Context, c cid.Cid) (bool, error)

func (*ProxyingBlockstore) HashOnRead 

func (pb *ProxyingBlockstore) HashOnRead(enabled bool)

func (*ProxyingBlockstore) Put 

func (pb *ProxyingBlockstore) Put(ctx context.Context, b blocks.Block) error

func (*ProxyingBlockstore) PutMany 

func (pb *ProxyingBlockstore) PutMany(ctx context.Context, bs []blocks.Block) error

func (*ProxyingBlockstore) ResetMetrics 

func (pb *ProxyingBlockstore) ResetMetrics()

func (*ProxyingBlockstore) View 

func (pb *ProxyingBlockstore) View(ctx context.Context, key cid.Cid, callback func([]byte) error) error

Source Files

View all Source files

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.