gossip

Apr 30, 2024

Changes in this version

type BranchingFactor

+ StakePercentage float64

Apr 29, 2024

Changes in this version

+ var ErrInvalidDiscardedSize = errors.New("discarded size cannot be negative")

+ var ErrInvalidNumNonValidators = errors.New("num non-validators cannot be negative")

+ var ErrInvalidNumPeers = errors.New("num peers cannot be negative")

+ var ErrInvalidNumToGossip = errors.New("must gossip to at least one peer")

+ var ErrInvalidNumValidators = errors.New("num validators cannot be negative")

+ var ErrInvalidRegossipFrequency = errors.New("re-gossip frequency cannot be negative")

+ var ErrInvalidTargetGossipSize = errors.New("target gossip size cannot be negative")

+ type BranchingFactor struct

+ NonValidators int

+ Peers int

+ Validators int

+ func (b *BranchingFactor) Verify() error

+ type EmptySet struct

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

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

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

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

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

+ type FullSet struct

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

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

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

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

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

type Set

+ Has func(gossipID ids.ID) bool

Mar 6, 2024

Changes in this version

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

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

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

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

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

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

Feb 29, 2024

Changes in this version

+ type Accumulator interface

+ Add func(gossipables ...T)

type BloomFilter

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

type Gossipable

+ GossipID func() ids.ID

type Handler

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

+ type Marshaller interface

+ MarshalGossip func(T) ([]byte, error)

+ UnmarshalGossip func([]byte) (T, error)

+ type Metrics struct

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

+ type NoOpAccumulator struct

+ func (NoOpAccumulator[T]) Add(...T)

+ func (NoOpAccumulator[_]) Gossip(context.Context) error

+ type NoOpGossiper struct

+ func (NoOpGossiper) Gossip(context.Context) error

+ type PushGossiper struct

+ func NewPushGossiper[T Gossipable](marshaller Marshaller[T], client *p2p.Client, metrics Metrics, ...) *PushGossiper[T]

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

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

+ type TestAccumulator struct

+ AddF func(...T)

+ GossipF func(ctx context.Context) error

+ func (t TestAccumulator[T]) Add(gossipables ...T)

+ func (t TestAccumulator[T]) Gossip(ctx context.Context) error

+ type TestGossiper struct

+ GossipF func(ctx context.Context) error

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

Dec 6, 2023

Changes in this version

+ var ErrInvalidID = errors.New("invalid id")

+ func Every(ctx context.Context, log logging.Logger, gossiper Gossiper, ...)

+ func ResetBloomFilterIfNeeded(bloomFilter *BloomFilter, falsePositiveProbability float64) (bool, error)

+ type BloomFilter struct

+ Bloom *bloomfilter.Filter

+ Salt ids.ID

+ func NewBloomFilter(maxExpectedElements uint64, falsePositiveProbability float64) (*BloomFilter, error)

+ func (b *BloomFilter) Add(gossipable Gossipable)

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

+ type Config struct

+ Namespace string

+ PollSize int

+ type Gossipable interface

+ GetID func() ids.ID

+ Marshal func() ([]byte, error)

+ Unmarshal func(bytes []byte) error

+ type GossipableAny interface

+ type Gossiper interface

+ Gossip func(ctx context.Context) error

+ type Handler struct

+ func NewHandler[T Gossipable](set Set[T], config HandlerConfig, metrics prometheus.Registerer) (*Handler[T], error)

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

+ type HandlerConfig struct

+ Namespace string

+ TargetResponseSize int

+ type PullGossiper struct

+ func NewPullGossiper[T any, U GossipableAny[T]](config Config, log logging.Logger, set Set[U], client *p2p.Client, ...) (*PullGossiper[T, U], error)

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

+ type Set interface

+ Add func(gossipable T) error

+ GetFilter func() (bloom []byte, salt []byte, err error)

+ Iterate func(f func(gossipable T) bool)

+ type ValidatorGossiper struct

+ NodeID ids.NodeID

+ Validators p2p.ValidatorSet

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