Documentation
¶
Index ¶
- type Ouroboros
- func (o *Ouroboros) BlockfetchClientRequestRange(connId ouroboros.ConnectionId, start ocommon.Point, end ocommon.Point) error
- func (o *Ouroboros) ConfigureListeners(listeners []connmanager.ListenerConfig) []connmanager.ListenerConfig
- func (o *Ouroboros) HandleConnClosedEvent(evt event.Event)
- func (o *Ouroboros) HandleOutboundConnEvent(evt event.Event)
- func (o *Ouroboros) OutboundConnOpts() []ouroboros.ConnectionOptionFunc
- func (o *Ouroboros) RequestPeersFromPeer(peer *peergov.Peer) []string
- type OuroborosConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Ouroboros ¶
type Ouroboros struct {
ConnManager *connmanager.ConnectionManager
PeerGov *peergov.PeerGovernor
ChainsyncState *chainsync.State
EventBus *event.EventBus
Mempool *mempool.Mempool
LedgerState *ledger.LedgerState
// contains filtered or unexported fields
}
func NewOuroboros ¶
func NewOuroboros(cfg OuroborosConfig) *Ouroboros
func (*Ouroboros) BlockfetchClientRequestRange ¶
func (o *Ouroboros) BlockfetchClientRequestRange( connId ouroboros.ConnectionId, start ocommon.Point, end ocommon.Point, ) error
BlockfetchClientRequestRange is called by the ledger when it needs to request a range of block bodies
func (*Ouroboros) ConfigureListeners ¶
func (o *Ouroboros) ConfigureListeners( listeners []connmanager.ListenerConfig, ) []connmanager.ListenerConfig
func (*Ouroboros) HandleConnClosedEvent ¶
func (*Ouroboros) HandleOutboundConnEvent ¶
func (*Ouroboros) OutboundConnOpts ¶
func (o *Ouroboros) OutboundConnOpts() []ouroboros.ConnectionOptionFunc
type OuroborosConfig ¶
type OuroborosConfig struct {
Logger *slog.Logger
EventBus *event.EventBus
ConnManager *connmanager.ConnectionManager
IntersectPoints []ocommon.Point
NetworkMagic uint32
PeerSharing bool
IntersectTip bool
PromRegistry prometheus.Registerer
}
Click to show internal directories.
Click to hide internal directories.