p2p

package
v1.2.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewVirtualStream

func NewVirtualStream(s p2p.Stream) *virtualStream

Types

type BuffMessage

type BuffMessage struct {
	bytes.Buffer
}

func (*BuffMessage) Marshal

func (b *BuffMessage) Marshal() ([]byte, error)

func (*BuffMessage) ProtoMessage

func (b *BuffMessage) ProtoMessage()

func (*BuffMessage) Unmarshal

func (b *BuffMessage) Unmarshal(p []byte) error

Directories

Path Synopsis
internal/handshake/pb
Package pb holds only Protocol Buffer definitions and generated code.
Package pb holds only Protocol Buffer definitions and generated code.
internal/headers/pb
Package pb holds only Protocol Buffer definitions and generated code.
Package pb holds only Protocol Buffer definitions and generated code.
internal/reacher
Package reacher runs a background worker that will ping peers from an internal queue and report back the reachability to the notifier.
Package reacher runs a background worker that will ping peers from an internal queue and report back the reachability to the notifier.

Jump to

Keyboard shortcuts

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