The highest tagged major version is v2.

sendertest

package

v0.1.1 Latest Latest Go to latest Published: Jul 30, 2025 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

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

Repository

github.com/luxfi/node

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AppError ¶

type AppError struct {
	NodeID    ids.NodeID
	RequestID uint32
	Code      int32
	Message   string
}

Errors to return

type Sender ¶

type Sender struct {
	SentAppRequest         chan []byte
	SentAppResponse        chan []byte
	SentAppGossip          chan []byte
	SentAppError           chan *AppError
	SentCrossChainRequest  chan []byte
	SentCrossChainResponse chan []byte
}

Sender is a test sender implementation

func NewSender ¶

func NewSender() *Sender

NewSender creates a new test sender

func (*Sender) SendAccepted ¶

func (s *Sender) SendAccepted(_ context.Context, _ ids.NodeID, _ uint32, _ []ids.ID)

func (*Sender) SendAcceptedFrontier ¶

func (s *Sender) SendAcceptedFrontier(_ context.Context, _ ids.NodeID, _ uint32, _ []ids.ID)

func (*Sender) SendAcceptedStateSummary ¶

func (s *Sender) SendAcceptedStateSummary(_ context.Context, _ ids.NodeID, _ uint32, _ []ids.ID)

func (*Sender) SendAncestors ¶

func (s *Sender) SendAncestors(_ context.Context, _ ids.NodeID, _ uint32, _ [][]byte)

func (*Sender) SendAppError ¶

func (s *Sender) SendAppError(_ context.Context, nodeID ids.NodeID, requestID uint32, code int32, msg string) error

func (*Sender) SendAppGossip ¶

func (s *Sender) SendAppGossip(_ context.Context, _ appsender.SendConfig, msgBytes []byte) error

func (*Sender) SendAppGossipSpecific ¶

func (s *Sender) SendAppGossipSpecific(_ context.Context, _ set.Set[ids.NodeID], msgBytes []byte) error

func (*Sender) SendAppRequest ¶

func (s *Sender) SendAppRequest(_ context.Context, _ set.Set[ids.NodeID], _ uint32, msgBytes []byte) error

func (*Sender) SendAppRequestFailed ¶

func (s *Sender) SendAppRequestFailed(_ context.Context, _ ids.NodeID, _ uint32) error

NetworkAppSender methods

func (*Sender) SendAppResponse ¶

func (s *Sender) SendAppResponse(_ context.Context, _ ids.NodeID, _ uint32, msgBytes []byte) error

func (*Sender) SendChits ¶

func (s *Sender) SendChits(_ context.Context, _ ids.NodeID, _ uint32, _ ids.ID, _ ids.ID, _ ids.ID)

func (*Sender) SendCrossChainAppRequest ¶

func (s *Sender) SendCrossChainAppRequest(_ context.Context, _ ids.ID, _ uint32, msgBytes []byte) error

func (*Sender) SendCrossChainAppResponse ¶

func (s *Sender) SendCrossChainAppResponse(_ context.Context, _ ids.ID, _ uint32, msgBytes []byte) error

func (*Sender) SendGet ¶

func (s *Sender) SendGet(_ context.Context, _ ids.NodeID, _ uint32, _ ids.ID)

func (*Sender) SendGetAccepted ¶

func (s *Sender) SendGetAccepted(_ context.Context, _ set.Set[ids.NodeID], _ uint32, _ []ids.ID)

func (*Sender) SendGetAcceptedFrontier ¶

func (s *Sender) SendGetAcceptedFrontier(_ context.Context, _ set.Set[ids.NodeID], _ uint32)

func (*Sender) SendGetAcceptedStateSummary ¶

func (s *Sender) SendGetAcceptedStateSummary(_ context.Context, _ set.Set[ids.NodeID], _ uint32, _ []uint64)

func (*Sender) SendGetAncestors ¶

func (s *Sender) SendGetAncestors(_ context.Context, _ ids.NodeID, _ uint32, _ ids.ID)

func (*Sender) SendGetStateSummaryFrontier ¶

func (s *Sender) SendGetStateSummaryFrontier(_ context.Context, _ set.Set[ids.NodeID], _ uint32)

func (*Sender) SendGossip ¶

func (s *Sender) SendGossip(_ context.Context, _ []byte)

func (*Sender) SendPullQuery ¶

func (s *Sender) SendPullQuery(_ context.Context, _ set.Set[ids.NodeID], _ uint32, _ ids.ID, _ uint64)

func (*Sender) SendPushQuery ¶

func (s *Sender) SendPushQuery(_ context.Context, _ set.Set[ids.NodeID], _ uint32, _ []byte, _ uint64)

func (*Sender) SendPut ¶

func (s *Sender) SendPut(_ context.Context, _ ids.NodeID, _ uint32, _ []byte)

func (*Sender) SendStateSummaryFrontier ¶

func (s *Sender) SendStateSummaryFrontier(_ context.Context, _ ids.NodeID, _ uint32, _ []byte)

Source Files ¶

View all Source files

sender.go

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