node

package

v0.3.15 Latest Latest Go to latest Published: May 20, 2025 License: MIT Imports: 61 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/antexprotocol/supernova

Links

Open Source Insights

Documentation ¶

Index ¶

func CosmosNodeToP2PNode(cosmosNodeAddr string) string
func DefaultMetricsProvider(config *cfg.InstrumentationConfig) cmtnode.MetricsProvider
func HandleExitSignal() context.Context
func InitLogger(config *cmtcfg.Config)
func LoadGenesisDoc(mainDB db.DB, genesisDocProvider cmtnode.GenesisDocProvider) (*cmttypes.GenesisDoc, error)
func NewChain(mainDB db.DB) *chain.Chain
func OpenMainDB(ctx *cli.Context, dataDir string) *lvldb.LevelDB
type Node
- func NewNode(ctx context.Context, config *cmtcfg.Config, privValidator *privval.FilePV, ...) (*Node, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CosmosNodeToP2PNode ¶ added in v0.0.5

func CosmosNodeToP2PNode(cosmosNodeAddr string) string

func DefaultMetricsProvider ¶

func DefaultMetricsProvider(config *cfg.InstrumentationConfig) cmtnode.MetricsProvider

func HandleExitSignal ¶

func HandleExitSignal() context.Context

func InitLogger ¶

func InitLogger(config *cmtcfg.Config)

func LoadGenesisDoc ¶

func LoadGenesisDoc(
	mainDB db.DB,
	genesisDocProvider cmtnode.GenesisDocProvider,
) (*cmttypes.GenesisDoc, error)

func NewChain ¶

func NewChain(mainDB db.DB) *chain.Chain

func OpenMainDB ¶

func OpenMainDB(ctx *cli.Context, dataDir string) *lvldb.LevelDB

Types ¶

type Node ¶

type Node struct {
	// contains filtered or unexported fields
}

var (
	GlobNodeInst *Node
)

func NewNode ¶

func NewNode(
	ctx context.Context,
	config *cmtcfg.Config,
	privValidator *privval.FilePV,
	nodeKey *types.NodeKey,
	clientCreator cmtproxy.ClientCreator,
	genesisDocProvider cmtnode.GenesisDocProvider,
	dbProvider cmtcfg.DBProvider,
	metricProvider cmtnode.MetricsProvider,
	logger log.Logger,
) (*Node, error)

func (*Node) BroadcastTxAsync ¶ added in v0.0.41

func (n *Node) BroadcastTxAsync(ctx *rpctypes.Context, tx cmttypes.Tx) (*ctypes.ResultBroadcastTx, error)

func (*Node) BroadcastTxSync ¶ added in v0.0.41

func (n *Node) BroadcastTxSync(ctx *rpctypes.Context, tx cmttypes.Tx) (*ctypes.ResultBroadcastTx, error)

func (*Node) ConfigureRPC ¶ added in v0.0.40

func (n *Node) ConfigureRPC() (*rpccore.Environment, error)

ConfigureRPC makes sure RPC has all the objects it needs to operate.

func (*Node) GetTxPool ¶ added in v0.0.47

func (n *Node) GetTxPool() *txpool.TxPool

func (*Node) IsRunning ¶

func (n *Node) IsRunning() bool

func (*Node) RpcABCIInfo ¶ added in v0.3.13

func (n *Node) RpcABCIInfo(ctx *rpctypes.Context) (*ctypes.ResultABCIInfo, error)

func (*Node) RpcABCIQuery ¶ added in v0.3.13

func (n *Node) RpcABCIQuery(
	_ *rpctypes.Context,
	path string,
	data cmtbytes.HexBytes,
	height int64,
	prove bool,
) (*ctypes.ResultABCIQuery, error)

func (*Node) RpcBlock ¶ added in v0.3.13

func (n *Node) RpcBlock(_ *rpctypes.Context, heightPtr *int64) (*ctypes.ResultBlock, error)

func (*Node) RpcBlockByHash ¶ added in v0.3.13

func (n *Node) RpcBlockByHash(_ *rpctypes.Context, hash []byte) (*ctypes.ResultBlock, error)

func (*Node) RpcHealth ¶ added in v0.3.13

func (n *Node) RpcHealth(*rpctypes.Context) (*ctypes.ResultHealth, error)

func (*Node) RpcNumUnconfirmedTxs ¶ added in v0.3.13

func (n *Node) RpcNumUnconfirmedTxs(*rpctypes.Context) (*ctypes.ResultUnconfirmedTxs, error)

func (*Node) RpcStatus ¶ added in v0.3.13

func (n *Node) RpcStatus(*rpctypes.Context) (*ctypes.ResultStatus, error)

func (*Node) RpcUnconfirmedTxs ¶ added in v0.3.13

func (n *Node) RpcUnconfirmedTxs(_ *rpctypes.Context, limitPtr *int) (*ctypes.ResultUnconfirmedTxs, error)

func (*Node) RpcValidators ¶ added in v0.3.14

func (n *Node) RpcValidators(
	_ *rpctypes.Context,
	heightPtr *int64,
	pagePtr, perPagePtr *int,
) (*ctypes.ResultValidators, error)

func (*Node) Start ¶

func (n *Node) Start() error

func (*Node) Stop ¶

func (n *Node) Stop() error

func (*Node) Tx ¶ added in v0.0.41

func (n *Node) Tx(ctx *rpctypes.Context, hash []byte, prove bool) (*ctypes.ResultTx, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL