Run NodesReference

warp

Package warp

import "github.com/luxfi/node/warp"

Types

ChainIPCs

ChainIPCs maintains IPCs for a set of chains

func NewChainIPCs(
	log log.Logger,
	path string,
	networkID uint32,
	blockAcceptorGroup nodeconsensus.AcceptorGroup,
	txAcceptorGroup nodeconsensus.AcceptorGroup,
	vertexAcceptorGroup nodeconsensus.AcceptorGroup,
	defaultChainIDs []ids.ID,
) (*ChainIPCs, error)
func (cipcs *ChainIPCs) GetPublishedBlockchains() []ids.ID
func (cipcs *ChainIPCs) Publish(chainID ids.ID) (*EventSockets, error)
func (cipcs *ChainIPCs) Shutdown() error
func (cipcs *ChainIPCs) Unpublish(chainID ids.ID) (bool, error)

EventSockets

EventSockets is a set of named eventSockets

func (ipcs *EventSockets) Accept(ctx context.Context, containerID ids.ID, container []byte) error
func (ipcs *EventSockets) ConsensusURL() string
func (ipcs *EventSockets) DecisionsURL() string