stmgr

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Aug 21, 2020 License: Apache-2.0, MIT Imports: 40 Imported by: 43

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MethodsMap = map[cid.Cid][]methodMeta{}

Functions

func CheckTotalFIL added in v0.5.0

func CheckTotalFIL(ctx context.Context, sm *StateManager, ts *types.TipSet) (abi.TokenAmount, error)

func ComputeState added in v0.2.5

func ComputeState(ctx context.Context, sm *StateManager, height abi.ChainEpoch, msgs []*types.Message, ts *types.TipSet) (cid.Cid, []*api.InvocResult, error)

func GetFilBurnt added in v0.5.0

func GetFilBurnt(ctx context.Context, st *state.StateTree) (abi.TokenAmount, error)

func GetFilMined added in v0.5.0

func GetFilMined(ctx context.Context, st *state.StateTree) (abi.TokenAmount, error)

func GetLookbackTipSetForRound added in v0.3.0

func GetLookbackTipSetForRound(ctx context.Context, sm *StateManager, ts *types.TipSet, round abi.ChainEpoch) (*types.TipSet, error)

func GetMinerSectorSet

func GetMinerSectorSet(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address, filter *abi.BitField, filterOut bool) ([]*api.ChainSectorInfo, error)

func GetMinerSlashed

func GetMinerSlashed(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (bool, error)

func GetMinerWorkerRaw

func GetMinerWorkerRaw(ctx context.Context, sm *StateManager, st cid.Cid, maddr address.Address) (address.Address, error)

func GetNetworkName added in v0.3.0

func GetNetworkName(ctx context.Context, sm *StateManager, st cid.Cid) (dtypes.NetworkName, error)

func GetPower

func GetPower(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (power.Claim, power.Claim, error)

func GetPowerRaw added in v0.3.0

func GetPowerRaw(ctx context.Context, sm *StateManager, st cid.Cid, maddr address.Address) (power.Claim, power.Claim, error)

func GetReturnType added in v0.5.0

func GetReturnType(ctx context.Context, sm *StateManager, to address.Address, method abi.MethodNum, ts *types.TipSet) (cbg.CBORUnmarshaler, error)

func GetSectorsForWinningPoSt added in v0.3.0

func GetSectorsForWinningPoSt(ctx context.Context, pv ffiwrapper.Verifier, sm *StateManager, st cid.Cid, maddr address.Address, rand abi.PoStRandomness) ([]abi.SectorInfo, error)

func GetStorageDeal

func GetStorageDeal(ctx context.Context, sm *StateManager, dealID abi.DealID, ts *types.TipSet) (*api.MarketDeal, error)

func ListMinerActors added in v0.1.5

func ListMinerActors(ctx context.Context, sm *StateManager, ts *types.TipSet) ([]address.Address, error)

func LoadSectorsFromSet

func LoadSectorsFromSet(ctx context.Context, bs blockstore.Blockstore, ssc cid.Cid, filter *abi.BitField, filterOut bool) ([]*api.ChainSectorInfo, error)

func MinerGetBaseInfo added in v0.3.0

func MinerGetBaseInfo(ctx context.Context, sm *StateManager, bcn beacon.RandomBeacon, tsk types.TipSetKey, round abi.ChainEpoch, maddr address.Address, pv ffiwrapper.Verifier) (*api.MiningBaseInfo, error)

func MinerHasMinPower added in v0.5.0

func MinerHasMinPower(ctx context.Context, sm *StateManager, addr address.Address, ts *types.TipSet) (bool, error)

func MinerSectorInfo added in v0.3.1

func MinerSectorInfo(ctx context.Context, sm *StateManager, maddr address.Address, sid abi.SectorNumber, ts *types.TipSet) (*miner.SectorOnChainInfo, error)

func PreCommitInfo added in v0.3.0

func PreCommitInfo(ctx context.Context, sm *StateManager, maddr address.Address, sid abi.SectorNumber, ts *types.TipSet) (miner.SectorPreCommitOnChainInfo, error)

func StateMinerInfo added in v0.3.0

func StateMinerInfo(ctx context.Context, sm *StateManager, ts *types.TipSet, maddr address.Address) (*miner.MinerInfo, error)

Types

type ActorCB added in v0.5.0

type ActorCB func(act *types.Actor) error

func GetActor added in v0.5.0

func GetActor(out *types.Actor) ActorCB

type DeadlineCB added in v0.5.0

type DeadlineCB func(store adt.Store, idx uint64, deadline *miner.Deadline) error

type DeadlinesCB added in v0.5.0

type DeadlinesCB func(store adt.Store, deadlines *miner.Deadlines) error

type ExecCallback added in v0.3.0

type ExecCallback func(cid.Cid, *types.Message, *vm.ApplyRet) error

type PartitionCB added in v0.5.0

type PartitionCB func(store adt.Store, idx uint64, partition *miner.Partition) error

type StateManager

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

func NewStateManager

func NewStateManager(cs *store.ChainStore) *StateManager

func (*StateManager) ApplyBlocks added in v0.3.0

func (sm *StateManager) ApplyBlocks(ctx context.Context, parentEpoch abi.ChainEpoch, pstate cid.Cid, bms []store.BlockMessages, epoch abi.ChainEpoch, r vm.Rand, cb ExecCallback, baseFee abi.TokenAmount) (cid.Cid, cid.Cid, error)

func (*StateManager) Call

func (sm *StateManager) Call(ctx context.Context, msg *types.Message, ts *types.TipSet) (*api.InvocResult, error)

func (*StateManager) CallRaw

func (sm *StateManager) CallRaw(ctx context.Context, msg *types.Message, bstate cid.Cid, r vm.Rand, bheight abi.ChainEpoch) (*api.InvocResult, error)

func (*StateManager) CallWithGas added in v0.5.0

func (sm *StateManager) CallWithGas(ctx context.Context, msg *types.Message, priorMsgs []types.ChainMsg, ts *types.TipSet) (*api.InvocResult, error)

func (*StateManager) ChainStore

func (sm *StateManager) ChainStore() *store.ChainStore

func (*StateManager) ExecutionTrace added in v0.3.0

func (sm *StateManager) ExecutionTrace(ctx context.Context, ts *types.TipSet) (cid.Cid, []*api.InvocResult, error)

func (*StateManager) GetBlsPublicKey

func (sm *StateManager) GetBlsPublicKey(ctx context.Context, addr address.Address, ts *types.TipSet) (pubk []byte, err error)

func (*StateManager) GetCirculatingSupply added in v0.5.0

func (sm *StateManager) GetCirculatingSupply(ctx context.Context, height abi.ChainEpoch, st *state.StateTree) (abi.TokenAmount, error)

func (*StateManager) GetCirculatingSupplyDetailed added in v0.5.0

func (sm *StateManager) GetCirculatingSupplyDetailed(ctx context.Context, height abi.ChainEpoch, st *state.StateTree) (api.CirculatingSupply, error)

func (*StateManager) GetFilLocked added in v0.5.0

func (sm *StateManager) GetFilLocked(ctx context.Context, st *state.StateTree) (abi.TokenAmount, error)

func (*StateManager) GetFilVested added in v0.5.0

func (sm *StateManager) GetFilVested(ctx context.Context, height abi.ChainEpoch, st *state.StateTree) (abi.TokenAmount, error)

GetVestedFunds returns all funds that have "left" actors that are in the genesis state: - For Multisigs, it counts the actual amounts that have vested at the given epoch - For Accounts, it counts max(currentBalance - genesisBalance, 0).

func (*StateManager) GetReceipt

func (sm *StateManager) GetReceipt(ctx context.Context, msg cid.Cid, ts *types.TipSet) (*types.MessageReceipt, error)

func (*StateManager) ListAllActors

func (sm *StateManager) ListAllActors(ctx context.Context, ts *types.TipSet) ([]address.Address, error)

func (*StateManager) LoadActorState

func (sm *StateManager) LoadActorState(ctx context.Context, addr address.Address, out interface{}, ts *types.TipSet) (*types.Actor, error)

func (*StateManager) LoadActorStateRaw added in v0.3.0

func (sm *StateManager) LoadActorStateRaw(ctx context.Context, addr address.Address, out interface{}, st cid.Cid) (*types.Actor, error)

func (*StateManager) LookupID added in v0.3.0

func (sm *StateManager) LookupID(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error)

func (*StateManager) MarketBalance

func (sm *StateManager) MarketBalance(ctx context.Context, addr address.Address, ts *types.TipSet) (api.MarketBalance, error)

func (*StateManager) Replay

func (sm *StateManager) Replay(ctx context.Context, ts *types.TipSet, mcid cid.Cid) (*types.Message, *vm.ApplyRet, error)

func (*StateManager) ResolveToKeyAddress

func (sm *StateManager) ResolveToKeyAddress(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error)

ResolveToKeyAddress is similar to `vm.ResolveToKeyAddr` but does not allow `Actor` type of addresses. Uses the `TipSet` `ts` to generate the VM state.

func (*StateManager) SearchForMessage added in v0.3.0

func (sm *StateManager) SearchForMessage(ctx context.Context, mcid cid.Cid) (*types.TipSet, *types.MessageReceipt, cid.Cid, error)

func (*StateManager) SetVMConstructor added in v0.2.8

func (sm *StateManager) SetVMConstructor(nvm func(*vm.VMOpts) (*vm.VM, error))

func (*StateManager) TipSetState

func (sm *StateManager) TipSetState(ctx context.Context, ts *types.TipSet) (st cid.Cid, rec cid.Cid, err error)

func (*StateManager) ValidateChain added in v0.2.6

func (sm *StateManager) ValidateChain(ctx context.Context, ts *types.TipSet) error

func (*StateManager) WaitForMessage

func (sm *StateManager) WaitForMessage(ctx context.Context, mcid cid.Cid, confidence uint64) (*types.TipSet, *types.MessageReceipt, cid.Cid, error)

WaitForMessage blocks until a message appears on chain. It looks backwards in the chain to see if this has already happened. It guarantees that the message has been on chain for at least confidence epochs without being reverted before returning.

func (*StateManager) WithActor added in v0.5.0

func (sm *StateManager) WithActor(addr address.Address, cb ActorCB) StateTreeCB

func (*StateManager) WithActorState added in v0.5.0

func (sm *StateManager) WithActorState(ctx context.Context, out interface{}) ActorCB

WithActorState usage: Option 1: WithActorState(ctx, idAddr, func(store adt.Store, st *ActorStateType) error {...}) Option 2: WithActorState(ctx, idAddr, actorStatePtr)

func (*StateManager) WithDeadline added in v0.5.0

func (sm *StateManager) WithDeadline(idx uint64, cb DeadlineCB) DeadlinesCB

func (*StateManager) WithDeadlines added in v0.5.0

func (sm *StateManager) WithDeadlines(cb DeadlinesCB) func(store adt.Store, mas *miner.State) error

func (*StateManager) WithEachDeadline added in v0.5.0

func (sm *StateManager) WithEachDeadline(cb DeadlineCB) DeadlinesCB

func (*StateManager) WithEachPartition added in v0.5.0

func (sm *StateManager) WithEachPartition(cb PartitionCB) DeadlineCB

func (*StateManager) WithParentState added in v0.5.0

func (sm *StateManager) WithParentState(ts *types.TipSet, cb StateTreeCB) error

func (*StateManager) WithParentStateTsk added in v0.5.0

func (sm *StateManager) WithParentStateTsk(tsk types.TipSetKey, cb StateTreeCB) error

func (*StateManager) WithStateTree added in v0.5.0

func (sm *StateManager) WithStateTree(st cid.Cid, cb StateTreeCB) error

type StateTreeCB added in v0.5.0

type StateTreeCB func(state *state.StateTree) error

Jump to

Keyboard shortcuts

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