web

Documentation

Index

• func MakeRPCServer(ctx context.Context, ribs ribs.RIBS) (*jsonrpc.RPCServer, jsonrpc.ClientCloser, error)
• func Serve(ctx context.Context, listen string, ribs ribs.RIBS) error
• type RIBSRpc
  • func (rc *RIBSRpc) CarUploadStats(ctx context.Context) (ribs.UploadStats, error)
  • func (rc *RIBSRpc) CrawlState(ctx context.Context) (ribs.CrawlState, error)
  • func (rc *RIBSRpc) DealSummary(ctx context.Context) (ribs.DealSummary, error)
  • func (rc *RIBSRpc) FindCid(ctx context.Context, hash cid.Cid) ([]ribs.GroupKey, error)
  • func (rc *RIBSRpc) GetGroupStats(ctx context.Context) (*ribs.GroupStats, error)
  • func (rc *RIBSRpc) GroupDeals(ctx context.Context, group ribs.GroupKey) ([]ribs.DealMeta, error)
  • func (rc *RIBSRpc) GroupIOStats(ctx context.Context) (ribs.GroupIOStats, error)
  • func (rc *RIBSRpc) GroupMeta(ctx context.Context, group ribs.GroupKey) (ribs.GroupMeta, error)
  • func (rc *RIBSRpc) Groups(ctx context.Context) ([]ribs.GroupKey, error)
  • func (rc *RIBSRpc) P2PNodes(ctx context.Context) (map[string]ribs.Libp2pInfo, error)
  • func (rc *RIBSRpc) ProviderInfo(ctx context.Context, id int64) (ribs.ProviderInfo, error)
  • func (rc *RIBSRpc) ReachableProviders(ctx context.Context) ([]ribs.ProviderMeta, error)
  • func (rc *RIBSRpc) RepairQueue() (ribs.RepairQueueStats, error)
  • func (rc *RIBSRpc) RepairStats() (map[int]ribs.RepairJob, error)
  • func (rc *RIBSRpc) RetrChecker() (ribs.RetrCheckerStats, error)
  • func (rc *RIBSRpc) RetrStats(ctx context.Context) (ribs.RetrStats, error)
  • func (rc *RIBSRpc) RetrievableDealCounts(ctx context.Context) ([]ribs.DealCountStats, error)
  • func (rc *RIBSRpc) RuntimeStats(ctx context.Context) (runtime.MemStats, error)
  • func (rc *RIBSRpc) SealedDealCounts(ctx context.Context) ([]ribs.DealCountStats, error)
  • func (rc *RIBSRpc) StagingStats(ctx context.Context) (ribs.StagingStats, error)
  • func (rc *RIBSRpc) TopIndexStats(ctx context.Context) (ribs.TopIndexStats, error)
  • func (rc *RIBSRpc) WalletInfo(ctx context.Context) (ribs.WalletInfo, error)
  • func (rc *RIBSRpc) WalletMarketAdd(ctx context.Context, amt abi.TokenAmount) (cid.Cid, error)
  • func (rc *RIBSRpc) WalletMarketWithdraw(ctx context.Context, amt abi.TokenAmount) (cid.Cid, error)
  • func (rc *RIBSRpc) WalletWithdraw(ctx context.Context, amt abi.TokenAmount, to address.Address) (cid.Cid, error)
  • func (rc *RIBSRpc) WorkerStats(ctx context.Context) (ribs.WorkerStats, error)
• type RIBSWeb
  • func (ri *RIBSWeb) Index(w http.ResponseWriter, r *http.Request)

Functions

func MakeRPCServer

func MakeRPCServer(ctx context.Context, ribs ribs.RIBS) (*jsonrpc.RPCServer, jsonrpc.ClientCloser, error)

func Serve

func Serve(ctx context.Context, listen string, ribs ribs.RIBS) error

Types

type RIBSRpc

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

func (*RIBSRpc) CarUploadStats

func (rc *RIBSRpc) CarUploadStats(ctx context.Context) (ribs.UploadStats, error)

func (*RIBSRpc) CrawlState

func (rc *RIBSRpc) CrawlState(ctx context.Context) (ribs.CrawlState, error)

func (*RIBSRpc) DealSummary

func (rc *RIBSRpc) DealSummary(ctx context.Context) (ribs.DealSummary, error)

func (*RIBSRpc) FindCid

func (rc *RIBSRpc) FindCid(ctx context.Context, hash cid.Cid) ([]ribs.GroupKey, error)

func (*RIBSRpc) GetGroupStats

func (rc *RIBSRpc) GetGroupStats(ctx context.Context) (*ribs.GroupStats, error)

func (*RIBSRpc) GroupDeals

func (rc *RIBSRpc) GroupDeals(ctx context.Context, group ribs.GroupKey) ([]ribs.DealMeta, error)

func (*RIBSRpc) GroupIOStats

func (rc *RIBSRpc) GroupIOStats(ctx context.Context) (ribs.GroupIOStats, error)

func (*RIBSRpc) GroupMeta

func (rc *RIBSRpc) GroupMeta(ctx context.Context, group ribs.GroupKey) (ribs.GroupMeta, error)

func (*RIBSRpc) Groups

func (rc *RIBSRpc) Groups(ctx context.Context) ([]ribs.GroupKey, error)

func (*RIBSRpc) P2PNodes

func (rc *RIBSRpc) P2PNodes(ctx context.Context) (map[string]ribs.Libp2pInfo, error)

func (*RIBSRpc) ProviderInfo

func (rc *RIBSRpc) ProviderInfo(ctx context.Context, id int64) (ribs.ProviderInfo, error)

func (*RIBSRpc) ReachableProviders

func (rc *RIBSRpc) ReachableProviders(ctx context.Context) ([]ribs.ProviderMeta, error)

func (*RIBSRpc) RepairQueue

func (rc *RIBSRpc) RepairQueue() (ribs.RepairQueueStats, error)

func (*RIBSRpc) RepairStats

func (rc *RIBSRpc) RepairStats() (map[int]ribs.RepairJob, error)

func (*RIBSRpc) RetrChecker

func (rc *RIBSRpc) RetrChecker() (ribs.RetrCheckerStats, error)

func (*RIBSRpc) RetrStats

func (rc *RIBSRpc) RetrStats(ctx context.Context) (ribs.RetrStats, error)

func (*RIBSRpc) RetrievableDealCounts

func (rc *RIBSRpc) RetrievableDealCounts(ctx context.Context) ([]ribs.DealCountStats, error)

func (*RIBSRpc) RuntimeStats

func (rc *RIBSRpc) RuntimeStats(ctx context.Context) (runtime.MemStats, error)

func (*RIBSRpc) SealedDealCounts

func (rc *RIBSRpc) SealedDealCounts(ctx context.Context) ([]ribs.DealCountStats, error)

func (*RIBSRpc) StagingStats

func (rc *RIBSRpc) StagingStats(ctx context.Context) (ribs.StagingStats, error)

func (*RIBSRpc) TopIndexStats

func (rc *RIBSRpc) TopIndexStats(ctx context.Context) (ribs.TopIndexStats, error)

func (*RIBSRpc) WalletInfo

func (rc *RIBSRpc) WalletInfo(ctx context.Context) (ribs.WalletInfo, error)

func (*RIBSRpc) WalletMarketAdd

func (rc *RIBSRpc) WalletMarketAdd(ctx context.Context, amt abi.TokenAmount) (cid.Cid, error)

func (*RIBSRpc) WalletMarketWithdraw

func (rc *RIBSRpc) WalletMarketWithdraw(ctx context.Context, amt abi.TokenAmount) (cid.Cid, error)

func (*RIBSRpc) WalletWithdraw

func (rc *RIBSRpc) WalletWithdraw(ctx context.Context, amt abi.TokenAmount, to address.Address) (cid.Cid, error)

func (*RIBSRpc) WorkerStats

func (rc *RIBSRpc) WorkerStats(ctx context.Context) (ribs.WorkerStats, error)

type RIBSWeb

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

func (*RIBSWeb) Index

func (ri *RIBSWeb) Index(w http.ResponseWriter, r *http.Request)