neblet

Documentation

Index

• Variables
• func CreateDefaultConfigFile(filename string)
• func LoadConfig(file string) *nebletpb.Config
• type Neblet
  • func New(config *nebletpb.Config) (*Neblet, error)
  • func (n *Neblet) AccountManager() core.AccountManager
  • func (n *Neblet) BlockChain() *core.BlockChain
  • func (n *Neblet) Config() *nebletpb.Config
  • func (n *Neblet) Consensus() core.Consensus
  • func (n *Neblet) Dip() core.Dip
  • func (n *Neblet) EventEmitter() *core.EventEmitter
  • func (n *Neblet) Genesis() *corepb.Genesis
  • func (n *Neblet) IsActiveSyncing() bool
  • func (n *Neblet) NetService() nebnet.Service
  • func (n *Neblet) Nr() core.NR
  • func (n *Neblet) Nvm() core.NVM
  • func (n *Neblet) SetGenesis(g *corepb.Genesis)
  • func (n *Neblet) Setup()
  • func (n *Neblet) Start()
  • func (n *Neblet) StartPprof(listen string) error
  • func (n *Neblet) Stop()
  • func (n *Neblet) Storage() storage.Storage
  • func (n *Neblet) SyncService() *nsync.Service
  • func (n *Neblet) TryStartProfiling()
  • func (n *Neblet) TryStopProfiling()

Variables

var (
	// ErrNebletAlreadyRunning throws when the neblet is already running.
	ErrNebletAlreadyRunning = errors.New("neblet is already running")

	// ErrIncompatibleStorageSchemeVersion throws when the storage schema has been changed
	ErrIncompatibleStorageSchemeVersion = errors.New("incompatible storage schema version, pls migrate your storage")
)

var (
	ErrConfigShouldHasChain = errors.New("config not has chain")
)

all error should in only file

Functions

func CreateDefaultConfigFile

func CreateDefaultConfigFile(filename string)

CreateDefaultConfigFile create a default config file.

func LoadConfig

func LoadConfig(file string) *nebletpb.Config

LoadConfig loads configuration from the file.

Types

type Neblet

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

Neblet manages life cycle of blockchain services.

func New

func New(config *nebletpb.Config) (*Neblet, error)

New returns a new neblet.

func (*Neblet) AccountManager

func (n *Neblet) AccountManager() core.AccountManager

AccountManager returns account manager reference.

func (*Neblet) BlockChain

func (n *Neblet) BlockChain() *core.BlockChain

BlockChain returns block chain reference.

func (*Neblet) Config

func (n *Neblet) Config() *nebletpb.Config

Config returns neblet configuration.

func (*Neblet) Consensus

func (n *Neblet) Consensus() core.Consensus

Consensus returns consensus reference.

func (*Neblet) Dip

func (n *Neblet) Dip() core.Dip

Dip return the dip

func (*Neblet) EventEmitter

func (n *Neblet) EventEmitter() *core.EventEmitter

EventEmitter returns eventEmitter reference.

func (*Neblet) Genesis

func (n *Neblet) Genesis() *corepb.Genesis

Genesis returns genesis conf.

func (*Neblet) IsActiveSyncing

func (n *Neblet) IsActiveSyncing() bool

IsActiveSyncing return if the neb is syncing blocks

func (*Neblet) NetService

func (n *Neblet) NetService() nebnet.Service

NetService returns p2p manager reference.

func (*Neblet) Nr

func (n *Neblet) Nr() core.NR

NR return the nr

func (*Neblet) Nvm

func (n *Neblet) Nvm() core.NVM

Nvm return nvm engine

func (*Neblet) SetGenesis

func (n *Neblet) SetGenesis(g *corepb.Genesis)

SetGenesis set genesis conf

func (*Neblet) Setup

func (n *Neblet) Setup()

Setup setup neblet

func (*Neblet) Start

func (n *Neblet) Start()

Start starts the services of the neblet.

func (*Neblet) StartPprof

func (n *Neblet) StartPprof(listen string) error

StartPprof start pprof http listen

func (*Neblet) Stop

func (n *Neblet) Stop()

Stop stops the services of the neblet.

func (*Neblet) Storage

func (n *Neblet) Storage() storage.Storage

Storage returns storage reference.

func (*Neblet) SyncService

func (n *Neblet) SyncService() *nsync.Service

SyncService return sync service

func (*Neblet) TryStartProfiling

func (n *Neblet) TryStartProfiling()

TryStartProfiling try start pprof

func (*Neblet) TryStopProfiling

func (n *Neblet) TryStopProfiling()

TryStopProfiling try stop pprof