deps

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

const (
	FlagRepoPath = "repo-path"
)

Variables

var RPCErrors = jsonrpc.NewErrors()

Functions

func CreateMinerConfig

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

func ErrorIsIn

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

func FullNodeProxy

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

FullNodeProxy creates a proxy for the Chain API

func GetAPI

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

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

func OnSingleNode(ctx context.Context) context.Context

OnSingleNode returns a new context that will try to perform all calls on the same node. If the backing node fails, the calls will be retried on a different node, and further calls will be made on that node. Not thread safe

func Retry

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

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
}