p2p

type Agent interface {
	lifecycle.StartStopper
	nodestats.StatsReporter
	// BroadcastOutbound sends a broadcast message to the whole network
	BroadcastOutbound(ctx context.Context, msg proto.Message) (err error)
	// UnicastOutbound sends a unicast message to the given address
	UnicastOutbound(_ context.Context, peer peer.AddrInfo, msg proto.Message) (err error)
	// Info returns agents' peer info.
	Info() (peer.AddrInfo, error)
	// Self returns the self network address
	Self() ([]multiaddr.Multiaddr, error)
	// ConnectedPeers returns the connected peers' info
	ConnectedPeers() ([]peer.AddrInfo, error)
	// BlockPeer blocks the peer in p2p layer
	BlockPeer(string)
}

type Config struct {
	Host           string   `yaml:"host"`
	Port           int      `yaml:"port"`
	ExternalHost   string   `yaml:"externalHost"`
	ExternalPort   int      `yaml:"externalPort"`
	BootstrapNodes []string `yaml:"bootstrapNodes"`
	MasterKey      string   `yaml:"masterKey"` // master key will be PrivateKey if not set.
	// RelayType is the type of P2P network relay. By default, the value is empty, meaning disabled. Two relay types
	// are supported: active, nat.
	RelayType         string              `yaml:"relayType"`
	ReconnectInterval time.Duration       `yaml:"reconnectInterval"`
	RateLimit         p2p.RateLimitConfig `yaml:"rateLimit"`
	EnableRateLimit   bool                `yaml:"enableRateLimit"`
	PrivateNetworkPSK string              `yaml:"privateNetworkPSK"`
	MaxPeers          int                 `yaml:"maxPeers"`
	MaxMessageSize    int                 `yaml:"maxMessageSize"`
	RpcMsgCacheSize   int                 `yaml:"rpcMsgCacheSize"`
	RpcDedupCacheSize int                 `yaml:"rpcDedupCacheSize"`
}

type HandleBroadcastInbound func(context.Context, uint32, string, proto.Message)

type HandleUnicastInboundAsync func(context.Context, uint32, peer.AddrInfo, proto.Message)

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

type ValidateBroadcastInbound func(proto.Message) (bool, error)