gossip

Documentation

Index

• func NewGovernorConfigHandler(govConfigC chan *gossipv1.SignedChainGovernorConfig, ...) *governorConfigHandler
• func NewGovernorStatusHandler(govStatusC chan *gossipv1.SignedChainGovernorStatus, ...) *governorStatusHandler
• func NewHeartbeatsHandler(heartbeatsC chan *gossipv1.Heartbeat, repository storage.Storager, ...) *heartbeatsHandler
• func NewObservationHandler(obsvC chan *common.MsgWithTimeStamp[gossipv1.SignedObservation], ...) *observationHandler
• func NewVaaHandler(p2pNetworkConfig *config.P2pNetworkConfig, metrics metrics.Metrics, ...) *vaaHandler
• type GossipChannels

Functions

func NewGovernorConfigHandler

func NewGovernorConfigHandler(
	govConfigC chan *gossipv1.SignedChainGovernorConfig,
	repository storage.Storager,
	guardian *health.GuardianCheck,
	metrics metrics.Metrics,
	logger *zap.Logger,
) *governorConfigHandler

func NewGovernorStatusHandler

func NewGovernorStatusHandler(
	govStatusC chan *gossipv1.SignedChainGovernorStatus,
	repository storage.Storager,
	guardian *health.GuardianCheck,
	metrics metrics.Metrics,
	logger *zap.Logger,
) *governorStatusHandler

func NewHeartbeatsHandler

func NewHeartbeatsHandler(
	heartbeatsC chan *gossipv1.Heartbeat,
	repository storage.Storager,
	guardian *health.GuardianCheck,
	metrics metrics.Metrics,
	logger *zap.Logger,
) *heartbeatsHandler

func NewObservationHandler

func NewObservationHandler(obsvC chan *common.MsgWithTimeStamp[gossipv1.SignedObservation],
	batchObsvC chan *common.MsgWithTimeStamp[gossipv1.SignedObservationBatch],
	pushFunc processor.ObservationPushFunc,
	pushBatchObsFunc processor.BatchObservationPushFunc,
	guardian *health.GuardianCheck,
	metrics metrics.Metrics,
) *observationHandler

func NewVaaHandler

func NewVaaHandler(
	p2pNetworkConfig *config.P2pNetworkConfig,
	metrics metrics.Metrics,
	signedInC chan *gossipv1.SignedVAAWithQuorum,
	vaaHandlerFunc processor.VAAPushFunc,
	guardian *health.GuardianCheck,
	logger *zap.Logger,
) *vaaHandler

Types

type GossipChannels

type GossipChannels struct {

	// Inbound observations
	ObsvChannel chan *common.MsgWithTimeStamp[gossipv1.SignedObservation]

	// Inbound batch observations.
	BatchObsvC chan *common.MsgWithTimeStamp[gossipv1.SignedObservationBatch]

	// Inbound observation requests - we don't add a environment because we are going to delete this channel
	ObsvReqChannel chan *gossipv1.ObservationRequest

	// Inbound signed VAAs
	SignedInChannel chan *gossipv1.SignedVAAWithQuorum

	// Heartbeat updates
	HeartbeatChannel chan *gossipv1.Heartbeat

	// Governor cfg
	GovConfigChannel chan *gossipv1.SignedChainGovernorConfig

	// Governor status
	GovStatusChannel chan *gossipv1.SignedChainGovernorStatus
}