mirror of
https://github.com/luxfi/consensus.git
synced 2026-09-24 00:26:58 +00:00
style: fix gofmt formatting issues
This commit is contained in:
@@ -126,4 +126,3 @@ type Fx struct {
|
||||
ID ids.ID
|
||||
Name string
|
||||
}
|
||||
|
||||
|
||||
@@ -22,23 +22,23 @@ type MessageType = uint32
|
||||
|
||||
// Message type constants (cast to uint32 for compatibility with Message.Type)
|
||||
const (
|
||||
PendingTxs MessageType = uint32(core.PendingTxs)
|
||||
PutBlock MessageType = uint32(core.PutBlock)
|
||||
GetBlock MessageType = uint32(core.GetBlock)
|
||||
GetAccepted MessageType = uint32(core.GetAccepted)
|
||||
Accepted MessageType = uint32(core.Accepted)
|
||||
GetAncestors MessageType = uint32(core.GetAncestors)
|
||||
MultiPut MessageType = uint32(core.MultiPut)
|
||||
GetFailed MessageType = uint32(core.GetFailed)
|
||||
QueryFailed MessageType = uint32(core.QueryFailed)
|
||||
Chits MessageType = uint32(core.Chits)
|
||||
ChitsV2 MessageType = uint32(core.ChitsV2)
|
||||
GetAcceptedFrontier MessageType = uint32(core.GetAcceptedFrontier)
|
||||
AcceptedFrontier MessageType = uint32(core.AcceptedFrontier)
|
||||
PendingTxs MessageType = uint32(core.PendingTxs)
|
||||
PutBlock MessageType = uint32(core.PutBlock)
|
||||
GetBlock MessageType = uint32(core.GetBlock)
|
||||
GetAccepted MessageType = uint32(core.GetAccepted)
|
||||
Accepted MessageType = uint32(core.Accepted)
|
||||
GetAncestors MessageType = uint32(core.GetAncestors)
|
||||
MultiPut MessageType = uint32(core.MultiPut)
|
||||
GetFailed MessageType = uint32(core.GetFailed)
|
||||
QueryFailed MessageType = uint32(core.QueryFailed)
|
||||
Chits MessageType = uint32(core.Chits)
|
||||
ChitsV2 MessageType = uint32(core.ChitsV2)
|
||||
GetAcceptedFrontier MessageType = uint32(core.GetAcceptedFrontier)
|
||||
AcceptedFrontier MessageType = uint32(core.AcceptedFrontier)
|
||||
GetAcceptedFrontierFailed MessageType = uint32(core.GetAcceptedFrontierFailed)
|
||||
WarpRequest MessageType = uint32(core.WarpRequest)
|
||||
WarpResponse MessageType = uint32(core.WarpResponse)
|
||||
WarpGossip MessageType = uint32(core.WarpGossip)
|
||||
WarpRequest MessageType = uint32(core.WarpRequest)
|
||||
WarpResponse MessageType = uint32(core.WarpResponse)
|
||||
WarpGossip MessageType = uint32(core.WarpGossip)
|
||||
)
|
||||
|
||||
// SendConfig is an alias for warp.SendConfig for backwards compatibility
|
||||
|
||||
@@ -52,13 +52,13 @@ func (t *TestEngine) SetHeight(height uint64) {
|
||||
|
||||
// Sender is a test implementation of warp.Sender for testing
|
||||
type Sender struct {
|
||||
SendRequestF func(context.Context, set.Set[ids.NodeID], uint32, []byte) error
|
||||
SendResponseF func(context.Context, ids.NodeID, uint32, []byte) error
|
||||
SendErrorF func(context.Context, ids.NodeID, uint32, int32, string) error
|
||||
SendGossipF func(context.Context, warp.SendConfig, []byte) error
|
||||
SendCrossChainRequestF func(context.Context, ids.ID, uint32, []byte) error
|
||||
SendCrossChainResponseF func(context.Context, ids.ID, uint32, []byte) error
|
||||
SendCrossChainErrorF func(context.Context, ids.ID, uint32, int32, string) error
|
||||
SendRequestF func(context.Context, set.Set[ids.NodeID], uint32, []byte) error
|
||||
SendResponseF func(context.Context, ids.NodeID, uint32, []byte) error
|
||||
SendErrorF func(context.Context, ids.NodeID, uint32, int32, string) error
|
||||
SendGossipF func(context.Context, warp.SendConfig, []byte) error
|
||||
SendCrossChainRequestF func(context.Context, ids.ID, uint32, []byte) error
|
||||
SendCrossChainResponseF func(context.Context, ids.ID, uint32, []byte) error
|
||||
SendCrossChainErrorF func(context.Context, ids.ID, uint32, int32, string) error
|
||||
}
|
||||
|
||||
func (s *Sender) SendRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, request []byte) error {
|
||||
|
||||
Reference in New Issue
Block a user