firewall

package

v0.2.0 Latest Latest Go to latest Published: Oct 15, 2025 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aerium-network/aerium

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Config
- func DefaultConfig() *Config
- func (conf *Config) BasicCheck() error
type Firewall
- func NewFirewall(conf *Config, network network.Network, peerSet *peerset.PeerSet, ...) (*Firewall, error)
type PeerBannedError
- func (e PeerBannedError) Error() string
type RateLimit

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrGossipMessage = errors.New("receive stream message as gossip message")

ErrGossipMessage is returned when a stream message sends as gossip message.

View Source

var ErrMisMatchConsensusHeight = errors.New("bundle and message consensus height mismatch")

ErrMisMatchConsensusHeight is returned when the bundle height mismatches with the message consensus height.

View Source

var ErrNetworkMismatch = errors.New("bundle is not for this network")

ErrNetworkMismatch is returned when the bundle doesn't belong to this network.

View Source

var ErrStreamMessage = errors.New("receive gossip message as stream message")

ErrStreamMessage is returned when a gossip message sends as stream message.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	BannedNets []string  `toml:"banned_nets"`
	RateLimit  RateLimit `toml:"rate_limit"`
}

func DefaultConfig ¶

func DefaultConfig() *Config

func (*Config) BasicCheck ¶

func (conf *Config) BasicCheck() error

BasicCheck performs basic checks on the configuration.

type Firewall ¶

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

Firewall check packets before passing them to sync module.

func NewFirewall ¶

func NewFirewall(conf *Config, network network.Network, peerSet *peerset.PeerSet, state state.Facade,
) (*Firewall, error)

func (*Firewall) AllowBlockRequest ¶

func (f *Firewall) AllowBlockRequest(gossipMsg *network.GossipMessage) network.PropagationPolicy

func (*Firewall) AllowConsensusRequest ¶

func (f *Firewall) AllowConsensusRequest(gossipMsg *network.GossipMessage) network.PropagationPolicy

func (*Firewall) AllowTransactionRequest ¶

func (f *Firewall) AllowTransactionRequest(_ *network.GossipMessage) network.PropagationPolicy

func (*Firewall) IsBannedAddress ¶

func (f *Firewall) IsBannedAddress(remoteAddr string) bool

IsBannedAddress checks if the remote IP address is banned.

func (*Firewall) OpenGossipBundle ¶

func (f *Firewall) OpenGossipBundle(data []byte, from peer.ID) (*bundle.Bundle, error)

func (*Firewall) OpenStreamBundle ¶

func (f *Firewall) OpenStreamBundle(r io.Reader, from peer.ID) (*bundle.Bundle, error)

type PeerBannedError ¶

type PeerBannedError struct {
	PeerID  lp2pcore.PeerID
	Address string
}

PeerBannedError is returned when a message received from a banned peer-id or banned address.

func (PeerBannedError) Error ¶

func (e PeerBannedError) Error() string

type RateLimit ¶

type RateLimit struct {
	BlockTopic       int `toml:"block_topic"`
	TransactionTopic int `toml:"transaction_topic"`
	ConsensusTopic   int `toml:"consensus_topic"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL