node

Documentation

Overview

Copyright (C) 2025, Lux Industries, Inc. All rights reserved. See the file LICENSE for licensing terms.

Copyright (C) 2025, Lux Industries, Inc. All rights reserved. See the file LICENSE for licensing terms.

Copyright (C) 2025, Lux Industries, Inc. All rights reserved. See the file LICENSE for licensing terms.

Copyright (C) 2025, Lux Industries, Inc. All rights reserved. See the file LICENSE for licensing terms.

Index

• Constants
• func AuthorizedAccessFromSettings(app *application.Lux) bool
• func CheckCluster(app *application.Lux, clusterName string) error
• func CheckClusterExists(app *application.Lux, clusterName string) (bool, error)
• func CheckHostsAreBootstrapped(hosts []*models.Host) error
• func CheckHostsAreHealthy(hosts []*models.Host) error
• func CheckHostsAreRPCCompatible(app *application.Lux, hosts []*models.Host, subnetName string) error
• func DisconnectHosts(hosts []*models.Host)
• func GetClusterNodes(app *application.Lux, clusterName string) ([]string, error)
• func GetHostWithCloudID(app *application.Lux, clusterName string, cloudID string) (*models.Host, error)
• func GetLuxdEndpoint(ip string) string
• func GetNotBootstrappedNodes(hosts []*models.Host) ([]string, error)
• func GetUnhealthyNodes(hosts []*models.Host) ([]string, error)
• func GetWarpRelayerHost(app *application.Lux, clusterName string) (*models.Host, error)
• func LocalStatus(app *application.Lux, clusterName string, blockchainName string) error
• func ParseLuxdOutput(byteValue []byte) (string, uint32, error)
• func StartLocalNode(app *application.Lux, clusterName string, luxdBinaryPath string, ...) error
• func SyncSubnet(app *application.Lux, clusterName, blockchainName string, avoidChecks bool, ...) error
• func WaitForHealthyCluster(app *application.Lux, clusterName string, timeout time.Duration, ...) error

Constants

const (
	HealthCheckPoolTime = 60 * time.Second
	HealthCheckTimeout  = 3 * time.Minute
)

Functions

func AuthorizedAccessFromSettings

func AuthorizedAccessFromSettings(app *application.Lux) bool

func CheckCluster

func CheckCluster(app *application.Lux, clusterName string) error

func CheckClusterExists

func CheckClusterExists(app *application.Lux, clusterName string) (bool, error)

func CheckHostsAreBootstrapped

func CheckHostsAreBootstrapped(hosts []*models.Host) error

func CheckHostsAreHealthy

func CheckHostsAreHealthy(hosts []*models.Host) error

func CheckHostsAreRPCCompatible

func CheckHostsAreRPCCompatible(app *application.Lux, hosts []*models.Host, subnetName string) error

func DisconnectHosts

func DisconnectHosts(hosts []*models.Host)

func GetClusterNodes

func GetClusterNodes(app *application.Lux, clusterName string) ([]string, error)

func GetHostWithCloudID

func GetHostWithCloudID(app *application.Lux, clusterName string, cloudID string) (*models.Host, error)

func GetLuxdEndpoint

func GetLuxdEndpoint(ip string) string

func GetNotBootstrappedNodes

func GetNotBootstrappedNodes(hosts []*models.Host) ([]string, error)

func GetUnhealthyNodes

func GetUnhealthyNodes(hosts []*models.Host) ([]string, error)

func GetWarpRelayerHost

func GetWarpRelayerHost(app *application.Lux, clusterName string) (*models.Host, error)

func LocalStatus

func LocalStatus(
	app *application.Lux,
	clusterName string,
	blockchainName string,
) error

func ParseLuxdOutput

func ParseLuxdOutput(byteValue []byte) (string, uint32, error)

func StartLocalNode

func StartLocalNode(
	app *application.Lux,
	clusterName string,
	luxdBinaryPath string,
	numNodes uint32,
	defaultFlags map[string]interface{},
	connectionSettings localnet.ConnectionSettings,
	nodeSettings []localnet.NodeSetting,
	luxdVersionSetting dependencies.LuxdVersionSettings,
	network models.Network,
) error

func SyncSubnet

func SyncSubnet(app *application.Lux, clusterName, blockchainName string, avoidChecks bool, subnetAliases []string) error

func WaitForHealthyCluster

func WaitForHealthyCluster(
	app *application.Lux,
	clusterName string,
	timeout time.Duration,
	poolTime time.Duration,
) error