simple_node_set

Documentation

Index

• Constants
• func FundNodes(c *ethclient.Client, nodes []*clclient.ChainlinkClient, pkey string, ...) error
• func SendETH(client *ethclient.Client, privateKeyHex string, toAddress string, ...) error
• type Input
• type Output
  • func NewSharedDBNodeSet(in *Input, bcOut *blockchain.Output) (*Output, error)
  • func UpgradeNodeSet(in *Input, bc *blockchain.Output, wait time.Duration) (*Output, error)

Constants

const (
	DefaultHTTPPortStaticRangeStart = 10000
	DefaultP2PStaticRangeStart      = 12000
)

Functions

func FundNodes

func FundNodes(c *ethclient.Client, nodes []*clclient.ChainlinkClient, pkey string, ethAmount float64) error

FundNodes funds Chainlink nodes with N ETH each

func SendETH

func SendETH(client *ethclient.Client, privateKeyHex string, toAddress string, amount *big.Float) error

Types

type Input

type Input struct {
	Nodes              int             `toml:"nodes" validate:"required"`
	HTTPPortRangeStart int             `toml:"http_port_range_start"`
	P2PPortRangeStart  int             `toml:"p2p_port_range_start"`
	DlvPortRangeStart  int             `toml:"dlv_port_range_start"`
	OverrideMode       string          `toml:"override_mode" validate:"required,oneof=all each"`
	DbInput            *postgres.Input `toml:"db" validate:"required"`
	NodeSpecs          []*clnode.Input `toml:"node_specs" validate:"required"`
	Out                *Output         `toml:"out"`
}

Input is a node set configuration input

type Output

type Output struct {
	UseCache bool             `toml:"use_cache"`
	DBOut    *postgres.Output `toml:"db_out"`
	CLNodes  []*clnode.Output `toml:"cl_nodes"`
}

Output is a node set configuration output, used for caching or external components

func NewSharedDBNodeSet

func NewSharedDBNodeSet(in *Input, bcOut *blockchain.Output) (*Output, error)

NewSharedDBNodeSet create a new node set with a shared database instance all the nodes have their own isolated database

func UpgradeNodeSet

func UpgradeNodeSet(in *Input, bc *blockchain.Output, wait time.Duration) (*Output, error)

UpgradeNodeSet updates nodes configuration TOML files this API is discouraged, however, you can use it if nodes require restart or configuration updates, temporarily!