validators

Documentation

Index

• type MessageValidator
• type SenderValidator
  • func NewSenderValidator(sender flow.Identifier) *SenderValidator
  • func (sv *SenderValidator) Validate(msg message.Message) bool
• type TargetValidator
  • func NewTargetValidator(log zerolog.Logger, target flow.Identifier) *TargetValidator
  • func (tv *TargetValidator) Validate(msg message.Message) bool

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

func (*SenderValidator) Validate

func (sv *SenderValidator) Validate(msg message.Message) bool

Validate returns true if the message origin id is different from the 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

func (*TargetValidator) Validate

func (tv *TargetValidator) Validate(msg message.Message) bool

Validate returns true if the message is intended for the given target ID else it returns false