peergov

type OutboundConnectionEvent struct {
	ConnectionId ouroboros.ConnectionId
}

type Peer struct {
	LastActivity   time.Time
	Connection     *PeerConnection
	Address        string
	ReconnectCount int
	ReconnectDelay time.Duration
	Source         PeerSource
	State          PeerState
	Sharable       bool
}

type PeerConnection struct {
	Id              ouroboros.ConnectionId
	VersionData     oprotocol.VersionData
	ProtocolVersion uint
	IsClient        bool
}

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

type PeerGovernorConfig struct {
	PromRegistry         prometheus.Registerer
	Logger               *slog.Logger
	EventBus             *event.EventBus
	ConnManager          *connmanager.ConnectionManager
	PeerRequestFunc      func(peer *Peer) []string
	ReconcileInterval    time.Duration
	MaxReconnectFailures int
	MinHotPeers          int
	InactivityTimeout    time.Duration
	DisableOutbound      bool
}

type PeerSource uint16

type PeerState uint16

type PeerStateChangeEvent struct {
	Address string
	Reason  string
}