gossipobserver

Documentation

Index

• type GossipObserverUnit
  • func NewGossipObserver(config *PolicyObserverConfig) (*GossipObserverUnit, error)
  • func (p *GossipObserverUnit) AddGossip(msg *pb.GossipMessage) error
  • func (p *GossipObserverUnit) GossipIsObserved(msg *pb.GossipMessage) bool
  • func (p *GossipObserverUnit) LatestGossip() *pb.GossipMessageID
• type PolicyObserverConfig

Types

type GossipObserverUnit

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

func NewGossipObserver

func NewGossipObserver(config *PolicyObserverConfig) (*GossipObserverUnit, error)

func (*GossipObserverUnit) AddGossip

func (p *GossipObserverUnit) AddGossip(msg *pb.GossipMessage) error

Inserts the gossip message into the log of observed gossips

func (*GossipObserverUnit) GossipIsObserved

func (p *GossipObserverUnit) GossipIsObserved(msg *pb.GossipMessage) bool

Returns true if the gossip message has already been observed, returns false otherwise

func (*GossipObserverUnit) LatestGossip

func (p *GossipObserverUnit) LatestGossip() *pb.GossipMessageID

hacky af...

type PolicyObserverConfig

type PolicyObserverConfig struct {
	// Output directory of the logfiles
	OutputDirectory string

	// The prefix used on the logfile names
	LogfilePrefix string

	// The capacity of the in-memory queue. When the capacity is reached, the
	// least recently element is evicted from the queue.
	Capacity int
}