p2p

package

v0.0.0-...-ebe581b Latest Latest Go to latest Published: Mar 22, 2024 License: Apache-2.0 Imports: 4 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/PaddlePaddle/PaddleDTX

Documentation ¶

Index ¶

type P2P
- func NewP2P(addrs ...string) *P2P
type Peer
- func (p *Peer) GetConnect() (*grpc.ClientConn, error)
type State

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type P2P ¶

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

P2P defines p2p network

func NewP2P ¶

func NewP2P(addrs ...string) *P2P

NewP2P creates P2P instance

func (*P2P) FreePeer ¶

func (p *P2P) FreePeer()

FreePeer frees a peer

func (*P2P) GetPeer ¶

func (p *P2P) GetPeer(address string) (*Peer, error)

GetPeer gets an available peer

func (*P2P) Stop ¶

func (p *P2P) Stop()

Stop stops p2p, and closes all the grpc connection

type Peer ¶

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

Peer defines peer

func (*Peer) GetConnect ¶

func (p *Peer) GetConnect() (*grpc.ClientConn, error)

GetConnect gets rpc connection

type State ¶

type State uint8

State is the state of the P2P

const (
	// NEW indicates that the P2P is new and ready for providing service
	NEW State = iota

	// CLOSED indicates that the P2P has been closed
	CLOSED
)

Source Files ¶

View all Source files

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