node_manager

Documentation

Index

• Variables
• func AugmentStackSizeLimit() error
• type ChainSuperviser
• type DeepMindDebuggable
• type HeadBlockUpdater
• type MetricsAndReadinessManager
  • func NewMetricsAndReadinessManager(headBlockTimeDrift *dmetrics.HeadTimeDrift, ...) *MetricsAndReadinessManager
  • func (m *MetricsAndReadinessManager) IsReady() bool
  • func (m *MetricsAndReadinessManager) Launch()
  • func (m *MetricsAndReadinessManager) UpdateHeadBlock(block *pbbstream.Block) error
• type MonitorableChainSuperviser
• type OnBlockWritten
• type ProducerChainSuperviser
• type ProductionEvent
• type ProductionState
  • func (s ProductionState) String() string
• type Readiness
• type ShutterInterface
• type StartOption

Variables

var DisableDebugDeepmindOption = StartOption("disable-debug-firehose-logs")

var EnableDebugDeepmindOption = StartOption("enable-debug-firehose-logs")

Functions

func AugmentStackSizeLimit

func AugmentStackSizeLimit() error

Types

type ChainSuperviser

type ChainSuperviser interface {
	ShutterInterface

	GetCommand() string
	GetName() string
	ServerID() (string, error)

	RegisterLogPlugin(plugin logplugin.LogPlugin)
	Start(options ...StartOption) error
	Stop() error

	IsRunning() bool
	Stopped() <-chan struct{}

	LastExitCode() int
	LastLogLines() []string
	LastSeenBlockNum() uint64
}

type DeepMindDebuggable

type DeepMindDebuggable interface {
	DebugDeepMind(enabled bool)
}

type HeadBlockUpdater

type HeadBlockUpdater func(block *pbbstream.Block) error

type MetricsAndReadinessManager

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

func NewMetricsAndReadinessManager

func NewMetricsAndReadinessManager(headBlockTimeDrift *dmetrics.HeadTimeDrift, headBlockNumber *dmetrics.HeadBlockNum, appReadiness *dmetrics.AppReadiness, readinessMaxLatency time.Duration) *MetricsAndReadinessManager

func (*MetricsAndReadinessManager) IsReady

func (m *MetricsAndReadinessManager) IsReady() bool

func (*MetricsAndReadinessManager) Launch

func (m *MetricsAndReadinessManager) Launch()

func (*MetricsAndReadinessManager) UpdateHeadBlock

func (m *MetricsAndReadinessManager) UpdateHeadBlock(block *pbbstream.Block) error

type MonitorableChainSuperviser

type MonitorableChainSuperviser interface {
	Monitor()
}

type OnBlockWritten

type OnBlockWritten func(block *pbbstream.Block) error

type ProducerChainSuperviser

type ProducerChainSuperviser interface {
	IsProducing() (bool, error)
	IsActiveProducer() bool

	ResumeProduction() error
	PauseProduction() error

	WaitUntilEndOfNextProductionRound(timeout time.Duration) error
}

type ProductionEvent

type ProductionEvent int

const (
	EventProduced ProductionEvent = iota
	EventReceived
)

type ProductionState

type ProductionState int

const (
	StatePre       ProductionState = iota // Just before we produce, don't restart
	StateProducing                        // We're producing right now
	StatePost                             // Right after production
	StateStale                            // We haven't produced for 12 minutes
)

func (ProductionState) String

func (s ProductionState) String() string

type Readiness

type Readiness interface {
	IsReady() bool
}

type ShutterInterface

type ShutterInterface interface {
	Shutdown(error)
	OnTerminating(func(error))
	OnTerminated(func(error))
	IsTerminated() bool
	IsTerminating() bool
	Terminated() <-chan struct{}
}

type StartOption

type StartOption string