kadcast

package

v0.6.1 Latest Latest Go to latest Published: Dec 21, 2022 License: MIT Imports: 20 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/dusk-network/dusk-blockchain

Links

Open Source Insights

README ¶

Kadcast Peer

p2p/kadcast package provides an embedded gRPC interface that allows the Node to communicate with the actual Kadcast Peer that lives within Rusk and exposes a gRPC server for bidirectional communication.

Documentation ¶

Index ¶

func CreateNetworkClient(ctx context.Context, network, address string, dialTimeout int) (rusk.NetworkClient, *grpc.ClientConn)
func InjectRuskVersion(ctx context.Context) context.Context
type Peer
- func NewKadcastPeer(pCtx context.Context, eventBus *eventbus.EventBus, ...) *Peer
- func (p *Peer) Close()
- func (p *Peer) Launch()
type Reader
- func NewReader(ctx context.Context, publisher eventbus.Publisher, g *protocol.Gossip, ...) *Reader
- func (r *Reader) Listen()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateNetworkClient ¶ added in v0.6.0

func CreateNetworkClient(ctx context.Context, network, address string, dialTimeout int) (rusk.NetworkClient, *grpc.ClientConn)

CreateNetworkClient creates a client for the Kadcast network layer.

func InjectRuskVersion ¶ added in v0.6.0

func InjectRuskVersion(ctx context.Context) context.Context

InjectRuskVersion injects the rusk version into the grpc headers.

Types ¶

type Peer ¶

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

Peer is a wrapper for both kadcast grpc sides.

func NewKadcastPeer ¶ added in v0.4.4

func NewKadcastPeer(pCtx context.Context, eventBus *eventbus.EventBus, processor *peer.MessageProcessor, gossip *protocol.Gossip) *Peer

NewKadcastPeer returns a new kadcast (gRPC interface) peer instance.

func (*Peer) Close ¶ added in v0.4.0

func (p *Peer) Close()

Close terminates kadcast peer instance.

func (*Peer) Launch ¶ added in v0.4.0

func (p *Peer) Launch()

Launch starts kadcast peer reader and writers, binds them to the event buss, and establishes connection to rusk network server.

type Reader ¶ added in v0.4.0

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

Reader is a proxy between Kadcast grpc service and Message Processor. It receives a wire message and ,if it's valid, redirects it to Message Processor. In addition, it turns any response message from Processor into topics.KadcastPoint EventBus message.

func NewReader ¶ added in v0.4.0

func NewReader(ctx context.Context, publisher eventbus.Publisher, g *protocol.Gossip, p *peer.MessageProcessor, rusk rusk.NetworkClient) *Reader

NewReader makes a new Kadcast reader.

func (*Reader) Listen ¶ added in v0.4.4

func (r *Reader) Listen()

Listen starts accepting and processing stream data.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
writer

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