mirror of
https://github.com/luxfi/node.git
synced 2026-10-30 15:24:05 +00:00
The module already called itself github.com/luxfi/node while containing no node in Go: cmd/luxd was twenty-one lines that printed the size of a few types, and the Go column of the matrix measured a VM plugin. A repo that fetches the thing it claims to be has not replaced it, so the Go sources move in — 1515 files, the daemon and everything under it — and the build reaches outside this module for nothing. Rust and C++ sit beside it unchanged and are still measured against it by the differential. That is the point of one repo: the reference implementation and the two ports are the same checkout, so parity is a thing you can run rather than a thing you assert. Verified: builds, and the closure carries no lux-private — checked at build time rather than believed. The daemon starts twelve chains on a local network (P X C Q Z A B G K M F, plus D through its plugin) and reports healthy.
58 lines
1.7 KiB
Go
58 lines
1.7 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package runtime
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"time"
|
|
)
|
|
|
|
const (
|
|
// Address of the runtime engine server.
|
|
EngineAddressKey = "VM_RUNTIME_ENGINE_ADDR"
|
|
|
|
// LegacyEngineAddressKey is the pre-rename env-var name. Plugin binaries
|
|
// compiled against luxfi/node <= v1.26.x read this key. The host sets
|
|
// both keys until every plugin in /data/plugins has been rebuilt against
|
|
// a luxfi/node version that has the rename.
|
|
LegacyEngineAddressKey = "LUX_VM_RUNTIME_ENGINE_ADDR"
|
|
|
|
// Duration before handshake timeout during bootstrap.
|
|
DefaultHandshakeTimeout = 5 * time.Second
|
|
|
|
// Duration of time to wait for graceful termination to complete.
|
|
DefaultGracefulTimeout = 5 * time.Second
|
|
)
|
|
|
|
var (
|
|
ErrProtocolVersionMismatch = errors.New("RPCChainVM protocol version mismatch between Lux Node and Virtual Machine plugin")
|
|
ErrHandshakeFailed = errors.New("handshake failed")
|
|
ErrInvalidConfig = errors.New("invalid config")
|
|
ErrProcessNotFound = errors.New("vm process not found")
|
|
)
|
|
|
|
type Initializer interface {
|
|
// Initialize provides Lux Node with compatibility, networking and
|
|
// process information of a VM.
|
|
Initialize(ctx context.Context, protocolVersion uint, vmAddr string) error
|
|
}
|
|
|
|
type Stopper interface {
|
|
// Stop begins shutdown of a VM. This method must not block
|
|
// and multiple calls to this method will result in no-op.
|
|
Stop(ctx context.Context)
|
|
}
|
|
|
|
type Tracker interface {
|
|
// TrackRuntime adds a VM stopper to the manager.
|
|
TrackRuntime(runtime Stopper)
|
|
}
|
|
|
|
type Manager interface {
|
|
Tracker
|
|
// Stop all managed VMs.
|
|
Stop(ctx context.Context)
|
|
}
|