cliutil

package

v0.0.0-...-484cccf Latest Latest Go to latest Published: Mar 16, 2023 License: Apache-2.0, MIT Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zelin44913/lotus1203

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func ApiAddrToUrl(apiAddr string) (*url.URL, error)
func ClientExportStream(apiAddr string, apiAuth http.Header, eref api.ExportRef, car bool) (io.ReadCloser, error)
func DaemonContext(cctx *cli.Context) context.Context
func EpochTime(curr, e abi.ChainEpoch) string
func EpochTimeTs(curr, e abi.ChainEpoch, ts *types.TipSet) string
func FullNodeProxy[T api.FullNode](ins []T, outstr *api.FullNodeStruct)
func GetCommonAPI(ctx *cli.Context) (api.CommonNet, jsonrpc.ClientCloser, error)
func GetFullNodeAPI(ctx *cli.Context) (v0api.FullNode, jsonrpc.ClientCloser, error)
func GetFullNodeAPIV1(ctx *cli.Context, opts ...GetFullNodeOption) (v1api.FullNode, jsonrpc.ClientCloser, error)
func GetFullNodeAPIV1Single(ctx *cli.Context) (v1api.FullNode, jsonrpc.ClientCloser, error)
func GetGatewayAPI(ctx *cli.Context) (api.Gateway, jsonrpc.ClientCloser, error)
func GetGatewayAPIV0(ctx *cli.Context) (v0api.Gateway, jsonrpc.ClientCloser, error)
func GetMarketsAPI(ctx *cli.Context) (api.StorageMiner, jsonrpc.ClientCloser, error)
func GetRawAPI(ctx *cli.Context, t repo.RepoType, version string) (string, http.Header, error)
func GetStorageMinerAPI(ctx *cli.Context, opts ...GetStorageMinerOption) (api.StorageMiner, jsonrpc.ClientCloser, error)
func GetWorkerAPI(ctx *cli.Context) (api.Worker, jsonrpc.ClientCloser, error)
func OnSingleNode(ctx context.Context) context.Context
func ReqContext(cctx *cli.Context) context.Context
func StorageMinerUseHttp(opts *GetStorageMinerOptions)
type APIInfo
- func GetAPIInfo(ctx *cli.Context, t repo.RepoType) (APIInfo, error)
- func GetAPIInfoMulti(ctx *cli.Context, t repo.RepoType) ([]APIInfo, error)
- func ParseApiInfo(s string) APIInfo
- func ParseApiInfoMulti(s string) []APIInfo
- func (a APIInfo) AuthHeader() http.Header
- func (a APIInfo) DialArgs(version string) (string, error)
- func (a APIInfo) Host() (string, error)
type GetFullNodeOption
- func FullNodeWithEthSubscribtionHandler(sh api.EthSubscriber) GetFullNodeOption
type GetFullNodeOptions
type GetStorageMinerOption
type GetStorageMinerOptions
type HttpHead
- func GetRawAPIMulti(ctx *cli.Context, t repo.RepoType, version string) ([]HttpHead, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var FlagVeryVerbose = &cli.BoolFlag{
	Name:        "vv",
	Usage:       "enables very verbose mode, useful for debugging the CLI",
	Destination: &IsVeryVerbose,
}

FlagVeryVerbose enables very verbose mode, which is useful when debugging the CLI itself. It should be included as a flag on the top-level command (e.g. lotus -vv, lotus-miner -vv).

View Source

var IsVeryVerbose bool

IsVeryVerbose is a global var signalling if the CLI is running in very verbose mode or not (default: false).

Functions ¶

func ApiAddrToUrl ¶

func ApiAddrToUrl(apiAddr string) (*url.URL, error)

func ClientExportStream ¶

func ClientExportStream(apiAddr string, apiAuth http.Header, eref api.ExportRef, car bool) (io.ReadCloser, error)

func DaemonContext ¶

func DaemonContext(cctx *cli.Context) context.Context

func EpochTime ¶

func EpochTime(curr, e abi.ChainEpoch) string

func EpochTimeTs ¶

func EpochTimeTs(curr, e abi.ChainEpoch, ts *types.TipSet) string

EpochTimeTs is like EpochTime, but also outputs absolute time. `ts` is only used to provide a timestamp at some epoch to calculate time from. It can be a genesis tipset.

Example output: `1944975 (01 Jul 22 08:07 CEST, 10 hours 29 minutes ago)`

func FullNodeProxy ¶

func FullNodeProxy[T api.FullNode](ins []T, outstr *api.FullNodeStruct)

func GetCommonAPI ¶

func GetCommonAPI(ctx *cli.Context) (api.CommonNet, jsonrpc.ClientCloser, error)

func GetFullNodeAPI ¶

func GetFullNodeAPI(ctx *cli.Context) (v0api.FullNode, jsonrpc.ClientCloser, error)

func GetFullNodeAPIV1 ¶

func GetFullNodeAPIV1(ctx *cli.Context, opts ...GetFullNodeOption) (v1api.FullNode, jsonrpc.ClientCloser, error)

func GetFullNodeAPIV1Single ¶

func GetFullNodeAPIV1Single(ctx *cli.Context) (v1api.FullNode, jsonrpc.ClientCloser, error)

func GetGatewayAPI ¶

func GetGatewayAPI(ctx *cli.Context) (api.Gateway, jsonrpc.ClientCloser, error)

func GetGatewayAPIV0 ¶

func GetGatewayAPIV0(ctx *cli.Context) (v0api.Gateway, jsonrpc.ClientCloser, error)

func GetMarketsAPI ¶

func GetMarketsAPI(ctx *cli.Context) (api.StorageMiner, jsonrpc.ClientCloser, error)

func GetRawAPI ¶

func GetRawAPI(ctx *cli.Context, t repo.RepoType, version string) (string, http.Header, error)

func GetStorageMinerAPI ¶

func GetStorageMinerAPI(ctx *cli.Context, opts ...GetStorageMinerOption) (api.StorageMiner, jsonrpc.ClientCloser, error)

func GetWorkerAPI ¶

func GetWorkerAPI(ctx *cli.Context) (api.Worker, jsonrpc.ClientCloser, error)

func OnSingleNode ¶

func OnSingleNode(ctx context.Context) context.Context

Not thread safe

func ReqContext ¶

func ReqContext(cctx *cli.Context) context.Context

ReqContext returns context for cli execution. Calling it for the first time installs SIGTERM handler that will close returned context. Not safe for concurrent execution.

func StorageMinerUseHttp ¶

func StorageMinerUseHttp(opts *GetStorageMinerOptions)

Types ¶

type APIInfo ¶

type APIInfo struct {
	Addr  string
	Token []byte
}

func GetAPIInfo ¶

func GetAPIInfo(ctx *cli.Context, t repo.RepoType) (APIInfo, error)

func GetAPIInfoMulti ¶

func GetAPIInfoMulti(ctx *cli.Context, t repo.RepoType) ([]APIInfo, error)

GetAPIInfo returns the API endpoint to use for the specified kind of repo.

The order of precedence is as follows:

*-api-url command line flags.
*_API_INFO environment variables
deprecated *_API_INFO environment variables
*-repo command line flags.

func ParseApiInfo ¶

func ParseApiInfo(s string) APIInfo

func ParseApiInfoMulti ¶

func ParseApiInfoMulti(s string) []APIInfo

func (APIInfo) AuthHeader ¶

func (a APIInfo) AuthHeader() http.Header

func (APIInfo) DialArgs ¶

func (a APIInfo) DialArgs(version string) (string, error)

func (APIInfo) Host ¶

func (a APIInfo) Host() (string, error)

type GetFullNodeOption ¶

type GetFullNodeOption func(*GetFullNodeOptions)

func FullNodeWithEthSubscribtionHandler ¶

func FullNodeWithEthSubscribtionHandler(sh api.EthSubscriber) GetFullNodeOption

type GetFullNodeOptions ¶

type GetFullNodeOptions struct {
	// contains filtered or unexported fields
}

type GetStorageMinerOption ¶

type GetStorageMinerOption func(*GetStorageMinerOptions)

type GetStorageMinerOptions ¶

type GetStorageMinerOptions struct {
	PreferHttp bool
}

type HttpHead ¶

type HttpHead struct {
	// contains filtered or unexported fields
}

func GetRawAPIMulti ¶

func GetRawAPIMulti(ctx *cli.Context, t repo.RepoType, version string) ([]HttpHead, error)

Source Files ¶

View all Source files

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