The highest tagged major version is v2.

node

package

v1.4.1-rc4 Latest Latest Go to latest Published: Dec 3, 2021 License: BSD-3-Clause Imports: 94 Imported by: 2

Details

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

Repository

github.com/ethersphere/bee

Links

Open Source Insights

Documentation ¶

Overview ¶

Package node defines the concept of a Bee node by bootstrapping and injecting all necessary dependencies.

Index ¶

Variables
func CheckOverlayWithStore(overlay swarm.Address, storer storage.StateStorer) error
func GetTxHash(stateStore storage.StateStorer, logger logging.Logger, trxString string) ([]byte, error)
func GetTxNextBlock(ctx context.Context, logger logging.Logger, backend transaction.Backend, ...) ([]byte, error)
func InitChain(ctx context.Context, logger logging.Logger, stateStore storage.StateStorer, ...) (transaction.Backend, common.Address, int64, transaction.Monitor, ...)
func InitChequebookFactory(logger logging.Logger, backend transaction.Backend, chainID int64, ...) (chequebook.Factory, error)
func InitChequebookService(ctx context.Context, logger logging.Logger, stateStore storage.StateStorer, ...) (chequebook.Service, error)
func InitStateStore(log logging.Logger, dataDir string) (ret storage.StateStorer, err error)
func InitSwap(p2ps *libp2p.Service, logger logging.Logger, stateStore storage.StateStorer, ...) (*swap.Service, priceoracle.Service, error)
type Bee
- func NewBee(addr string, publicKey *ecdsa.PublicKey, signer crypto.Signer, ...) (b *Bee, err error)
- func (b *Bee) Shutdown(ctx context.Context) error
type DevBee
- func NewDevBee(logger logging.Logger, o *DevOptions) (b *DevBee, err error)
- func (b *DevBee) Shutdown(ctx context.Context) error
type DevOptions
type Options

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrShutdownInProgress error = errors.New("shutdown in progress")

Functions ¶

func CheckOverlayWithStore ¶ added in v0.5.3

func CheckOverlayWithStore(overlay swarm.Address, storer storage.StateStorer) error

CheckOverlayWithStore checks the overlay is the same as stored in the statestore

func GetTxHash ¶ added in v1.0.0

func GetTxHash(stateStore storage.StateStorer, logger logging.Logger, trxString string) ([]byte, error)

func GetTxNextBlock ¶ added in v1.0.0

func GetTxNextBlock(ctx context.Context, logger logging.Logger, backend transaction.Backend, monitor transaction.Monitor, duration time.Duration, trx []byte, blockHash string) ([]byte, error)

func InitChain ¶ added in v0.5.2

func InitChain(
	ctx context.Context,
	logger logging.Logger,
	stateStore storage.StateStorer,
	endpoint string,
	signer crypto.Signer,
	pollingInterval time.Duration,
) (transaction.Backend, common.Address, int64, transaction.Monitor, transaction.Service, error)

InitChain will initialize the Ethereum backend at the given endpoint and set up the Transaction Service to interact with it using the provided signer.

func InitChequebookFactory ¶ added in v0.5.2

func InitChequebookFactory(
	logger logging.Logger,
	backend transaction.Backend,
	chainID int64,
	transactionService transaction.Service,
	factoryAddress string,
	legacyFactoryAddresses []string,
) (chequebook.Factory, error)

InitChequebookFactory will initialize the chequebook factory with the given chain backend.

func InitChequebookService ¶ added in v0.5.2

func InitChequebookService(
	ctx context.Context,
	logger logging.Logger,
	stateStore storage.StateStorer,
	signer crypto.Signer,
	chainID int64,
	backend transaction.Backend,
	overlayEthAddress common.Address,
	transactionService transaction.Service,
	chequebookFactory chequebook.Factory,
	initialDeposit string,
	deployGasPrice string,
) (chequebook.Service, error)

InitChequebookService will initialize the chequebook service with the given chequebook factory and chain backend.

func InitStateStore ¶ added in v0.5.2

func InitStateStore(log logging.Logger, dataDir string) (ret storage.StateStorer, err error)

InitStateStore will initialize the stateStore with the given path to the data directory. When given an empty directory path, the function will instead initialize an in-memory state store that will not be persisted.

func InitSwap ¶ added in v0.5.2

func InitSwap(
	p2ps *libp2p.Service,
	logger logging.Logger,
	stateStore storage.StateStorer,
	networkID uint64,
	overlayEthAddress common.Address,
	chequebookService chequebook.Service,
	chequeStore chequebook.ChequeStore,
	cashoutService chequebook.CashoutService,
	accounting settlement.Accounting,
	priceOracleAddress string,
	chainID int64,
	transactionService transaction.Service,
) (*swap.Service, priceoracle.Service, error)

InitSwap will initialize and register the swap service.

Types ¶

type Bee ¶

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

func NewBee ¶

func NewBee(addr string, publicKey *ecdsa.PublicKey, signer crypto.Signer, networkID uint64, logger logging.Logger, libp2pPrivateKey, pssPrivateKey *ecdsa.PrivateKey, o *Options) (b *Bee, err error)

func (*Bee) Shutdown ¶

func (b *Bee) Shutdown(ctx context.Context) error

type DevBee ¶ added in v1.1.0

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

func NewDevBee ¶ added in v1.1.0

func NewDevBee(logger logging.Logger, o *DevOptions) (b *DevBee, err error)

NewDevBee starts the bee instance in 'development' mode this implies starting an API and a Debug endpoints while mocking all their services.

func (*DevBee) Shutdown ¶ added in v1.1.0

func (b *DevBee) Shutdown(ctx context.Context) error

type DevOptions ¶ added in v1.1.0

type DevOptions struct {
	Logger                   logging.Logger
	APIAddr                  string
	DebugAPIAddr             string
	CORSAllowedOrigins       []string
	DBOpenFilesLimit         uint64
	ReserveCapacity          uint64
	DBWriteBufferSize        uint64
	DBBlockCacheCapacity     uint64
	DBDisableSeeksCompaction bool
	Restricted               bool
	TokenEncryptionKey       string
	AdminPasswordHash        string
}

type Options ¶

type Options struct {
	DataDir                    string
	CacheCapacity              uint64
	DBOpenFilesLimit           uint64
	DBWriteBufferSize          uint64
	DBBlockCacheCapacity       uint64
	DBDisableSeeksCompaction   bool
	APIAddr                    string
	DebugAPIAddr               string
	Addr                       string
	NATAddr                    string
	EnableWS                   bool
	WelcomeMessage             string
	Bootnodes                  []string
	CORSAllowedOrigins         []string
	Logger                     logging.Logger
	TracingEnabled             bool
	TracingEndpoint            string
	TracingServiceName         string
	GlobalPinningEnabled       bool
	PaymentThreshold           string
	PaymentTolerance           int64
	PaymentEarly               int64
	ResolverConnectionCfgs     []multiresolver.ConnectionConfig
	RetrievalCaching           bool
	GatewayMode                bool
	BootnodeMode               bool
	SwapEndpoint               string
	SwapFactoryAddress         string
	SwapLegacyFactoryAddresses []string
	SwapInitialDeposit         string
	SwapEnable                 bool
	FullNodeMode               bool
	Transaction                string
	BlockHash                  string
	PostageContractAddress     string
	PriceOracleAddress         string
	BlockTime                  uint64
	DeployGasPrice             string
	WarmupTime                 time.Duration
	ChainID                    int64
	Resync                     bool
	BlockProfile               bool
	MutexProfile               bool
	StaticNodes                []swarm.Address
	AllowPrivateCIDRs          bool
	Restricted                 bool
	TokenEncryptionKey         string
	AdminPasswordHash          string
}

Source Files ¶

View all Source files

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