node

package

v1.0.6 Latest Latest Go to latest Published: Mar 12, 2024 License: MIT Imports: 35 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/SiaFoundation/renterd

Links

Open Source Insights

Documentation ¶

Overview ¶

TODO: remove this file when we can import it from hostd

Index ¶

Variables
func NewAutopilot(cfg AutopilotConfig, b autopilot.Bus, workers []autopilot.Worker, ...) (http.Handler, RunFn, ShutdownFn, error)
func NewChainManager(cs modules.ConsensusSet, network *consensus.Network) (*chainManager, error)
func NewLogger(path string) (*zap.Logger, func(context.Context) error, error)
func NewTransactionPool(tp modules.TransactionPool) bus.TransactionPool
type AutopilotConfig
type BusConfig
type Consensus
type Miner
- func NewMiner(consensus Consensus) *Miner
type RunFn
type ShutdownFn
- func NewBus(cfg BusConfig, dir string, seed types.PrivateKey, l *zap.Logger) (http.Handler, ShutdownFn, error)
- func NewWorker(cfg config.Worker, b worker.Bus, seed types.PrivateKey, l *zap.Logger) (http.Handler, ShutdownFn, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrBlockNotFound   = errors.New("block not found")
	ErrInvalidChangeID = errors.New("invalid change id")
)

Functions ¶

func NewAutopilot ¶

func NewAutopilot(cfg AutopilotConfig, b autopilot.Bus, workers []autopilot.Worker, l *zap.Logger) (http.Handler, RunFn, ShutdownFn, error)

func NewChainManager ¶ added in v0.7.0

func NewChainManager(cs modules.ConsensusSet, network *consensus.Network) (*chainManager, error)

NewManager creates a new chain manager.

func NewLogger ¶

func NewLogger(path string) (*zap.Logger, func(context.Context) error, error)

func NewTransactionPool ¶ added in v0.7.0

func NewTransactionPool(tp modules.TransactionPool) bus.TransactionPool

Types ¶

type AutopilotConfig ¶

type AutopilotConfig struct {
	config.Autopilot
	ID string
}

type BusConfig ¶

type BusConfig struct {
	config.Bus
	Network             *consensus.Network
	Miner               *Miner
	DBLoggerConfig      stores.LoggerConfig
	DBDialector         gorm.Dialector
	DBMetricsDialector  gorm.Dialector
	SlabPruningInterval time.Duration
	SlabPruningCooldown time.Duration
}

type Consensus ¶

type Consensus interface {
	AcceptBlock(context.Context, types.Block) error
}

Consensus defines a minimal interface needed by the miner to interact with the consensus set

type Miner ¶

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

A Miner is a CPU miner that can mine blocks, sending the reward to a specified address.

func NewMiner ¶

func NewMiner(consensus Consensus) *Miner

NewMiner initializes a new CPU miner

func (*Miner) Mine ¶

func (m *Miner) Mine(addr types.Address, n int) error

Mine mines n blocks, sending the reward to addr

func (*Miner) ProcessConsensusChange ¶

func (m *Miner) ProcessConsensusChange(cc modules.ConsensusChange)

ProcessConsensusChange implements modules.ConsensusSetSubscriber.

func (*Miner) ReceiveUpdatedUnconfirmedTransactions ¶

func (m *Miner) ReceiveUpdatedUnconfirmedTransactions(diff *modules.TransactionPoolDiff)

ReceiveUpdatedUnconfirmedTransactions implements modules.TransactionPoolSubscriber

type RunFn ¶

type RunFn = func() error

type ShutdownFn ¶

type ShutdownFn = func(context.Context) error

func NewBus ¶

func NewBus(cfg BusConfig, dir string, seed types.PrivateKey, l *zap.Logger) (http.Handler, ShutdownFn, error)

func NewWorker ¶

func NewWorker(cfg config.Worker, b worker.Bus, seed types.PrivateKey, l *zap.Logger) (http.Handler, ShutdownFn, error)

Source Files ¶

View all Source files

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