gossip

type BloomChecker interface {
	Contains(hash []byte, salt []byte) bool
}

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

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
}

type Cacher[K comparable, V any] interface {
	Get(key K) (V, bool)
	Put(key K, value V)
}

type Deque[T any] interface {
	PushRight(T) bool
	PushLeft(T) bool
	PopLeft() (T, bool)
	Len() int
}

type EmptyCache[K comparable, V any] struct{}

type FullSet[T Gossipable] struct{}

type Gossipable interface {
	GossipID() ids.ID
}

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

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

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

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

type NoOpGossiper struct{}

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

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

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)
}

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

type ValidatorGossiper struct {
	Gossiper

	NodeID     ids.NodeID
	Validators p2p.ValidatorSet
}