p2p

package

v0.0.0-...-a163439 Latest Latest Go to latest Published: Apr 11, 2022 License: MIT Imports: 31 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/QuarkChain/go-minimal-pbft

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ReadMsgWithPrependedSize(stream stream.Stream) ([]byte, error)
func RunDevp2p(state *consensus.ConsensusState, obsvC chan consensus.MsgInfo, ...) func(ctx context.Context) error
func Send(ctx context.Context, h host.Host, peer peer.ID, topic string, msg interface{}) (stream.Stream, error)
func SendRPC(ctx context.Context, h host.Host, peer peer.ID, topic string, req interface{}, ...) error
func SplitAndTrim(input string) (ret []string)
func WriteMsgWithPrependedSize(stream network.Stream, msg []byte) error
type BlockSync
- func NewBlockSync(h host.Host, chainState consensus.ChainState, blockStore consensus.BlockStore, ...) *BlockSync
- func (bs *BlockSync) LastChainState() consensus.ChainState
- func (bs *BlockSync) Start(ctx context.Context)
- func (bs *BlockSync) WaitDone() error
type GetFullBlockRequest
type GetLatestMessagesRequest
type GetLatestMessagesResponse
type HelloRequest
- func (req *HelloRequest) ValidateBasic() error
type HelloResponse
- func (req *HelloResponse) ValidateBasic() error
type PeerHandler
type Server
- func NewP2PServer(ctx context.Context, blockStore consensus.BlockStore, ...) (*Server, error)
- func (server *Server) Run(ctx context.Context) error
- func (server *Server) SetConsensusState(cs *consensus.ConsensusState)

Constants ¶

View Source

const (
	MsgProposal        = 0x01
	MsgVote            = 0x02
	MsgVerifiedBlock   = 0x03
	MsgHelloRequest    = 0x04
	MsgHelloResponse   = 0x05
	TopicHello         = "/mpbft/dev/hello/1.0.0"
	TopicFullBlock     = "/mpbft/dev/fullblock/1.0.0"
	TopicConsensusSync = "/mpbft/dev/consensus_sync/1.0.0"
)

Variables ¶

View Source

var TestMode bool

Functions ¶

func ReadMsgWithPrependedSize ¶

func ReadMsgWithPrependedSize(stream stream.Stream) ([]byte, error)

func RunDevp2p ¶

func RunDevp2p(
	state *consensus.ConsensusState,
	obsvC chan consensus.MsgInfo,
	sendC chan consensus.Message,
	priv crypto.PrivKey,
	port uint,
	networkID string,
	bootstrapPeers string,
	nodeName string,
	rootCtxCancel context.CancelFunc) func(ctx context.Context) error

func Send ¶

func Send(ctx context.Context, h host.Host, peer peer.ID, topic string, msg interface{}) (stream.Stream, error)

func SendRPC ¶

func SendRPC(ctx context.Context, h host.Host, peer peer.ID, topic string, req interface{}, resp interface{}) error

func SplitAndTrim ¶

func SplitAndTrim(input string) (ret []string)

SplitAndTrim splits input separated by a comma and trims excessive white space from the substrings.

func WriteMsgWithPrependedSize ¶

func WriteMsgWithPrependedSize(stream network.Stream, msg []byte) error

Types ¶

type BlockSync ¶

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

func NewBlockSync ¶

func NewBlockSync(h host.Host, chainState consensus.ChainState, blockStore consensus.BlockStore, executor consensus.BlockExecutor, obsvC chan consensus.MsgInfo) *BlockSync

func (*BlockSync) LastChainState ¶

func (bs *BlockSync) LastChainState() consensus.ChainState

func (*BlockSync) Start ¶

func (bs *BlockSync) Start(ctx context.Context)

func (*BlockSync) WaitDone ¶

func (bs *BlockSync) WaitDone() error

type GetFullBlockRequest ¶

type GetFullBlockRequest struct {
	Height uint64
}

type GetLatestMessagesRequest ¶

type GetLatestMessagesRequest struct {
}

type GetLatestMessagesResponse ¶

type GetLatestMessagesResponse struct {
	MessageData [][]byte
}

type HelloRequest ¶

type HelloRequest struct {
	LastHeight uint64
}

func (*HelloRequest) ValidateBasic ¶

func (req *HelloRequest) ValidateBasic() error

type HelloResponse ¶

type HelloResponse struct {
	LastHeight uint64
}

func (*HelloResponse) ValidateBasic ¶

func (req *HelloResponse) ValidateBasic() error

type PeerHandler ¶

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

type Server ¶

type Server struct {
	Host host.Host
	// contains filtered or unexported fields
}

func NewP2PServer ¶

func NewP2PServer(
	ctx context.Context,
	blockStore consensus.BlockStore,
	obsvC chan consensus.MsgInfo,
	sendC chan consensus.Message,
	priv crypto.PrivKey,
	port uint,
	networkID string,
	bootstrapPeers string,
	nodeName string,
	rootCtxCancel context.CancelFunc,
) (*Server, error)

func (*Server) Run ¶

func (server *Server) Run(ctx context.Context) error

func (*Server) SetConsensusState ¶

func (server *Server) SetConsensusState(cs *consensus.ConsensusState)

Source Files ¶

View all Source files

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