modules

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: May 14, 2020 License: Apache-2.0, MIT Imports: 82 Imported by: 30

Documentation

Index

Constants

View Source 
const JWTSecretName = "auth-jwt-private"

Variables

This section is empty.

Functions

func APISecret 

func APISecret(keystore types.KeyStore, lr repo.LockedRepo) (*dtypes.APIAlg, error)

func BuiltinBootstrap 

func BuiltinBootstrap() (dtypes.BootstrapPeers, error)

func ChainBlockservice 

func ChainBlockservice(bs dtypes.ChainBlockstore, rem dtypes.ChainExchange) dtypes.ChainBlockService

func ChainBlockstore 

func ChainBlockstore(r repo.LockedRepo) (dtypes.ChainBlockstore, error)

func ChainExchange 

func ChainExchange(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, rt routing.Routing, bs dtypes.ChainGCBlockstore) dtypes.ChainExchange

func ChainGCBlockstore 

func ChainGCBlockstore(bs dtypes.ChainBlockstore, gcl dtypes.ChainGCLocker) dtypes.ChainGCBlockstore

func ChainStore 

func ChainStore(lc fx.Lifecycle, bs dtypes.ChainBlockstore, ds dtypes.MetadataDS, syscalls runtime.Syscalls) *store.ChainStore

func ClientBlockstore 

func ClientBlockstore(fstore dtypes.ClientFilestore) dtypes.ClientBlockstore

func ClientDAG 

func ClientDAG(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.ClientBlockstore, rt routing.Routing, h host.Host) dtypes.ClientDAG

ClientDAG is a DAGService for the ClientBlockstore

func ClientFstore 

func ClientFstore(r repo.LockedRepo) (dtypes.ClientFilestore, error)

func ConfigBootstrap 

func ConfigBootstrap(peers []string) func() (dtypes.BootstrapPeers, error)

func Datastore 

func Datastore(r repo.LockedRepo) (dtypes.MetadataDS, error)

func DoSetGenesis added in v0.3.0 

func DoSetGenesis(_ dtypes.AfterGenesisSet)

func GetParams 

func GetParams(sbc *ffiwrapper.Config) error

func Graphsync added in v0.3.0 

func Graphsync(mctx helpers.MetricsCtx, lc fx.Lifecycle, clientBs dtypes.ClientBlockstore, chainBs dtypes.ChainBlockstore, h host.Host) (dtypes.Graphsync, error)

Graphsync creates a graphsync instance from the given loader and storer

func HandleDeals 

func HandleDeals(mctx helpers.MetricsCtx, lc fx.Lifecycle, host host.Host, h storagemarket.StorageProvider)

func HandleIncomingBlocks 

func HandleIncomingBlocks(mctx helpers.MetricsCtx, lc fx.Lifecycle, ps *pubsub.PubSub, s *chain.Syncer, h host.Host, nn dtypes.NetworkName)

func HandleIncomingMessages 

func HandleIncomingMessages(mctx helpers.MetricsCtx, lc fx.Lifecycle, ps *pubsub.PubSub, mpool *messagepool.MessagePool, nn dtypes.NetworkName)

func HandleRetrieval 

func HandleRetrieval(host host.Host, lc fx.Lifecycle, m retrievalmarket.RetrievalProvider)

func IpfsClientBlockstore added in v0.3.0 

func IpfsClientBlockstore(mctx helpers.MetricsCtx, lc fx.Lifecycle, fstore dtypes.ClientFilestore) (dtypes.ClientBlockstore, error)

func KeyStore 

func KeyStore(lr repo.LockedRepo) (types.KeyStore, error)

func LoadGenesis 

func LoadGenesis(genBytes []byte) func(dtypes.ChainBlockstore) Genesis

func LockedRepo 

func LockedRepo(lr repo.LockedRepo) func(lc fx.Lifecycle) repo.LockedRepo

func MessagePool 

func MessagePool(lc fx.Lifecycle, sm *stmgr.StateManager, ps *pubsub.PubSub, ds dtypes.MetadataDS, nn dtypes.NetworkName) (*messagepool.MessagePool, error)

func MinerAddress added in v0.3.0 

func MinerAddress(ds dtypes.MetadataDS) (dtypes.MinerAddress, error)

func MinerID added in v0.3.0 

func MinerID(ma dtypes.MinerAddress) (dtypes.MinerID, error)

func MinerRandomBeacon added in v0.3.0 

func MinerRandomBeacon(api lapi.FullNode) (beacon.RandomBeacon, error)

func NetworkName added in v0.3.0 

func NetworkName(mctx helpers.MetricsCtx, lc fx.Lifecycle, cs *store.ChainStore, _ dtypes.AfterGenesisSet) (dtypes.NetworkName, error)

func NewClientDatastore added in v0.3.0 

func NewClientDatastore(ds dtypes.MetadataDS) dtypes.ClientDatastore

NewClientDatastore creates a datastore for the client to store its deals

func NewClientDealStore 

func NewClientDealStore(ds dtypes.ClientDatastore) dtypes.ClientDealStore

NewClientDealStore creates a statestore for the client to store its deals

func NewClientGraphsyncDataTransfer added in v0.3.0 

func NewClientGraphsyncDataTransfer(h host.Host, gs dtypes.Graphsync, ds dtypes.MetadataDS) dtypes.ClientDataTransfer

NewClientGraphsyncDataTransfer returns a data transfer manager that just uses the clients's Client DAG service for transfers

func NewClientRequestValidator added in v0.2.1 

func NewClientRequestValidator(deals dtypes.ClientDealStore) *requestvalidation.ClientRequestValidator

func NewLocalDiscovery added in v0.2.1 

func NewLocalDiscovery(ds dtypes.MetadataDS) *discovery.Local

func NewProviderDAGServiceDataTransfer 

func NewProviderDAGServiceDataTransfer(h host.Host, gs dtypes.StagingGraphsync, ds dtypes.MetadataDS) dtypes.ProviderDataTransfer

NewProviderDAGServiceDataTransfer returns a data transfer manager that just uses the provider's Staging DAG service for transfers

func NewProviderDealStore 

func NewProviderDealStore(ds dtypes.MetadataDS) dtypes.ProviderDealStore

NewProviderDealStore creates a statestore for the client to store its deals

func NewProviderPieceStore added in v0.3.0 

func NewProviderPieceStore(ds dtypes.MetadataDS) dtypes.ProviderPieceStore

NewProviderPieceStore creates a statestore for storing metadata about pieces shared by the storage and retrieval providers

func NewProviderRequestValidator added in v0.2.1 

func NewProviderRequestValidator(deals dtypes.ProviderDealStore) *requestvalidation.ProviderRequestValidator

func NewSyncer 

func NewSyncer(lc fx.Lifecycle, sm *stmgr.StateManager, bsync *blocksync.BlockSync, h host.Host, beacon beacon.RandomBeacon, verifier ffiwrapper.Verifier) (*chain.Syncer, error)

func ProofsConfig added in v0.3.0 

func ProofsConfig(maddr dtypes.MinerAddress, fnapi lapi.FullNode) (*ffiwrapper.Config, error)

func RandomBeacon added in v0.3.0 

func RandomBeacon(cs *store.ChainStore, _ dtypes.AfterGenesisSet) (beacon.RandomBeacon, error)

func RecordValidator 

func RecordValidator(ps peerstore.Peerstore) record.Validator

RecordValidator provides namesys compatible routing record validator

func RegisterClientValidator 

func RegisterClientValidator(crv *requestvalidation.ClientRequestValidator, dtm dtypes.ClientDataTransfer)

RegisterClientValidator is an initialization hook that registers the client request validator with the data transfer module as the validator for StorageDataTransferVoucher types

func RegisterProviderValidator 

func RegisterProviderValidator(mrv *requestvalidation.ProviderRequestValidator, dtm dtypes.ProviderDataTransfer)

RegisterProviderValidator is an initialization hook that registers the provider request validator with the data transfer module as the validator for StorageDataTransferVoucher types

func RetrievalClient added in v0.2.1 

func RetrievalClient(h host.Host, bs dtypes.ClientBlockstore, pmgr *paychmgr.Manager, payapi payapi.PaychAPI, resolver retrievalmarket.PeerResolver, ds dtypes.MetadataDS, chainapi full.ChainAPI) (retrievalmarket.RetrievalClient, error)

RetrievalClient creates a new retrieval client attached to the client blockstore

func RetrievalProvider added in v0.2.1 

func RetrievalProvider(h host.Host, miner *storage.Miner, sealer sectorstorage.SectorManager, full lapi.FullNode, ds dtypes.MetadataDS, pieceStore dtypes.ProviderPieceStore, ibs dtypes.StagingBlockstore) (retrievalmarket.RetrievalProvider, error)

RetrievalProvider creates a new retrieval provider attached to the provider blockstore

func RetrievalResolver 

func RetrievalResolver(l *discovery.Local) retrievalmarket.PeerResolver

func RunBlockSync 

func RunBlockSync(h host.Host, svc *blocksync.BlockSyncService)

func RunDealClient 

func RunDealClient(mctx helpers.MetricsCtx, lc fx.Lifecycle, c storagemarket.StorageClient)

func RunHello 

func RunHello(mctx helpers.MetricsCtx, lc fx.Lifecycle, h host.Host, svc *hello.Service) error

func RunPeerMgr 

func RunPeerMgr(mctx helpers.MetricsCtx, lc fx.Lifecycle, pmgr *peermgr.PeerMgr)

func SectorIDCounter added in v0.3.0 

func SectorIDCounter(ds dtypes.MetadataDS) sealing.SectorIDCounter

func SectorStorage added in v0.3.0 

func SectorStorage(mctx helpers.MetricsCtx, lc fx.Lifecycle, ls stores.LocalStorage, si stores.SectorIndex, cfg *ffiwrapper.Config, sc sectorstorage.SealerConfig, urls sectorstorage.URLs, sa sectorstorage.StorageAuth) (*sectorstorage.Manager, error)

func SetGenesis 

func SetGenesis(cs *store.ChainStore, g Genesis) (dtypes.AfterGenesisSet, error)

func SetupBlockProducer 

func SetupBlockProducer(lc fx.Lifecycle, ds dtypes.MetadataDS, api lapi.FullNode, epp gen.WinningPoStProver, beacon beacon.RandomBeacon) (*miner.Miner, error)

func StagingBlockstore added in v0.2.1 

func StagingBlockstore(r repo.LockedRepo) (dtypes.StagingBlockstore, error)

StagingBlockstore creates a blockstore for staging blocks for a miner in a storage deal, prior to sealing

func StagingDAG 

func StagingDAG(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.StagingBlockstore, rt routing.Routing, h host.Host) (dtypes.StagingDAG, error)

StagingDAG is a DAGService for the StagingBlockstore

func StagingGraphsync added in v0.2.1 

func StagingGraphsync(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.StagingBlockstore, h host.Host) dtypes.StagingGraphsync

StagingGraphsync creates a graphsync instance which reads and writes blocks to the StagingBlockstore

func StorageAuth added in v0.3.0 

func StorageAuth(ctx helpers.MetricsCtx, ca lapi.Common) (sectorstorage.StorageAuth, error)

func StorageClient added in v0.2.1 

func StorageClient(lc fx.Lifecycle, h host.Host, ibs dtypes.ClientBlockstore, r repo.LockedRepo, dataTransfer dtypes.ClientDataTransfer, discovery *discovery.Local, deals dtypes.ClientDatastore, scn storagemarket.StorageClientNode) (storagemarket.StorageClient, error)

func StorageMiner 

func StorageMiner(mctx helpers.MetricsCtx, lc fx.Lifecycle, api lapi.FullNode, h host.Host, ds dtypes.MetadataDS, sealer sectorstorage.SectorManager, sc sealing.SectorIDCounter, verif ffiwrapper.Verifier) (*storage.Miner, error)

func StorageNetworkName added in v0.3.0 

func StorageNetworkName(ctx helpers.MetricsCtx, a lapi.FullNode) (dtypes.NetworkName, error)

func StorageProvider added in v0.2.1 

func StorageProvider(ctx helpers.MetricsCtx, fapi lapi.FullNode, h host.Host, ds dtypes.MetadataDS, ibs dtypes.StagingBlockstore, r repo.LockedRepo, pieceStore dtypes.ProviderPieceStore, dataTransfer dtypes.ProviderDataTransfer, spn storagemarket.StorageProviderNode) (storagemarket.StorageProvider, error)

Types

type Genesis 

type Genesis func() (*types.BlockHeader, error)

func ErrorGenesis 

func ErrorGenesis() Genesis

Source Files

View all Source files

Directories

Path Synopsis

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.