validation

type ControlMsgValidationInspector struct {
	component.Component
	events.Noop
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

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

type InspectRPCRequest struct {
	// Nonce adds random value so that when msg req is stored on hero store a unique ID can be created from the struct fields.
	Nonce []byte
	// Peer sender of the message.
	Peer peer.ID
	// contains filtered or unexported fields
}

type InspectorParams struct {
	// Logger the logger used by the inspector.
	Logger zerolog.Logger `validate:"required"`
	// SporkID the current spork ID.
	SporkID flow.Identifier `validate:"required"`
	// Config inspector configuration.
	Config *p2pconfig.RpcValidationInspector `validate:"required"`
	// HeroCacheMetricsFactory the metrics factory.
	HeroCacheMetricsFactory metrics.HeroCacheMetricsFactory `validate:"required"`
	// IdProvider identity provider is used to get the flow identifier for a peer.
	IdProvider module.IdentityProvider `validate:"required"`
	// InspectorMetrics metrics for the validation inspector.
	InspectorMetrics module.GossipSubRpcValidationInspectorMetrics `validate:"required"`
	// RpcTracker tracker used to track iHave RPC's sent and last size.
	RpcTracker p2p.RpcControlTracking `validate:"required"`
	// NetworkingType the networking type of the node.
	NetworkingType network.NetworkingType `validate:"required"`
	// TopicOracle callback used to retrieve the current subscribed topics of the libp2p node.
	// It is set as a callback to avoid circular dependencies between the topic oracle and the inspector.
	TopicOracle func() p2p.TopicProvider `validate:"required"`

	// InvalidControlMessageNotificationConsumer the consumer that will be notified when a misbehavior is detected upon inspection of an RPC.
	// For each RPC, at most one notification is sent to the consumer.
	// Each notification acts as a penalty to the peer's score.
	InvalidControlMessageNotificationConsumer p2p.GossipSubInvCtrlMsgNotifConsumer `validate:"required"`
}

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

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