Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageValidator ¶
type MessageValidator interface {
// Validate validates the message and returns true if the message is to be retained and false if it needs to be dropped
Validate(msg message.Message) bool
}
MessageValidator validates the incoming message.
type SenderValidator ¶
type SenderValidator struct {
// contains filtered or unexported fields
}
SenderValidator validates messages by sender ID
func NewSenderValidator ¶
func NewSenderValidator(sender flow.Identifier) *SenderValidator
NewSenderValidator creates and returns a new SenderValidator for the given sender ID
type TargetValidator ¶
type TargetValidator struct {
// contains filtered or unexported fields
}
TargetValidator filters out messages by target ID
func NewTargetValidator ¶
func NewTargetValidator(log zerolog.Logger, target flow.Identifier) *TargetValidator
NewTargetValidator returns a new TargetValidator for the given target id
Source Files
Click to show internal directories.
Click to hide internal directories.