rpc

Documentation

Overview

Package rpc provides all direct access to this node.

Index

• func CurioHandler(authv func(ctx context.Context, token string) ([]auth.Permission, error), ...) http.Handler
• func GetCurioAPI(ctx *cli.Context) (api.Curio, jsonrpc.ClientCloser, error)
• func ListenAndServe(ctx context.Context, dependencies *deps.Deps, shutdownChan chan struct{}) error
• type CurioAPI
  • func (p *CurioAPI) AllocatePieceToSector(ctx context.Context, maddr address.Address, piece piece.PieceDealInfo, ...) (lapi.SectorOffset, error)
  • func (p *CurioAPI) Cordon(ctx context.Context) error
  • func (p *CurioAPI) Info(ctx context.Context) (*ltypes.NodeInfo, error)
  • func (p *CurioAPI) LogList(ctx context.Context) ([]string, error)
  • func (p *CurioAPI) LogSetLevel(ctx context.Context, subsystem, level string) error
  • func (p *CurioAPI) Shutdown(context.Context) error
  • func (p *CurioAPI) StorageAddLocal(ctx context.Context, path string) error
  • func (p *CurioAPI) StorageDetachLocal(ctx context.Context, path string) error
  • func (p *CurioAPI) StorageInit(ctx context.Context, path string, opts storiface.LocalStorageMeta) error
  • func (p *CurioAPI) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)
  • func (p *CurioAPI) StorageStat(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)
  • func (p *CurioAPI) Uncordon(ctx context.Context) error
  • func (p *CurioAPI) Version(context.Context) ([]int, error)

Functions

func CurioHandler

func CurioHandler(
	authv func(ctx context.Context, token string) ([]auth.Permission, error),
	remote http.HandlerFunc,
	a api.Curio,
	permissioned bool) http.Handler

func GetCurioAPI

func GetCurioAPI(ctx *cli.Context) (api.Curio, jsonrpc.ClientCloser, error)

func ListenAndServe

func ListenAndServe(ctx context.Context, dependencies *deps.Deps, shutdownChan chan struct{}) error

Types

type CurioAPI

type CurioAPI struct {
	*deps.Deps
	paths.SectorIndex
	ShutdownChan chan struct{}
}

func (*CurioAPI) AllocatePieceToSector

func (p *CurioAPI) AllocatePieceToSector(ctx context.Context, maddr address.Address, piece piece.PieceDealInfo, rawSize int64, source url.URL, header http.Header) (lapi.SectorOffset, error)

this method is currently unused, might be back when we get markets into curio

func (*CurioAPI) Cordon

func (p *CurioAPI) Cordon(ctx context.Context) error

func (*CurioAPI) Info

func (p *CurioAPI) Info(ctx context.Context) (*ltypes.NodeInfo, error)

func (*CurioAPI) LogList

func (p *CurioAPI) LogList(ctx context.Context) ([]string, error)

func (*CurioAPI) LogSetLevel

func (p *CurioAPI) LogSetLevel(ctx context.Context, subsystem, level string) error

func (*CurioAPI) Shutdown

func (p *CurioAPI) Shutdown(context.Context) error

Trigger shutdown

func (*CurioAPI) StorageAddLocal

func (p *CurioAPI) StorageAddLocal(ctx context.Context, path string) error

func (*CurioAPI) StorageDetachLocal

func (p *CurioAPI) StorageDetachLocal(ctx context.Context, path string) error

func (*CurioAPI) StorageInit

func (p *CurioAPI) StorageInit(ctx context.Context, path string, opts storiface.LocalStorageMeta) error

func (*CurioAPI) StorageLocal

func (p *CurioAPI) StorageLocal(ctx context.Context) (map[storiface.ID]string, error)

func (*CurioAPI) StorageStat

func (p *CurioAPI) StorageStat(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)

func (*CurioAPI) Uncordon

func (p *CurioAPI) Uncordon(ctx context.Context) error

func (*CurioAPI) Version

func (p *CurioAPI) Version(context.Context) ([]int, error)