node

Documentation

Overview

Package node contains the main executable for go-spacemesh node

Index

• Constants
• func GetCommand() *cobra.Command
• func LoadConfig(cfg *config.Config, preset string, src io.Reader) error
• func WithErrorUnused() viper.DecoderConfigOption
• func WithIgnoreUntagged() viper.DecoderConfigOption
• func WithZeroFields() viper.DecoderConfigOption
• type App
  • func New(opts ...Option) *App
  • func NewApp(tb testing.TB, conf *config.Config, l log.Log) *App
  • func (app *App) Cleanup(ctx context.Context)
  • func (app *App) Host() *p2p.Host
  • func (app *App) Initialize() error
  • func (app *App) LoadIdentities() error
  • func (app *App) Lock() error
  • func (app *App) NewIdentity() error
  • func (app *App) SetLogLevel(name, loglevel string) error
  • func (app *App) Start(ctx context.Context) error
  • func (app *App) Started() <-chan struct{}
  • func (app *App) Unlock()
• type Option
  • func WithConfig(conf *config.Config) Option
  • func WithLog(logger log.Log) Option
• type TestApp
  • func NewTestNetwork(tb testing.TB, conf config.Config, l log.Log, size int) []*TestApp

Constants

const (
	ClockLogger            = "clock"
	P2PLogger              = "p2p"
	PostLogger             = "post"
	PostServiceLogger      = "postService"
	PostInfoServiceLogger  = "postInfoService"
	StateDbLogger          = "stateDb"
	ApiStateDBLogger       = "apiStateDB"
	BeaconLogger           = "beacon"
	CachedDBLogger         = "cachedDB"
	PoetDbLogger           = "poetDb"
	TrtlLogger             = "trtl"
	ATXHandlerLogger       = "atxHandler"
	ATXBuilderLogger       = "atxBuilder"
	MeshLogger             = "mesh"
	SyncLogger             = "sync"
	HareOracleLogger       = "hareOracle"
	HareLogger             = "hare"
	BlockCertLogger        = "blockCert"
	BlockGenLogger         = "blockGenerator"
	BlockHandlerLogger     = "blockHandler"
	TxHandlerLogger        = "txHandler"
	ProposalStoreLogger    = "proposalStore"
	ProposalBuilderLogger  = "proposalBuilder"
	ProposalListenerLogger = "proposalListener"
	NipostBuilderLogger    = "nipostBuilder"
	NipostValidatorLogger  = "nipostValidator"
	Fetcher                = "fetcher"
	TimeSyncLogger         = "timesync"
	VMLogger               = "vm"
	GRPCLogger             = "grpc"
	ConStateLogger         = "conState"
	ExecutorLogger         = "executor"
	MalfeasanceLogger      = "malfeasance"
	BootstrapLogger        = "bootstrap"
)

Logger names.

Functions

func GetCommand

func GetCommand() *cobra.Command

func LoadConfig

func LoadConfig(cfg *config.Config, preset string, src io.Reader) error

LoadConfig loads config and preset (if provided) into the provided config. It first loads the preset and then overrides it with values from the config file.

func WithErrorUnused

func WithErrorUnused() viper.DecoderConfigOption

func WithIgnoreUntagged

func WithIgnoreUntagged() viper.DecoderConfigOption

func WithZeroFields

func WithZeroFields() viper.DecoderConfigOption

Types

type App

type App struct {
	*cobra.Command

	Config *config.Config
	// contains filtered or unexported fields
}

App is the cli app singleton.

func New

func New(opts ...Option) *App

New creates an instance of the spacemesh app.

func NewApp

func NewApp(tb testing.TB, conf *config.Config, l log.Log) *App

func (*App) Cleanup

func (app *App) Cleanup(ctx context.Context)

Cleanup stops all app services.

func (*App) Host

func (app *App) Host() *p2p.Host

func (*App) Initialize

func (app *App) Initialize() error

Initialize parses and validates the node configuration and sets up logging.

func (*App) LoadIdentities

func (app *App) LoadIdentities() error

LoadIdentities loads all existing identities from the config directory.

func (*App) Lock

func (app *App) Lock() error

Lock locks the app for exclusive use. It returns an error if the app is already locked.

func (*App) NewIdentity

func (app *App) NewIdentity() error

NewIdentity creates a new identity, saves it to `keyDir/supervisedIDKeyFileName` in the config directory and initializes app.signers with that identity.

func (*App) SetLogLevel

func (app *App) SetLogLevel(name, loglevel string) error

SetLogLevel updates the log level of an existing logger.

func (*App) Start

func (app *App) Start(ctx context.Context) error

Start starts the Spacemesh node and initializes all relevant services according to command line arguments provided.

func (*App) Started

func (app *App) Started() <-chan struct{}

func (*App) Unlock

func (app *App) Unlock()

Unlock unlocks the app. It is a no-op if the app is not locked.

type Option

type Option func(app *App)

Option to modify an App instance.

func WithConfig

func WithConfig(conf *config.Config) Option

WithConfig overwrites default App config.

func WithLog

func WithLog(logger log.Log) Option

WithLog enables logger for an App.

type TestApp

type TestApp struct {
	*App
	Conn *grpc.ClientConn
}

func NewTestNetwork

func NewTestNetwork(tb testing.TB, conf config.Config, l log.Log, size int) []*TestApp

NewTestNetwork creates a network of fully connected nodes.