deps

package

v1.24.0 Latest Latest Go to latest Published: Oct 21, 2024 License: Apache-2.0, MIT Imports: 47 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/filecoin-project/curio

Links

Open Source Insights

Documentation ¶

Overview ¶

Package deps provides the dependencies for the curio node.

Index ¶

Constants
Variables
func CreateMinerConfig(ctx context.Context, full CreateMinerConfigChainAPI, db *harmonydb.DB, ...) error
func ErrorIsIn(err error, errorTypes []error) bool
func FullNodeProxy[T api.Chain](ins []T, outstr *api.ChainStruct)
func GetAPI(ctx context.Context, cctx *cli.Context) (*harmonydb.DB, *config.CurioConfig, api.Chain, jsonrpc.ClientCloser, error)
func GetConfig(ctx context.Context, layers []string, db *harmonydb.DB) (*config.CurioConfig, error)
func GetDefaultConfig(comment bool) (string, error)
func GetFullNodeAPIV1Curio(ctx *cli.Context, ainfoCfg []string) (api.Chain, jsonrpc.ClientCloser, error)
func LoadConfigWithUpgrades(text string, curioConfigWithDefaults *config.CurioConfig) (toml.MetaData, error)
func MakeDB(cctx *cli.Context) (*harmonydb.DB, error)
func OnSingleNode(ctx context.Context) context.Context
func Retry[T any](ctx context.Context, attempts int, initialBackoff time.Duration, ...) (result T, err error)
func StorageAuth(apiKey string) (sealer.StorageAuth, error)
type CreateMinerConfigChainAPI
type Deps
- func GetDeps(ctx context.Context, cctx *cli.Context) (*Deps, error)
- func GetDepsCLI(ctx context.Context, cctx *cli.Context) (*Deps, error)
- func (deps *Deps) PopulateRemainingDeps(ctx context.Context, cctx *cli.Context, makeRepo bool) error
type JwtPayload

Constants ¶

View Source

const (
	FlagRepoPath = "repo-path"
)

Variables ¶

View Source

var RPCErrors = jsonrpc.NewErrors()

Functions ¶

func CreateMinerConfig ¶

func CreateMinerConfig(ctx context.Context, full CreateMinerConfigChainAPI, db *harmonydb.DB, miners []string, info string) error

func ErrorIsIn ¶ added in v1.24.0

func ErrorIsIn(err error, errorTypes []error) bool

func FullNodeProxy ¶ added in v1.22.1

func FullNodeProxy[T api.Chain](ins []T, outstr *api.ChainStruct)

FullNodeProxy creates a proxy for the Chain API

func GetAPI ¶ added in v1.23.0

func GetAPI(ctx context.Context, cctx *cli.Context) (*harmonydb.DB, *config.CurioConfig, api.Chain, jsonrpc.ClientCloser, error)

func GetConfig ¶

func GetConfig(ctx context.Context, layers []string, db *harmonydb.DB) (*config.CurioConfig, error)

func GetDefaultConfig ¶

func GetDefaultConfig(comment bool) (string, error)

func GetFullNodeAPIV1Curio ¶ added in v1.23.0

func GetFullNodeAPIV1Curio(ctx *cli.Context, ainfoCfg []string) (api.Chain, jsonrpc.ClientCloser, error)

func LoadConfigWithUpgrades ¶

func LoadConfigWithUpgrades(text string, curioConfigWithDefaults *config.CurioConfig) (toml.MetaData, error)

func MakeDB ¶

func MakeDB(cctx *cli.Context) (*harmonydb.DB, error)

func OnSingleNode ¶ added in v1.22.1

func OnSingleNode(ctx context.Context) context.Context

Not thread safe

func Retry ¶ added in v1.24.0

func Retry[T any](ctx context.Context, attempts int, initialBackoff time.Duration, errorTypes []error, f func(isRetry bool) (T, error)) (result T, err error)

func StorageAuth ¶

func StorageAuth(apiKey string) (sealer.StorageAuth, error)

Types ¶

type CreateMinerConfigChainAPI ¶ added in v1.23.0

type CreateMinerConfigChainAPI interface {
	StateMinerInfo(context.Context, address.Address, types.TipSetKey) (lapi.MinerInfo, error)
}

type Deps ¶

type Deps struct {
	Layers     []string
	Cfg        *config.CurioConfig // values
	DB         *harmonydb.DB       // has itest capability
	Chain      api.Chain
	Bstore     curiochain.CurioBlockstore
	Verif      storiface.Verifier
	As         *multictladdr.MultiAddressSelector
	Maddrs     map[dtypes.MinerAddress]bool
	ProofTypes map[abi.RegisteredSealProof]bool
	Stor       *paths.Remote
	Al         *curioalerting.AlertingSystem
	Si         paths.SectorIndex
	LocalStore *paths.Local
	LocalPaths *paths.BasicLocalStorage
	ListenAddr string
	Name       string
	Alert      *alertmanager.AlertNow
}

func GetDeps ¶

func GetDeps(ctx context.Context, cctx *cli.Context) (*Deps, error)

func GetDepsCLI ¶

func GetDepsCLI(ctx context.Context, cctx *cli.Context) (*Deps, error)

func (*Deps) PopulateRemainingDeps ¶

func (deps *Deps) PopulateRemainingDeps(ctx context.Context, cctx *cli.Context, makeRepo bool) error

type JwtPayload ¶

type JwtPayload struct {
	Allow []auth.Permission
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config
cfgdocgen command

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL