node

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 24, 2026 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BlockAction added in v0.6.0 

func BlockAction(services services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func BlockIDsAction added in v0.11.0 

func BlockIDsAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func BlockSnapshotAction added in v0.11.0 

func BlockSnapshotAction(
	services services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger,
) (fsm.Async, error)

func EndorseBlockAction added in v0.11.0 

func EndorseBlockAction(
	_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger,
) (fsm.Async, error)

func GetBlockAction added in v0.6.0 

func GetBlockAction(services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func GetBlockIdsAction added in v0.6.0 

func GetBlockIdsAction(
	services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger,
) (fsm.Async, error)

func GetPeersAction added in v0.6.0 

func GetPeersAction(services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func GetSignaturesAction added in v0.6.0 

func GetSignaturesAction(
	services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger,
) (fsm.Async, error)

GetSignaturesAction replies to signature requests

func GetSnapshotAction added in v0.11.0 

func GetSnapshotAction(
	services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger,
) (fsm.Async, error)

func MaybeEnableExtendedApi added in v0.5.0 

func MaybeEnableExtendedApi(state state.State, time types.Time) error

func MicroBlockAction added in v0.6.0 

func MicroBlockAction(
	services services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger,
) (fsm.Async, error)

func MicroBlockInvAction added in v0.6.0 

func MicroBlockInvAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

MicroBlockInvAction handles notification about new microblock.

func MicroBlockRequestAction added in v0.6.0 

func MicroBlockRequestAction(
	services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, nl *slog.Logger,
) (fsm.Async, error)

MicroBlockRequestAction handles microblock requests.

func MicroBlockSnapshotAction added in v0.11.0 

func MicroBlockSnapshotAction(
	services services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger,
) (fsm.Async, error)

func MicroSnapshotRequestAction added in v0.11.0 

func MicroSnapshotRequestAction(
	services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger,
) (fsm.Async, error)

func PBBlockAction added in v0.6.0 

func PBBlockAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger) (fsm.Async, error)

PBBlockAction handles protobuf block message.

func PBMicroBlockAction added in v0.6.0 

func PBMicroBlockAction(
	_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger,
) (fsm.Async, error)

func PBTransactionAction added in v0.8.8 

func PBTransactionAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

PBTransactionAction handles protobuf transaction message.

func PeersAction added in v0.8.0 

func PeersAction(services services.Services, mess peer.ProtoMessage, _ *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func ScoreAction added in v0.6.0 

func ScoreAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

func SignaturesAction added in v0.6.0 

func SignaturesAction(_ services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

SignaturesAction receives requested earlier signatures

func TransactionAction added in v0.6.0 

func TransactionAction(s services.Services, mess peer.ProtoMessage, fsm *fsm.FSM, _ *slog.Logger) (fsm.Async, error)

TransactionAction handles new transaction message.

Types

type Action added in v0.6.0 

type Action func(services services.Services, msg peer.ProtoMessage, fsm *fsm.FSM, nl *slog.Logger) (fsm.Async, error)

type Config 

type Config struct {
	AppName  string
	NodeName string
	Listen   string
	DeclAddr string
}

type Node 

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

func NewNode 

func NewNode(
	services services.Services, declAddr proto.TCPAddr, bindAddr proto.TCPAddr, microblockInterval time.Duration,
	enableLightMode bool, netLogger, fsmLogger *slog.Logger,
) *Node

func (*Node) Close 

func (a *Node) Close() error

func (*Node) Run added in v0.5.0 

func (a *Node) Run(
	ctx context.Context, p peer.Parent, internalMessageCh <-chan messages.InternalMessage,
	networkMsgCh <-chan network.InfoMessage, syncPeer *network.SyncPeer,
	generationPeriod uint64,
)

func (*Node) SpawnOutgoingConnections 

func (a *Node) SpawnOutgoingConnections(ctx context.Context)

Source Files

View all Source files

Directories

Path Synopsis
fsm
ng
sync_internal
tasks
storage

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.