util

Documentation

Index

• Variables
• func ActorNameAndFamilyFromCode(c cid.Cid) (name string, family string, err error)
• func GetExecutedAndBlockMessagesForTipset(ctx context.Context, cs *store.ChainStore, next, current *types.TipSet) (*lens.TipSetMessages, error)
• func MakeGetActorCodeFunc(ctx context.Context, store adt.Store, next, current *types.TipSet) (func(a address.Address) (cid.Cid, bool), error)
• func MethodAndParamsForMessage(m *types.Message, destCode cid.Cid) (string, string, error)
• type Network
  • func NewNetwork(us stmgr.UpgradeSchedule, current network.Version) *Network
  • func (n *Network) Version(ctx context.Context, height abi.ChainEpoch) network.Version
• type ProxyingBlockstore
  • func NewCachingStore(backing blockstore.Blockstore) *ProxyingBlockstore
  • func (pb *ProxyingBlockstore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (pb *ProxyingBlockstore) DeleteBlock(c cid.Cid) error
  • func (pb *ProxyingBlockstore) DeleteMany(keys []cid.Cid) error
  • func (pb *ProxyingBlockstore) Get(c cid.Cid) (blocks.Block, error)
  • func (pb *ProxyingBlockstore) GetCount() int64
  • func (pb *ProxyingBlockstore) GetSize(c cid.Cid) (int, error)
  • func (pb *ProxyingBlockstore) Has(c cid.Cid) (bool, error)
  • func (pb *ProxyingBlockstore) HashOnRead(enabled bool)
  • func (pb *ProxyingBlockstore) Put(b blocks.Block) error
  • func (pb *ProxyingBlockstore) PutMany(bs []blocks.Block) error
  • func (pb *ProxyingBlockstore) ResetMetrics()
  • func (pb *ProxyingBlockstore) View(key cid.Cid, callback func([]byte) error) error

Variables

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, next, current *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 MethodAndParamsForMessage

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

Types

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(c cid.Cid) error

func (*ProxyingBlockstore) DeleteMany

func (pb *ProxyingBlockstore) DeleteMany(keys []cid.Cid) error

func (*ProxyingBlockstore) Get

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

func (*ProxyingBlockstore) GetCount

func (pb *ProxyingBlockstore) GetCount() int64

func (*ProxyingBlockstore) GetSize

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

func (*ProxyingBlockstore) Has

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

func (*ProxyingBlockstore) HashOnRead

func (pb *ProxyingBlockstore) HashOnRead(enabled bool)

func (*ProxyingBlockstore) Put

func (pb *ProxyingBlockstore) Put(b blocks.Block) error

func (*ProxyingBlockstore) PutMany

func (pb *ProxyingBlockstore) PutMany(bs []blocks.Block) error

func (*ProxyingBlockstore) ResetMetrics

func (pb *ProxyingBlockstore) ResetMetrics()

func (*ProxyingBlockstore) View

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