gql

Documentation

Index

• Constants
• Variables
• func NewResolver(cfg *config.Boost, r lotus_repo.LockedRepo, h host.Host, dealsDB *db.DealsDB, ...) *resolver
• type BlockGetter
• type IndexStatus
• type Server
  • func NewServer(resolver *resolver, bstore BlockGetter) *Server
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error

Constants

const DummyDealsDir = "/tmp/dummy"

const DummyDealsPrefix = "dummy"

Variables

var DummyDealsBase string

Functions

func NewResolver

func NewResolver(cfg *config.Boost, r lotus_repo.LockedRepo, h host.Host, dealsDB *db.DealsDB, logsDB *db.LogsDB, retDB *rtvllog.RetrievalLogDB, plDB *db.ProposalLogsDB, fundsDB *db.FundsDB, fundMgr *fundmanager.FundManager, storageMgr *storagemanager.StorageManager, spApi sealingpipeline.API, provider *storagemarket.Provider, legacyProv gfm_storagemarket.StorageProvider, legacyDT dtypes.ProviderDataTransfer, ps piecestore.PieceStore, sa retrievalmarket.SectorAccessor, dagst dagstore.Interface, publisher *storageadapter.DealPublisher, fullNode v1api.FullNode, mpool *mpoolmonitor.MpoolMonitor) *resolver

Types

type BlockGetter

type BlockGetter interface {
	Get(context.Context, cid.Cid) (blocks.Block, error)
}

type IndexStatus

type IndexStatus string

const (
	IndexStatusUnknown    IndexStatus = ""
	IndexStatusNotFound   IndexStatus = "NotFound"
	IndexStatusRegistered IndexStatus = "Registered"
	IndexStatusComplete   IndexStatus = "Complete"
	IndexStatusFailed     IndexStatus = "Failed"
)

type Server

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

func NewServer

func NewServer(resolver *resolver, bstore BlockGetter) *Server

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error