monitor

Documentation

Index

• func NewCrossShardPeerTopicNotifier(args ArgsCrossShardPeerTopicNotifier) (*crossShardPeerTopicNotifier, error)
• func NewHeartbeatV2Monitor(args ArgHeartbeatV2Monitor) (*heartbeatV2Monitor, error)
• type ArgHeartbeatV2Monitor
• type ArgsCrossShardPeerTopicNotifier

Functions

func NewCrossShardPeerTopicNotifier

func NewCrossShardPeerTopicNotifier(args ArgsCrossShardPeerTopicNotifier) (*crossShardPeerTopicNotifier, error)

NewCrossShardPeerTopicNotifier create a new cross shard peer topic notifier instance

func NewHeartbeatV2Monitor

func NewHeartbeatV2Monitor(args ArgHeartbeatV2Monitor) (*heartbeatV2Monitor, error)

NewHeartbeatV2Monitor creates a new instance of heartbeatV2Monitor

Types

type ArgHeartbeatV2Monitor

type ArgHeartbeatV2Monitor struct {
	Cache                         storage.Cacher
	PubKeyConverter               core.PubkeyConverter
	Marshaller                    marshal.Marshalizer
	MaxDurationPeerUnresponsive   time.Duration
	HideInactiveValidatorInterval time.Duration
	ShardId                       uint32
	PeerTypeProvider              heartbeat.PeerTypeProviderHandler
}

ArgHeartbeatV2Monitor holds the arguments needed to create a new instance of heartbeatV2Monitor

type ArgsCrossShardPeerTopicNotifier

type ArgsCrossShardPeerTopicNotifier struct {
	ShardCoordinator sharding.Coordinator
	PeerShardMapper  heartbeat.PeerShardMapper
}

ArgsCrossShardPeerTopicNotifier represents the arguments for the cross shard peer topic notifier