Affected by 
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.