Documentation
¶
Index ¶
- func NewLinearizeOnInitializeVM(vm vertex.LinearizableVMWithEngine) *linearizeOnInitializeVM
- type ChainConfig
- type ChainParameters
- type Manager
- type ManagerConfig
- type MockManager
- func (mm MockManager) AddRegistrant(Registrant)
- func (mm MockManager) Alias(ids.ID, string) error
- func (mm MockManager) Aliases(ids.ID) ([]string, error)
- func (mm MockManager) ForceCreateChain(ChainParameters)
- func (mm MockManager) IsBootstrapped(ids.ID) bool
- func (mm MockManager) Lookup(s string) (ids.ID, error)
- func (mm MockManager) LookupVM(s string) (ids.ID, error)
- func (mm MockManager) PrimaryAlias(ids.ID) (string, error)
- func (mm MockManager) PrimaryAliasOrDefault(ids.ID) string
- func (mm MockManager) QueueChainCreation(ChainParameters)
- func (mm MockManager) RemoveAliases(ids.ID)
- func (mm MockManager) Router() router.Router
- func (mm MockManager) Shutdown()
- func (mm MockManager) StartChainCreator(ChainParameters)
- func (mm MockManager) SubnetID(ids.ID) (ids.ID, error)
- type Registrant
- type Subnet
- type SubnetConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewLinearizeOnInitializeVM ¶ added in v1.10.9
func NewLinearizeOnInitializeVM(vm vertex.LinearizableVMWithEngine) *linearizeOnInitializeVM
Types ¶
type ChainConfig ¶ added in v1.10.9
ChainConfig is configuration settings for the current execution. [Config] is the user-provided config blob for the chain. [Upgrade] is a chain-specific blob for coordinating upgrades.
type ChainParameters ¶
type ChainParameters struct {
// The ID of the chain being created.
ID ids.ID
// ID of the subnet that validates this chain.
SubnetID ids.ID
// The genesis data of this chain's ledger.
GenesisData []byte
// The ID of the vm this chain is running.
VMID ids.ID
// The IDs of the feature extensions this chain is running.
FxIDs []ids.ID
// Invariant: Only used when [ID] is the P-chain ID.
CustomBeacons validators.Manager
}
ChainParameters defines the chain being created
type Manager ¶
type Manager interface {
ids.Aliaser
// Return the router this Manager is using to route consensus messages to chains
Router() router.Router
// Queues a chain to be created in the future after chain creator is unblocked.
// This is only called from the P-chain thread to create other chains
// Queued chains are created only after P-chain is bootstrapped.
// This assumes only chains in tracked subnets are queued.
QueueChainCreation(ChainParameters)
// Add a registrant [r]. Every time a chain is
// created, [r].RegisterChain([new chain]) is called.
AddRegistrant(Registrant)
// Given an alias, return the ID of the chain associated with that alias
Lookup(string) (ids.ID, error)
// Given an alias, return the ID of the VM associated with that alias
LookupVM(string) (ids.ID, error)
// Returns true iff the chain with the given ID exists and is finished bootstrapping
IsBootstrapped(ids.ID) bool
// Starts the chain creator with the initial platform chain parameters, must
// be called once.
StartChainCreator(platformChain ChainParameters) error
Shutdown()
}
Manager manages the chains running on this node. It can:
- Create a chain
- Add a registrant. When a chain is created, each registrant calls RegisterChain with the new chain as the argument.
- Manage the aliases of chains
var TestManager Manager = testManager{}
TestManager implements Manager but does nothing. Always returns nil error. To be used only in tests
type ManagerConfig ¶ added in v1.10.9
type ManagerConfig struct {
SybilProtectionEnabled bool
StakingTLSCert tls.Certificate // needed to sign snowman++ blocks
StakingBLSKey *bls.SecretKey
TracingEnabled bool
// Must not be used unless [TracingEnabled] is true as this may be nil.
Tracer trace.Tracer
Log logging.Logger
LogFactory logging.Factory
VMManager vms.Manager // Manage mappings from vm ID --> vm
BlockAcceptorGroup snow.AcceptorGroup
TxAcceptorGroup snow.AcceptorGroup
VertexAcceptorGroup snow.AcceptorGroup
DB database.Database
MsgCreator message.OutboundMsgBuilder // message creator, shared with network
Router router.Router // Routes incoming messages to the appropriate chain
Net network.Network // Sends consensus messages to other validators
Validators validators.Manager // Validators validating on this chain
NodeID ids.NodeID // The ID of this node
NetworkID uint32 // ID of the network this node is connected to
PartialSyncPrimaryNetwork bool
Server server.Server // Handles HTTP API calls
Keystore keystore.Keystore
AtomicMemory *atomic.Memory
LUXAssetID ids.ID
XChainID ids.ID // ID of the X-Chain,
CChainID ids.ID // ID of the C-Chain,
CriticalChains set.Set[ids.ID] // Chains that can't exit gracefully
TimeoutManager timeout.Manager // Manages request timeouts when sending messages to other validators
Health health.Registerer
SubnetConfigs map[ids.ID]subnets.Config // ID -> SubnetConfig
ChainConfigs map[string]ChainConfig // alias -> ChainConfig
// ShutdownNodeFunc allows the chain manager to issue a request to shutdown the node
ShutdownNodeFunc func(exitCode int)
MeterVMEnabled bool // Should each VM be wrapped with a MeterVM
Metrics metrics.MultiGatherer
FrontierPollFrequency time.Duration
ConsensusAppConcurrency int
// Max Time to spend fetching a container and its
// ancestors when responding to a GetAncestors
BootstrapMaxTimeGetAncestors time.Duration
// Max number of containers in an ancestors message sent by this node.
BootstrapAncestorsMaxContainersSent int
// This node will only consider the first [AncestorsMaxContainersReceived]
// containers in an ancestors message it receives.
BootstrapAncestorsMaxContainersReceived int
ApricotPhase4Time time.Time
ApricotPhase4MinPChainHeight uint64
// Tracks CPU/disk usage caused by each peer.
ResourceTracker timetracker.ResourceTracker
StateSyncBeacons []ids.NodeID
ChainDataDir string
}
type MockManager ¶
type MockManager struct{}
MockManager implements Manager but does nothing. Always returns nil error. To be used only in tests
func (MockManager) AddRegistrant ¶
func (mm MockManager) AddRegistrant(Registrant)
func (MockManager) ForceCreateChain ¶
func (mm MockManager) ForceCreateChain(ChainParameters)
func (MockManager) IsBootstrapped ¶ added in v1.10.9
func (mm MockManager) IsBootstrapped(ids.ID) bool
func (MockManager) PrimaryAlias ¶ added in v1.10.9
func (mm MockManager) PrimaryAlias(ids.ID) (string, error)
func (MockManager) PrimaryAliasOrDefault ¶ added in v1.10.9
func (mm MockManager) PrimaryAliasOrDefault(ids.ID) string
func (MockManager) QueueChainCreation ¶ added in v1.10.9
func (mm MockManager) QueueChainCreation(ChainParameters)
func (MockManager) RemoveAliases ¶ added in v1.10.9
func (mm MockManager) RemoveAliases(ids.ID)
func (MockManager) Router ¶
func (mm MockManager) Router() router.Router
func (MockManager) Shutdown ¶
func (mm MockManager) Shutdown()
func (MockManager) StartChainCreator ¶ added in v1.10.9
func (mm MockManager) StartChainCreator(ChainParameters)
type Registrant ¶
type Registrant interface {
// Called when a chain is created
// This function is called before the chain starts processing messages
// [vm] should be a vertex.DAGVM or block.ChainVM
RegisterChain(chainName string, ctx *snow.ConsensusContext, vm common.VM)
}
Registrant can register the existence of a chain
type Subnet ¶ added in v1.10.9
Subnet keeps track of the currently bootstrapping chains in a subnet. If no chains in the subnet are currently bootstrapping, the subnet is considered bootstrapped.
type SubnetConfig ¶ added in v1.10.9
type SubnetConfig struct {
sender.GossipConfig
// ValidatorOnly indicates that this Subnet's Chains are available to only subnet validators.
ValidatorOnly bool `json:"validatorOnly" yaml:"validatorOnly"`
ConsensusParameters lux.Parameters `json:"consensusParameters" yaml:"consensusParameters"`
// ProposerMinBlockDelay is the minimum delay this node will enforce when
// building a snowman++ block.
// TODO: Remove this flag once all VMs throttle their own block production.
ProposerMinBlockDelay time.Duration `json:"proposerMinBlockDelay" yaml:"proposerMinBlockDelay"`
}
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package atomic is a generated GoMock package.
|
Package atomic is a generated GoMock package. |