util

package
v0.12.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Sep 1, 2022 License: Apache-2.0, MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ActorRegistry *vm.ActorRegistry

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 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)

func ParseReturn added in v0.12.0

func ParseReturn(ret []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 MessageParamsReturn added in v0.12.0

type MessageParamsReturn struct {
	MethodName string
	Params     string
	Return     string
}

func MethodParamsReturnForMessage

func MethodParamsReturnForMessage(m *MessageTrace, destCode cid.Cid) (*MessageParamsReturn, error)

type MessageTrace added in v0.12.0

type MessageTrace struct {
	Message   *types.Message
	Receipt   *types.MessageReceipt
	Error     string
	Duration  time.Duration
	GasCharge []*types.GasTrace
}

func GetChildMessagesOf added in v0.12.0

func GetChildMessagesOf(m *lens.MessageExecution) []*MessageTrace

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 (*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

Jump to

Keyboard shortcuts

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