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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeRPCServer ¶
Types ¶
type RIBSRpc ¶
type RIBSRpc struct {
// contains filtered or unexported fields
}
func (*RIBSRpc) CarUploadStats ¶
func (*RIBSRpc) CrawlState ¶
func (*RIBSRpc) DealSummary ¶
func (*RIBSRpc) GetGroupStats ¶
func (*RIBSRpc) GroupDeals ¶
func (*RIBSRpc) GroupIOStats ¶
func (*RIBSRpc) ProviderInfo ¶
func (*RIBSRpc) ReachableProviders ¶
func (*RIBSRpc) RepairQueue ¶
func (rc *RIBSRpc) RepairQueue() (ribs.RepairQueueStats, error)
func (*RIBSRpc) RetrChecker ¶
func (rc *RIBSRpc) RetrChecker() (ribs.RetrCheckerStats, error)
func (*RIBSRpc) RetrievableDealCounts ¶
func (*RIBSRpc) RuntimeStats ¶
func (*RIBSRpc) SealedDealCounts ¶
func (*RIBSRpc) StagingStats ¶
func (*RIBSRpc) TopIndexStats ¶
func (*RIBSRpc) WalletInfo ¶
func (*RIBSRpc) WalletMarketAdd ¶
func (*RIBSRpc) WalletMarketWithdraw ¶
func (*RIBSRpc) WalletWithdraw ¶
func (*RIBSRpc) WorkerStats ¶
Click to show internal directories.
Click to hide internal directories.