gossip

Documentation

Index

• Variables
• func BroadcastHeartbeat()
• func BroadcastLatestMilestoneRequest()
• func BroadcastMilestoneRequests(solidMilestoneIndex milestone.Index, knownLatestMilestone milestone.Index)
• func BroadcastQueue() bqueue.Queue
• func Processor() *processor.Processor
• func Request(hash trinary.Hash, msIndex milestone.Index, preventDiscard ...bool) bool
• func RequestApprovees(cachedTx *tangle.CachedTransaction, msIndex milestone.Index)
• func RequestMilestoneApprovees(cachedMsBndl *tangle.CachedBundle) bool
• func RequestMultiple(hashes trinary.Hashes, msIndex milestone.Index)
• func RequestQueue() rqueue.Queue

Variables

var (
	PLUGIN = node.NewPlugin("Gossip", node.Enabled, configure, run)
)

Functions

func BroadcastHeartbeat

func BroadcastHeartbeat()

BroadcastHeartbeat broadcasts a heartbeat message to every connected peer who supports STING.

func BroadcastLatestMilestoneRequest

func BroadcastLatestMilestoneRequest()

BroadcastLatestMilestoneRequest broadcasts a milestone request for the latest milestone every connected peer who supports STING.

func BroadcastMilestoneRequests

func BroadcastMilestoneRequests(solidMilestoneIndex milestone.Index, knownLatestMilestone milestone.Index)

BroadcastMilestoneRequests broadcasts up to 50 requests for milestones nearest to the current solid milestone index to every connected peer who supports STING.

func BroadcastQueue

func BroadcastQueue() bqueue.Queue

BroadcastQueue returns the broadcast queue instance of the gossip plugin.

func Processor

func Processor() *processor.Processor

Processor returns the message processor instance of the gossip plugin.

func Request

func Request(hash trinary.Hash, msIndex milestone.Index, preventDiscard ...bool) bool

Request enqueues a request to the request queue for the given transaction if it isn't a solid entry point and is not contained in the database already.

func RequestApprovees

func RequestApprovees(cachedTx *tangle.CachedTransaction, msIndex milestone.Index)

RequestApprovees enqueues requests for the approvees of the given transaction to the request queue, if the given transaction is not a solid entry point and neither its approvees are and also not in the database.

func RequestMilestoneApprovees

func RequestMilestoneApprovees(cachedMsBndl *tangle.CachedBundle) bool

RequestMilestoneApprovees enqueues requests for the approvees of the given milestone bundle to the request queue, if the approvees are not solid entry points and not already in the database.

func RequestMultiple

func RequestMultiple(hashes trinary.Hashes, msIndex milestone.Index)

RequestMultiple works like Request but takes multiple transaction hashes.

func RequestQueue

func RequestQueue() rqueue.Queue

RequestQueue returns the request queue instance of the gossip plugin.