gossip

package
v1.11.12 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2024 License: BSD-3-Clause Imports: 19 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidNumValidators     = errors.New("num validators cannot be negative")
	ErrInvalidNumNonValidators  = errors.New("num non-validators cannot be negative")
	ErrInvalidNumPeers          = errors.New("num peers cannot be negative")
	ErrInvalidNumToGossip       = errors.New("must gossip to at least one peer")
	ErrInvalidDiscardedSize     = errors.New("discarded size cannot be negative")
	ErrInvalidTargetGossipSize  = errors.New("target gossip size cannot be negative")
	ErrInvalidRegossipFrequency = errors.New("re-gossip frequency cannot be negative")
)

Functions

func Every 

func Every(ctx context.Context, log logging.Logger, gossiper Gossiper, frequency time.Duration)

Every calls [Gossip] every [frequency] amount of time.

func MarshalAppGossip added in v1.11.1 

func MarshalAppGossip(gossip [][]byte) ([]byte, error)

func MarshalAppRequest added in v1.11.1 

func MarshalAppRequest(filter, salt []byte) ([]byte, error)

func MarshalAppResponse added in v1.11.1 

func MarshalAppResponse(gossip [][]byte) ([]byte, error)

func ParseAppGossip added in v1.11.1 

func ParseAppGossip(bytes []byte) ([][]byte, error)

func ParseAppRequest added in v1.11.1 

func ParseAppRequest(bytes []byte) (*bloom.ReadFilter, ids.ID, error)

func ParseAppResponse added in v1.11.1 

func ParseAppResponse(bytes []byte) ([][]byte, error)

func ResetBloomFilterIfNeeded 

func ResetBloomFilterIfNeeded(
	bloomFilter *BloomFilter,
	targetElements int,
) (bool, error)

ResetBloomFilterIfNeeded resets a bloom filter if it breaches [targetFalsePositiveProbability].

If [targetElements] exceeds [minTargetElements], the size of the bloom filter will grow to maintain the same [targetFalsePositiveProbability].

Returns true if the bloom filter was reset.

Types

type BloomFilter 

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

func NewBloomFilter 

func NewBloomFilter(
	registerer prometheus.Registerer,
	namespace string,
	minTargetElements int,
	targetFalsePositiveProbability,
	resetFalsePositiveProbability float64,
) (*BloomFilter, error)

NewBloomFilter returns a new instance of a bloom filter with at least [minTargetElements] elements anticipated at any moment, and a false positive probability of [targetFalsePositiveProbability]. If the false positive probability exceeds [resetFalsePositiveProbability], the bloom filter will be reset.

Invariant: The returned bloom filter is not safe to reset concurrently with other operations. However, it is otherwise safe to access concurrently.

func (*BloomFilter) Add 

func (b *BloomFilter) Add(gossipable Gossipable)

func (*BloomFilter) Has 

func (b *BloomFilter) Has(gossipable Gossipable) bool

func (*BloomFilter) Marshal added in v1.10.18 

func (b *BloomFilter) Marshal() ([]byte, []byte)

type BranchingFactor added in v1.11.2 

type BranchingFactor struct {
	// StakePercentage determines the percentage of stake that should have
	// gossip sent to based on the inverse CDF of stake weights. This value does
	// not account for the connectivity of the nodes.
	StakePercentage float64
	// Validators specifies the number of connected validators, in addition to
	// any validators sent from the StakePercentage parameter, to send gossip
	// to. These validators are sampled uniformly rather than by stake.
	Validators int
	// NonValidators specifies the number of connected non-validators to send
	// gossip to.
	NonValidators int
	// Peers specifies the number of connected validators or non-validators, in
	// addition to the number sent due to other configs, to send gossip to.
	Peers int
}

func (*BranchingFactor) Verify added in v1.11.2 

func (b *BranchingFactor) Verify() error

type EmptySet added in v1.11.2 

type EmptySet[T Gossipable] struct{}

func (EmptySet[T]) Add added in v1.11.2 

func (EmptySet[T]) Add(T) error

func (EmptySet[_]) GetFilter added in v1.11.2 

func (EmptySet[_]) GetFilter() ([]byte, []byte)

func (EmptySet[_]) Gossip added in v1.11.2 

func (EmptySet[_]) Gossip(context.Context) error

func (EmptySet[T]) Has added in v1.11.2 

func (EmptySet[T]) Has(ids.ID) bool

func (EmptySet[T]) Iterate added in v1.11.2 

func (EmptySet[T]) Iterate(func(gossipable T) bool)

type FullSet added in v1.11.2 

type FullSet[T Gossipable] struct{}

func (FullSet[T]) Add added in v1.11.2 

func (FullSet[T]) Add(T) error

func (FullSet[_]) GetFilter added in v1.11.2 

func (FullSet[_]) GetFilter() ([]byte, []byte)

func (FullSet[_]) Gossip added in v1.11.2 

func (FullSet[_]) Gossip(context.Context) error

func (FullSet[T]) Has added in v1.11.2 

func (FullSet[T]) Has(ids.ID) bool

func (FullSet[T]) Iterate added in v1.11.2 

func (FullSet[T]) Iterate(func(gossipable T) bool)

type Gossipable 

type Gossipable interface {
	GossipID() ids.ID
}

Gossipable is an item that can be gossiped across the network

type Gossiper 

type Gossiper interface {
	// Gossip runs a cycle of gossip. Returns an error if we failed to gossip.
	Gossip(ctx context.Context) error
}

Gossiper gossips Gossipables to other nodes

type Handler 

type Handler[T Gossipable] struct {
	p2p.Handler
	// contains filtered or unexported fields
}

func NewHandler 

func NewHandler[T Gossipable](
	log logging.Logger,
	marshaller Marshaller[T],
	set Set[T],
	metrics Metrics,
	targetResponseSize int,
) *Handler[T]

func (Handler[_]) AppGossip added in v1.10.18 

func (h Handler[_]) AppGossip(_ context.Context, nodeID ids.NodeID, gossipBytes []byte)

func (Handler[T]) AppRequest 

func (h Handler[T]) AppRequest(_ context.Context, _ ids.NodeID, _ time.Time, requestBytes []byte) ([]byte, error)

type Marshaller added in v1.10.18 

type Marshaller[T Gossipable] interface {
	MarshalGossip(T) ([]byte, error)
	UnmarshalGossip([]byte) (T, error)
}

Marshaller handles parsing logic for a concrete Gossipable type

type Metrics added in v1.10.18 

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

Metrics that are tracked across a gossip protocol. A given protocol should only use a single instance of Metrics.

func NewMetrics added in v1.10.18 

func NewMetrics(
	metrics prometheus.Registerer,
	namespace string,
) (Metrics, error)

NewMetrics returns a common set of metrics

type NoOpGossiper added in v1.10.18 

type NoOpGossiper struct{}

func (NoOpGossiper) Gossip added in v1.10.18 

func (NoOpGossiper) Gossip(context.Context) error

type PullGossiper 

type PullGossiper[T Gossipable] struct {
	// contains filtered or unexported fields
}

func NewPullGossiper 

func NewPullGossiper[T Gossipable](
	log logging.Logger,
	marshaller Marshaller[T],
	set Set[T],
	client *p2p.Client,
	metrics Metrics,
	pollSize int,
) *PullGossiper[T]

func (*PullGossiper[_]) Gossip 

func (p *PullGossiper[_]) Gossip(ctx context.Context) error

type PushGossiper added in v1.10.18 

type PushGossiper[T Gossipable] struct {
	// contains filtered or unexported fields
}

PushGossiper broadcasts gossip to peers randomly in the network

func NewPushGossiper added in v1.10.18 

func NewPushGossiper[T Gossipable](
	marshaller Marshaller[T],
	mempool Set[T],
	validators p2p.ValidatorSubset,
	client *p2p.Client,
	metrics Metrics,
	gossipParams BranchingFactor,
	regossipParams BranchingFactor,
	discardedSize int,
	targetGossipSize int,
	maxRegossipFrequency time.Duration,
) (*PushGossiper[T], error)

NewPushGossiper returns an instance of PushGossiper

func (*PushGossiper[T]) Add added in v1.10.18 

func (p *PushGossiper[T]) Add(gossipables ...T)

Add enqueues new gossipables to be pushed. If a gossiable is already tracked, it is not added again.

func (*PushGossiper[T]) Gossip added in v1.10.18 

func (p *PushGossiper[T]) Gossip(ctx context.Context) error

Gossip flushes any queued gossipables.

type Set 

type Set[T Gossipable] interface {
	// Add adds a Gossipable to the set. Returns an error if gossipable was not
	// added.
	Add(gossipable T) error
	// Has returns true if the gossipable is in the set.
	Has(gossipID ids.ID) bool
	// Iterate iterates over elements until [f] returns false
	Iterate(f func(gossipable T) bool)
	// GetFilter returns the byte representation of bloom filter and its
	// corresponding salt.
	GetFilter() (bloom []byte, salt []byte)
}

Set holds a set of known Gossipable items

type TestGossiper added in v1.10.18 

type TestGossiper struct {
	GossipF func(ctx context.Context) error
}

func (*TestGossiper) Gossip added in v1.10.18 

func (t *TestGossiper) Gossip(ctx context.Context) error

type ValidatorGossiper 

type ValidatorGossiper struct {
	Gossiper

	NodeID     ids.NodeID
	Validators p2p.ValidatorSet
}

ValidatorGossiper only calls [Gossip] if the given node is a validator

func (ValidatorGossiper) Gossip 

func (v ValidatorGossiper) Gossip(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.