Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + const EnvWatchdogDisabled + const JWTSecretName + const KTJwtHmacSecret + var ManagerWorkPrefix = datastore.NewKey("/stmgr/calls") + var StorageCounterDSPrefix = "/storage/nextid" + var WorkerCallsPrefix = datastore.NewKey("/worker/calls") + func APISecret(keystore types.KeyStore, lr repo.LockedRepo) (*dtypes.APIAlg, error) + func AddressSelector(addrConf *config.MinerAddressConfig) func() (*storage.AddressSelector, error) + func BadgerColdBlockstore(lc fx.Lifecycle, r repo.LockedRepo) (dtypes.ColdBlockstore, error) + func BadgerHotBlockstore(lc fx.Lifecycle, r repo.LockedRepo) (dtypes.HotBlockstore, error) + func BasicDealFilter(user dtypes.StorageDealFilter) ... + func BuiltinBootstrap() (dtypes.BootstrapPeers, error) + func BuiltinDrandConfig() dtypes.DrandSchedule + func ChainBitswap(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, rt routing.Routing, ...) dtypes.ChainBitswap + func ChainBlockService(bs dtypes.ExposedBlockstore, rem dtypes.ChainBitswap) dtypes.ChainBlockService + func ChainFlatBlockstore(_ fx.Lifecycle, _ helpers.MetricsCtx, bs dtypes.UniversalBlockstore) (dtypes.ChainBlockstore, error) + func ChainSplitBlockstore(_ fx.Lifecycle, _ helpers.MetricsCtx, bs dtypes.SplitBlockstore) (dtypes.ChainBlockstore, error) + func ChainStore(lc fx.Lifecycle, cbs dtypes.ChainBlockstore, sbs dtypes.StateBlockstore, ...) *store.ChainStore + func ClientBlockstore(imgr dtypes.ClientImportMgr) dtypes.ClientBlockstore + func ClientBlockstoreRetrievalStoreManager(bs dtypes.ClientBlockstore) dtypes.ClientRetrievalStoreManager + func ClientImportMgr(mds dtypes.ClientMultiDstore, ds dtypes.MetadataDS) dtypes.ClientImportMgr + func ClientMultiDatastore(lc fx.Lifecycle, mctx helpers.MetricsCtx, r repo.LockedRepo) (dtypes.ClientMultiDstore, error) + func ClientRetrievalStoreManager(imgr dtypes.ClientImportMgr) dtypes.ClientRetrievalStoreManager + func ConfigBootstrap(peers []string) func() (dtypes.BootstrapPeers, error) + func Datastore(disableLog bool) ... + func DoSetGenesis(_ dtypes.AfterGenesisSet) + func DrandBootstrap(ds dtypes.DrandSchedule) (dtypes.DrandBootstrap, error) + func FallbackChainBlockstore(cbs dtypes.ChainBlockstore) dtypes.ChainBlockstore + func FallbackStateBlockstore(sbs dtypes.StateBlockstore) dtypes.StateBlockstore + func GetParams(spt abi.RegisteredSealProof) error + func Graphsync(parallelTransfers uint64) ... + func HandleDeals(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, ...) + func HandleIncomingBlocks(mctx helpers.MetricsCtx, lc fx.Lifecycle, ps *pubsub.PubSub, s *chain.Syncer, ...) + func HandleIncomingMessages(mctx helpers.MetricsCtx, lc fx.Lifecycle, ps *pubsub.PubSub, ...) + func HandleRetrieval(host host.Host, lc fx.Lifecycle, m retrievalmarket.RetrievalProvider, ...) + func InitFallbackBlockstores(cbs dtypes.ChainBlockstore, sbs dtypes.StateBlockstore, ...) error + func IpfsClientBlockstore(ipfsMaddr string, onlineMode bool) ... + func KeyStore(lr repo.LockedRepo) (types.KeyStore, error) + func LoadGenesis(genBytes []byte) func(dtypes.ChainBlockstore) Genesis + func LockedRepo(lr repo.LockedRepo) func(lc fx.Lifecycle) repo.LockedRepo + func MemoryConstraints() system.MemoryConstraints + func MemoryWatchdog(lr repo.LockedRepo, lc fx.Lifecycle, constraints system.MemoryConstraints) + func MessagePool(lc fx.Lifecycle, sm *stmgr.StateManager, ps *pubsub.PubSub, ...) (*messagepool.MessagePool, error) + func MinerAddress(ds dtypes.MetadataDS) (dtypes.MinerAddress, error) + func MinerID(ma dtypes.MinerAddress) (dtypes.MinerID, error) + func NetworkName(mctx helpers.MetricsCtx, lc fx.Lifecycle, cs *store.ChainStore, ...) (dtypes.NetworkName, error) + func NewClientDatastore(ds dtypes.MetadataDS) dtypes.ClientDatastore + func NewClientGraphsyncDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.Graphsync, ds dtypes.MetadataDS, ...) (dtypes.ClientDataTransfer, error) + func NewConsiderOfflineRetrievalDealsConfigFunc(r repo.LockedRepo) (dtypes.ConsiderOfflineRetrievalDealsConfigFunc, error) + func NewConsiderOfflineStorageDealsConfigFunc(r repo.LockedRepo) (dtypes.ConsiderOfflineStorageDealsConfigFunc, error) + func NewConsiderOnlineRetrievalDealsConfigFunc(r repo.LockedRepo) (dtypes.ConsiderOnlineRetrievalDealsConfigFunc, error) + func NewConsiderOnlineStorageDealsConfigFunc(r repo.LockedRepo) (dtypes.ConsiderOnlineStorageDealsConfigFunc, error) + func NewDefaultMaxFeeFunc(r repo.LockedRepo) dtypes.DefaultMaxFeeFunc + func NewGetExpectedSealDurationFunc(r repo.LockedRepo) (dtypes.GetExpectedSealDurationFunc, error) + func NewGetSealConfigFunc(r repo.LockedRepo) (dtypes.GetSealingConfigFunc, error) + func NewLocalDiscovery(lc fx.Lifecycle, ds dtypes.MetadataDS) (*discoveryimpl.Local, error) + func NewProviderDAGServiceDataTransfer(lc fx.Lifecycle, h host.Host, gs dtypes.StagingGraphsync, ds dtypes.MetadataDS, ...) (dtypes.ProviderDataTransfer, error) + func NewProviderPieceStore(lc fx.Lifecycle, ds dtypes.MetadataDS) (dtypes.ProviderPieceStore, error) + func NewSetConsiderOfflineRetrievalDealsConfigFunc(r repo.LockedRepo) (dtypes.SetConsiderOfflineRetrievalDealsConfigFunc, error) + func NewSetConsiderOnlineRetrievalDealsConfigFunc(r repo.LockedRepo) (dtypes.SetConsiderOnlineRetrievalDealsConfigFunc, error) + func NewSetConsideringOfflineStorageDealsFunc(r repo.LockedRepo) (dtypes.SetConsiderOfflineStorageDealsConfigFunc, error) + func NewSetConsideringOnlineStorageDealsFunc(r repo.LockedRepo) (dtypes.SetConsiderOnlineStorageDealsConfigFunc, error) + func NewSetExpectedSealDurationFunc(r repo.LockedRepo) (dtypes.SetExpectedSealDurationFunc, error) + func NewSetSealConfigFunc(r repo.LockedRepo) (dtypes.SetSealingConfigFunc, error) + func NewSetStorageDealPieceCidBlocklistConfigFunc(r repo.LockedRepo) (dtypes.SetStorageDealPieceCidBlocklistConfigFunc, error) + func NewSlashFilter(ds dtypes.MetadataDS) *slashfilter.SlashFilter + func NewStorageAsk(ctx helpers.MetricsCtx, fapi lapi.FullNode, ds dtypes.MetadataDS, ...) (*storedask.StoredAsk, error) + func NewStorageDealPieceCidBlocklistConfigFunc(r repo.LockedRepo) (dtypes.StorageDealPieceCidBlocklistConfigFunc, error) + func NewSyncer(params SyncerParams) (*chain.Syncer, error) + func OpenFilesystemJournal(lr repo.LockedRepo, lc fx.Lifecycle, disabled journal.DisabledEvents) (journal.Journal, error) + func RandomSchedule(p RandomBeaconParams, _ dtypes.AfterGenesisSet) (beacon.Schedule, error) + func RecordValidator(ps peerstore.Peerstore) record.Validator + func RegisterClientValidator(crv dtypes.ClientRequestValidator, dtm dtypes.ClientDataTransfer) + func RetrievalClient(lc fx.Lifecycle, h host.Host, mds dtypes.ClientMultiDstore, ...) (retrievalmarket.RetrievalClient, error) + func RetrievalDealFilter(userFilter dtypes.RetrievalDealFilter) ... + func RetrievalProvider(h host.Host, miner *storage.Miner, sealer sectorstorage.SectorManager, ...) (retrievalmarket.RetrievalProvider, error) + func RetrievalResolver(l *discoveryimpl.Local) discovery.PeerResolver + func RunChainExchange(h host.Host, svc exchange.Server) + func RunChainSysMetrics(mctx helpers.MetricsCtx, lc fx.Lifecycle, reporter metrics2.Reporter) + func RunHello(mctx helpers.MetricsCtx, lc fx.Lifecycle, h host.Host, svc *hello.Service) error + func RunMinerMetrics(mctx helpers.MetricsCtx, lc fx.Lifecycle, node api.FullNode, st *storage.Miner, ...) + func RunMinerSysMetrics(mctx helpers.MetricsCtx, lc fx.Lifecycle, reporter metrics2.Reporter) + func RunPeerMgr(mctx helpers.MetricsCtx, lc fx.Lifecycle, pmgr *peermgr.PeerMgr) + func SealProofType(maddr dtypes.MinerAddress, fnapi lapi.FullNode) (abi.RegisteredSealProof, error) + func SectorIDCounter(ds dtypes.MetadataDS) sealing.SectorIDCounter + func SectorStorage(mctx helpers.MetricsCtx, lc fx.Lifecycle, ls stores.LocalStorage, ...) (*sectorstorage.Manager, error) + func SetGenesis(cs *store.ChainStore, g Genesis) (dtypes.AfterGenesisSet, error) + func SetupBlockProducer(lc fx.Lifecycle, ds dtypes.MetadataDS, api lapi.FullNode, ...) (*lotusminer.Miner, error) + func SplitBlockstore(cfg *config.Chainstore) ... + func StagingBlockstore(lc fx.Lifecycle, mctx helpers.MetricsCtx, r repo.LockedRepo) (dtypes.StagingBlockstore, error) + func StagingDAG(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.StagingBlockstore, ...) (dtypes.StagingDAG, error) + func StagingGraphsync(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.StagingBlockstore, ...) dtypes.StagingGraphsync + func StagingMultiDatastore(lc fx.Lifecycle, mctx helpers.MetricsCtx, r repo.LockedRepo) (dtypes.StagingMultiDstore, error) + func StateFlatBlockstore(_ fx.Lifecycle, _ helpers.MetricsCtx, bs dtypes.UniversalBlockstore) (dtypes.StateBlockstore, error) + func StateManager(lc fx.Lifecycle, cs *store.ChainStore, us stmgr.UpgradeSchedule) (*stmgr.StateManager, error) + func StateSplitBlockstore(_ fx.Lifecycle, _ helpers.MetricsCtx, bs dtypes.SplitBlockstore) (dtypes.StateBlockstore, error) + func StorageAuth(ctx helpers.MetricsCtx, ca lapi.Common) (sectorstorage.StorageAuth, error) + func StorageClient(lc fx.Lifecycle, h host.Host, ibs dtypes.ClientBlockstore, ...) (storagemarket.StorageClient, error) + func StorageMiner(fc config.MinerFeeConfig) func(params StorageMinerParams) (*storage.Miner, error) + func StorageNetworkName(ctx helpers.MetricsCtx, a lapi.FullNode) (dtypes.NetworkName, error) + func StorageProvider(minerAddress dtypes.MinerAddress, storedAsk *storedask.StoredAsk, h host.Host, ...) (storagemarket.StorageProvider, error) + func UniversalBlockstore(lc fx.Lifecycle, mctx helpers.MetricsCtx, r repo.LockedRepo) (dtypes.UniversalBlockstore, error) + type Genesis func() (*types.BlockHeader, error) + func ErrorGenesis() Genesis + type JwtPayload struct + Allow []auth.Permission + type MpoolNonceAPI struct + StateAPI full.StateAPI + func (a *MpoolNonceAPI) GetNonce(addr address.Address) (uint64, error) + type RPCStateManager struct + func NewRPCStateManager(api api.GatewayAPI) *RPCStateManager + func (s *RPCStateManager) Call(ctx context.Context, msg *types.Message, ts *types.TipSet) (*api.InvocResult, error) + func (s *RPCStateManager) GetFlowchState(ctx context.Context, addr address.Address, ts *types.TipSet) (*types.Actor, flowch.State, error) + func (s *RPCStateManager) GetPaychState(ctx context.Context, addr address.Address, ts *types.TipSet) (*types.Actor, paych.State, error) + func (s *RPCStateManager) LoadActorTsk(ctx context.Context, addr address.Address, tsk types.TipSetKey) (*types.Actor, error) + func (s *RPCStateManager) LookupID(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) + func (s *RPCStateManager) ResolveToKeyAddress(ctx context.Context, addr address.Address, ts *types.TipSet) (address.Address, error) + type RandomBeaconParams struct + Cs *store.ChainStore + DrandConfig dtypes.DrandSchedule + PubSub *pubsub.PubSub + type StorageMinerParams struct + API lapi.FullNode + AddrSel *storage.AddressSelector + GetSealingConfigFn dtypes.GetSealingConfigFunc + Host host.Host + Journal journal.Journal + Lifecycle fx.Lifecycle + MetadataDS dtypes.MetadataDS + MetricsCtx helpers.MetricsCtx + Sealer sectorstorage.SectorManager + SectorIDCounter sealing.SectorIDCounter + Verifier ffiwrapper.Verifier + type SyncerParams struct + Beacon beacon.Schedule + ChainXchg exchange.Client + Host host.Host + Lifecycle fx.Lifecycle + MetadataDS dtypes.MetadataDS + StateManager *stmgr.StateManager + SyncMgrCtor chain.SyncManagerCtor + Verifier ffiwrapper.Verifier
Go to main page