curiorpc

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotSupported = xerrors.New("method not supported")

Functions

func WebRPCProxy 

func WebRPCProxy[T WebRPC](ins []T, outStr *WebRPCStruct)

Types

type WebRPC 

type WebRPC interface {
	ActorSectorExpirations(ctx context.Context, maddr address.Address) (*webrpc.SectorExpirations, error)
	ActorSummary(ctx context.Context) ([]webrpc.ActorSummary, error)
	ActorList(ctx context.Context) ([]string, error)
	ClusterMachines(ctx context.Context) ([]webrpc.MachineSummary, error)
	ClusterTaskHistory(ctx context.Context) ([]webrpc.TaskHistorySummary, error)
	ClusterNodeInfo(ctx context.Context, id int64) (*webrpc.MachineInfo, error)
	DealsPending(ctx context.Context) ([]webrpc.OpenDealInfo, error)
	DealsSealNow(ctx context.Context, spID, sectorNumber uint64) error
	HarmonyTaskStats(ctx context.Context) ([]webrpc.HarmonyTaskStats, error)
	HarmonyTaskMachines(ctx context.Context, taskName string) ([]webrpc.HarmonyMachineDesc, error)
	HarmonyTaskHistory(ctx context.Context, taskName string) ([]webrpc.HarmonyTaskHistory, error)
	PipelinePorepSectors(ctx context.Context) ([]sectorListEntry, error)
	PorepPipelineSummary(ctx context.Context) ([]webrpc.PorepPipelineSummary, error)
	SectorInfo(ctx context.Context, sp string, intid int64) (*webrpc.SectorInfo, error)
	SectorRemove(ctx context.Context, spid, id int) error
	StorageUseStats(ctx context.Context) ([]webrpc.StorageUseStats, error)
	StorageGCMarks(ctx context.Context) ([]webrpc.StorageGCMarks, error)
	StorageGCApprove(ctx context.Context, actor int64, sectorNum int64, fileType int64, storageID string) error
	StorageGCApproveAll(ctx context.Context) error
	StorageGCUnapproveAll(ctx context.Context) error
	SyncerState(ctx context.Context) ([]webrpc.RpcInfo, error)
	ClusterTaskSummary(ctx context.Context) ([]webrpc.TaskSummary, error)
	UpgradeSectors(ctx context.Context) ([]webrpc.UpgradeSector, error)
	UpgradeResetTaskIDs(ctx context.Context, spid, sectorNum uint64) error
	UpgradeDelete(ctx context.Context, spid, sectorNum uint64) error
	WinStats(ctx context.Context) ([]webrpc.WinStats, error)
}

func NewWebRPCV0 

func NewWebRPCV0(ctx context.Context, addr string, requestHeader http.Header) (WebRPC, jsonrpc.ClientCloser, error)

type WebRPCMethods 

type WebRPCMethods struct {
	ActorList func(p0 context.Context) ([]string, error) ``

	ActorSectorExpirations func(p0 context.Context, p1 address.Address) (*webrpc.SectorExpirations, error) ``

	ActorSummary func(p0 context.Context) ([]webrpc.ActorSummary, error) ``

	ClusterMachines func(p0 context.Context) ([]webrpc.MachineSummary, error) ``

	ClusterNodeInfo func(p0 context.Context, p1 int64) (*webrpc.MachineInfo, error) ``

	ClusterTaskHistory func(p0 context.Context) ([]webrpc.TaskHistorySummary, error) ``

	ClusterTaskSummary func(p0 context.Context) ([]webrpc.TaskSummary, error) ``

	DealsPending func(p0 context.Context) ([]webrpc.OpenDealInfo, error) ``

	DealsSealNow func(p0 context.Context, p1 uint64, p2 uint64) error ``

	HarmonyTaskHistory func(p0 context.Context, p1 string) ([]webrpc.HarmonyTaskHistory, error) ``

	HarmonyTaskMachines func(p0 context.Context, p1 string) ([]webrpc.HarmonyMachineDesc, error) ``

	HarmonyTaskStats func(p0 context.Context) ([]webrpc.HarmonyTaskStats, error) ``

	PipelinePorepSectors func(p0 context.Context) ([]sectorListEntry, error) ``

	PorepPipelineSummary func(p0 context.Context) ([]webrpc.PorepPipelineSummary, error) ``

	SectorInfo func(p0 context.Context, p1 string, p2 int64) (*webrpc.SectorInfo, error) ``

	SectorRemove func(p0 context.Context, p1 int, p2 int) error ``

	StorageGCApprove func(p0 context.Context, p1 int64, p2 int64, p3 int64, p4 string) error ``

	StorageGCApproveAll func(p0 context.Context) error ``

	StorageGCMarks func(p0 context.Context) ([]webrpc.StorageGCMarks, error) ``

	StorageGCUnapproveAll func(p0 context.Context) error ``

	StorageUseStats func(p0 context.Context) ([]webrpc.StorageUseStats, error) ``

	SyncerState func(p0 context.Context) ([]webrpc.RpcInfo, error) ``

	UpgradeDelete func(p0 context.Context, p1 uint64, p2 uint64) error ``

	UpgradeResetTaskIDs func(p0 context.Context, p1 uint64, p2 uint64) error ``

	UpgradeSectors func(p0 context.Context) ([]webrpc.UpgradeSector, error) ``

	WinStats func(p0 context.Context) ([]webrpc.WinStats, error) ``
}

type WebRPCStruct 

type WebRPCStruct struct {
	Internal WebRPCMethods
}

func (*WebRPCStruct) ActorList 

func (s *WebRPCStruct) ActorList(p0 context.Context) ([]string, error)

func (*WebRPCStruct) ActorSectorExpirations 

func (s *WebRPCStruct) ActorSectorExpirations(p0 context.Context, p1 address.Address) (*webrpc.SectorExpirations, error)

func (*WebRPCStruct) ActorSummary 

func (s *WebRPCStruct) ActorSummary(p0 context.Context) ([]webrpc.ActorSummary, error)

func (*WebRPCStruct) ClusterMachines 

func (s *WebRPCStruct) ClusterMachines(p0 context.Context) ([]webrpc.MachineSummary, error)

func (*WebRPCStruct) ClusterNodeInfo 

func (s *WebRPCStruct) ClusterNodeInfo(p0 context.Context, p1 int64) (*webrpc.MachineInfo, error)

func (*WebRPCStruct) ClusterTaskHistory 

func (s *WebRPCStruct) ClusterTaskHistory(p0 context.Context) ([]webrpc.TaskHistorySummary, error)

func (*WebRPCStruct) ClusterTaskSummary 

func (s *WebRPCStruct) ClusterTaskSummary(p0 context.Context) ([]webrpc.TaskSummary, error)

func (*WebRPCStruct) DealsPending 

func (s *WebRPCStruct) DealsPending(p0 context.Context) ([]webrpc.OpenDealInfo, error)

func (*WebRPCStruct) DealsSealNow 

func (s *WebRPCStruct) DealsSealNow(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStruct) HarmonyTaskHistory 

func (s *WebRPCStruct) HarmonyTaskHistory(p0 context.Context, p1 string) ([]webrpc.HarmonyTaskHistory, error)

func (*WebRPCStruct) HarmonyTaskMachines 

func (s *WebRPCStruct) HarmonyTaskMachines(p0 context.Context, p1 string) ([]webrpc.HarmonyMachineDesc, error)

func (*WebRPCStruct) HarmonyTaskStats 

func (s *WebRPCStruct) HarmonyTaskStats(p0 context.Context) ([]webrpc.HarmonyTaskStats, error)

func (*WebRPCStruct) PipelinePorepSectors 

func (s *WebRPCStruct) PipelinePorepSectors(p0 context.Context) ([]sectorListEntry, error)

func (*WebRPCStruct) PorepPipelineSummary 

func (s *WebRPCStruct) PorepPipelineSummary(p0 context.Context) ([]webrpc.PorepPipelineSummary, error)

func (*WebRPCStruct) SectorInfo 

func (s *WebRPCStruct) SectorInfo(p0 context.Context, p1 string, p2 int64) (*webrpc.SectorInfo, error)

func (*WebRPCStruct) SectorRemove 

func (s *WebRPCStruct) SectorRemove(p0 context.Context, p1 int, p2 int) error

func (*WebRPCStruct) StorageGCApprove 

func (s *WebRPCStruct) StorageGCApprove(p0 context.Context, p1 int64, p2 int64, p3 int64, p4 string) error

func (*WebRPCStruct) StorageGCApproveAll 

func (s *WebRPCStruct) StorageGCApproveAll(p0 context.Context) error

func (*WebRPCStruct) StorageGCMarks 

func (s *WebRPCStruct) StorageGCMarks(p0 context.Context) ([]webrpc.StorageGCMarks, error)

func (*WebRPCStruct) StorageGCUnapproveAll 

func (s *WebRPCStruct) StorageGCUnapproveAll(p0 context.Context) error

func (*WebRPCStruct) StorageUseStats 

func (s *WebRPCStruct) StorageUseStats(p0 context.Context) ([]webrpc.StorageUseStats, error)

func (*WebRPCStruct) SyncerState 

func (s *WebRPCStruct) SyncerState(p0 context.Context) ([]webrpc.RpcInfo, error)

func (*WebRPCStruct) UpgradeDelete 

func (s *WebRPCStruct) UpgradeDelete(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStruct) UpgradeResetTaskIDs 

func (s *WebRPCStruct) UpgradeResetTaskIDs(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStruct) UpgradeSectors 

func (s *WebRPCStruct) UpgradeSectors(p0 context.Context) ([]webrpc.UpgradeSector, error)

func (*WebRPCStruct) WinStats 

func (s *WebRPCStruct) WinStats(p0 context.Context) ([]webrpc.WinStats, error)

type WebRPCStub 

type WebRPCStub struct {
}

func (*WebRPCStub) ActorList 

func (s *WebRPCStub) ActorList(p0 context.Context) ([]string, error)

func (*WebRPCStub) ActorSectorExpirations 

func (s *WebRPCStub) ActorSectorExpirations(p0 context.Context, p1 address.Address) (*webrpc.SectorExpirations, error)

func (*WebRPCStub) ActorSummary 

func (s *WebRPCStub) ActorSummary(p0 context.Context) ([]webrpc.ActorSummary, error)

func (*WebRPCStub) ClusterMachines 

func (s *WebRPCStub) ClusterMachines(p0 context.Context) ([]webrpc.MachineSummary, error)

func (*WebRPCStub) ClusterNodeInfo 

func (s *WebRPCStub) ClusterNodeInfo(p0 context.Context, p1 int64) (*webrpc.MachineInfo, error)

func (*WebRPCStub) ClusterTaskHistory 

func (s *WebRPCStub) ClusterTaskHistory(p0 context.Context) ([]webrpc.TaskHistorySummary, error)

func (*WebRPCStub) ClusterTaskSummary 

func (s *WebRPCStub) ClusterTaskSummary(p0 context.Context) ([]webrpc.TaskSummary, error)

func (*WebRPCStub) DealsPending 

func (s *WebRPCStub) DealsPending(p0 context.Context) ([]webrpc.OpenDealInfo, error)

func (*WebRPCStub) DealsSealNow 

func (s *WebRPCStub) DealsSealNow(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStub) HarmonyTaskHistory 

func (s *WebRPCStub) HarmonyTaskHistory(p0 context.Context, p1 string) ([]webrpc.HarmonyTaskHistory, error)

func (*WebRPCStub) HarmonyTaskMachines 

func (s *WebRPCStub) HarmonyTaskMachines(p0 context.Context, p1 string) ([]webrpc.HarmonyMachineDesc, error)

func (*WebRPCStub) HarmonyTaskStats 

func (s *WebRPCStub) HarmonyTaskStats(p0 context.Context) ([]webrpc.HarmonyTaskStats, error)

func (*WebRPCStub) PipelinePorepSectors 

func (s *WebRPCStub) PipelinePorepSectors(p0 context.Context) ([]sectorListEntry, error)

func (*WebRPCStub) PorepPipelineSummary 

func (s *WebRPCStub) PorepPipelineSummary(p0 context.Context) ([]webrpc.PorepPipelineSummary, error)

func (*WebRPCStub) SectorInfo 

func (s *WebRPCStub) SectorInfo(p0 context.Context, p1 string, p2 int64) (*webrpc.SectorInfo, error)

func (*WebRPCStub) SectorRemove 

func (s *WebRPCStub) SectorRemove(p0 context.Context, p1 int, p2 int) error

func (*WebRPCStub) StorageGCApprove 

func (s *WebRPCStub) StorageGCApprove(p0 context.Context, p1 int64, p2 int64, p3 int64, p4 string) error

func (*WebRPCStub) StorageGCApproveAll 

func (s *WebRPCStub) StorageGCApproveAll(p0 context.Context) error

func (*WebRPCStub) StorageGCMarks 

func (s *WebRPCStub) StorageGCMarks(p0 context.Context) ([]webrpc.StorageGCMarks, error)

func (*WebRPCStub) StorageGCUnapproveAll 

func (s *WebRPCStub) StorageGCUnapproveAll(p0 context.Context) error

func (*WebRPCStub) StorageUseStats 

func (s *WebRPCStub) StorageUseStats(p0 context.Context) ([]webrpc.StorageUseStats, error)

func (*WebRPCStub) SyncerState 

func (s *WebRPCStub) SyncerState(p0 context.Context) ([]webrpc.RpcInfo, error)

func (*WebRPCStub) UpgradeDelete 

func (s *WebRPCStub) UpgradeDelete(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStub) UpgradeResetTaskIDs 

func (s *WebRPCStub) UpgradeResetTaskIDs(p0 context.Context, p1 uint64, p2 uint64) error

func (*WebRPCStub) UpgradeSectors 

func (s *WebRPCStub) UpgradeSectors(p0 context.Context) ([]webrpc.UpgradeSector, error)

func (*WebRPCStub) WinStats 

func (s *WebRPCStub) WinStats(p0 context.Context) ([]webrpc.WinStats, error)

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.