node

package

v0.3.16 Latest Latest Go to latest Published: Jun 19, 2025 License: MIT Imports: 60 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 cmtdb.DB) *chain.Chain
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 cmtdb.DB) *chain.Chain

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) RpcBlockResults ¶ added in v0.3.16

func (n *Node) RpcBlockResults(_ *rpctypes.Context, heightPtr *int64) (*ctypes.ResultBlockResults, error)

RpcBlockResults returns the results of executing a block, including events

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) RpcTxSearch ¶ added in v0.3.16

func (n *Node) RpcTxSearch(
	ctx *rpctypes.Context,
	query string,
	prove bool,
	pagePtr, perPagePtr *int,
	orderBy string,
) (*ctypes.ResultTxSearch, error)

RpcTxSearch searches for transactions with events matching the query

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)

func (*Node) ValidateSyncedBlock ¶ added in v0.3.16

func (n *Node) ValidateSyncedBlock(blk *block.Block, nowNanoTimestamp uint64) error

Process process a block.

Source Files ¶

View all Source files

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