ouroboros

Oct 21, 2024

Changes in this version

type Network

+ BootstrapPeers []NetworkBootstrapPeer

+ type NetworkBootstrapPeer struct

+ Address string

+ Port uint

Oct 2, 2024

Changes in this version

type ConnectionOptionFunc

+ func WithLogger(logger *slog.Logger) ConnectionOptionFunc

Apr 6, 2024

Changes in this version

type Connection

+ func (c *Connection) Id() ConnectionId

+ type ConnectionId = connection.ConnectionId

Mar 28, 2024

Changes in this version

type Connection

+ func (c *Connection) ProtocolVersion() (uint16, protocol.VersionData)

Mar 15, 2024

Changes in this version

type ConnectionOptionFunc

+ func WithPeerSharing(peerSharing bool) ConnectionOptionFunc

Mar 7, 2024

Changes in this version

type ConnectionOptionFunc

+ func WithLocalTxMonitorConfig(cfg localtxmonitor.Config) ConnectionOptionFunc

Feb 15, 2024

Changes in this version

type ConnectionManagerConfig

+ ConnClosedFunc ConnectionManagerConnClosedFunc

+ type ConnectionManagerConnClosedFunc func(int, error)

Dec 29, 2023

Changes in this version

+ const DefaultConnectTimeout

type Connection

+ func (c *Connection) DialTimeout(proto string, address string, timeout time.Duration) error

Dec 2, 2023

Changes in this version

type ConnectionManager

+ func (c *ConnectionManager) RemoveConnection(connId int)

Nov 29, 2023

Changes in this version

+ type ConnectionManager struct

+ func NewConnectionManager(cfg ConnectionManagerConfig) *ConnectionManager

+ func (c *ConnectionManager) AddConnection(connId int, conn *Connection)

+ func (c *ConnectionManager) AddHost(address string, port uint, tags ...ConnectionManagerTag)

+ func (c *ConnectionManager) AddHostsFromTopology(topology *TopologyConfig)

+ func (c *ConnectionManager) GetConnectionById(id int) *ConnectionManagerConnection

+ func (c *ConnectionManager) GetConnectionsByTags(tags ...ConnectionManagerTag) []*ConnectionManagerConnection

+ type ConnectionManagerConfig struct

+ ErrorFunc ConnectionManagerErrorFunc

+ type ConnectionManagerConnection struct

+ Conn *Connection

+ Id int

+ Tags map[ConnectionManagerTag]bool

+ func (c *ConnectionManagerConnection) AddTags(tags ...ConnectionManagerTag)

+ func (c *ConnectionManagerConnection) RemoveTags(tags ...ConnectionManagerTag)

+ type ConnectionManagerErrorFunc func(int, error)

+ type ConnectionManagerHost struct

+ Address string

+ Port uint

+ Tags map[ConnectionManagerTag]bool

+ type ConnectionManagerTag uint16

+ const ConnectionManagerTagHostLocalRoot

+ const ConnectionManagerTagHostP2PGossip

+ const ConnectionManagerTagHostP2PLedger

+ const ConnectionManagerTagHostProducer

+ const ConnectionManagerTagHostPublicRoot

+ const ConnectionManagerTagNone

+ const ConnectionManagerTagRoleInitiator

+ const ConnectionManagerTagRoleResponder

+ func (c ConnectionManagerTag) String() string

Nov 7, 2023

Changes in this version

+ type TopologyConfig struct

+ LocalRoots []TopologyConfigP2PLocalRoot

+ Producers []TopologyConfigLegacyProducer

+ PublicRoots []TopologyConfigP2PPublicRoot

+ UseLedgerAfterSlot uint64

+ func NewTopologyConfigFromFile(path string) (*TopologyConfig, error)

+ func NewTopologyConfigFromReader(r io.Reader) (*TopologyConfig, error)

+ type TopologyConfigLegacyProducer struct

+ Address string

+ Continent string

+ Port uint16

+ State string

+ Valency uint

+ type TopologyConfigP2PAccessPoint struct

+ Address string

+ Port uint16

+ type TopologyConfigP2PLocalRoot struct

+ AccessPoints []TopologyConfigP2PAccessPoint

+ Advertise bool

+ Valency uint

+ type TopologyConfigP2PPublicRoot struct

+ AccessPoints []TopologyConfigP2PAccessPoint

+ Advertise bool

+ Valency uint

Aug 19, 2023

Changes in this version

+ var NetworkSancho = Network

type ProtocolVersionNtC

+ EnableConwayEra bool

type ProtocolVersionNtN

+ EnableConwayEra bool

May 23, 2023

Changes in this version

type Connection

+ func (c *Connection) PeerSharing() *peersharing.PeerSharing

type ConnectionOptionFunc

+ func WithDelayProtocolStart(delayProtocolStart bool) ConnectionOptionFunc

+ func WithPeerSharingConfig(cfg peersharing.Config) ConnectionOptionFunc

type ProtocolVersionNtN

+ EnablePeerSharingProtocol bool

May 18, 2023

Changes in this version

+ type Connection struct

+ func NewConnection(options ...ConnectionOptionFunc) (*Connection, error)

+ func (c *Connection) BlockFetch() *blockfetch.BlockFetch

+ func (c *Connection) ChainSync() *chainsync.ChainSync

+ func (c *Connection) Close() error

+ func (c *Connection) Dial(proto string, address string) error

+ func (c *Connection) ErrorChan() chan error

+ func (c *Connection) Handshake() *handshake.Handshake

+ func (c *Connection) KeepAlive() *keepalive.KeepAlive

+ func (c *Connection) LocalStateQuery() *localstatequery.LocalStateQuery

+ func (c *Connection) LocalTxMonitor() *localtxmonitor.LocalTxMonitor

+ func (c *Connection) LocalTxSubmission() *localtxsubmission.LocalTxSubmission

+ func (c *Connection) Muxer() *muxer.Muxer

+ func (c *Connection) TxSubmission() *txsubmission.TxSubmission

+ type ConnectionOptionFunc func(*Connection)

May 18, 2023

Changes in this version

+ func GetProtocolVersionsNtC() []uint16

+ func GetProtocolVersionsNtN() []uint16

type Ouroboros

+ func (o *Ouroboros) Handshake() *handshake.Handshake

+ type ProtocolVersionNtC struct

+ EnableAllegraEra bool

+ EnableAlonzoEra bool

+ EnableBabbageEra bool

+ EnableLocalQueryProtocol bool

+ EnableLocalTxMonitorProtocol bool

+ EnableMaryEra bool

+ EnableShelleyEra bool

+ func GetProtocolVersionNtC(version uint16) ProtocolVersionNtC

+ type ProtocolVersionNtN struct

+ EnableAllegraEra bool

+ EnableAlonzoEra bool

+ EnableBabbageEra bool

+ EnableFullDuplex bool

+ EnableKeepAliveProtocol bool

+ EnableMaryEra bool

+ EnableShelleyEra bool

+ func GetProtocolVersionNtN(version uint16) ProtocolVersionNtN

Apr 18, 2023

Changes in this version

type Network

+ PublicRootAddress string

+ PublicRootPort uint

Mar 31, 2023

Changes in this version

+ var NetworkInvalid = Network

+ var NetworkMainnet = Network

+ var NetworkPreprod = Network

+ var NetworkPreview = Network

+ var NetworkTestnet = Network

+ type Network struct

+ Id uint

+ Name string

+ NetworkMagic uint32

+ func NetworkById(id uint) Network

+ func NetworkByName(name string) Network

+ func NetworkByNetworkMagic(networkMagic uint32) Network

+ func (n Network) String() string

+ type Ouroboros struct

+ func New(options ...OuroborosOptionFunc) (*Ouroboros, error)

+ func (o *Ouroboros) BlockFetch() *blockfetch.BlockFetch

+ func (o *Ouroboros) ChainSync() *chainsync.ChainSync

+ func (o *Ouroboros) Close() error

+ func (o *Ouroboros) Dial(proto string, address string) error

+ func (o *Ouroboros) ErrorChan() chan error

+ func (o *Ouroboros) KeepAlive() *keepalive.KeepAlive

+ func (o *Ouroboros) LocalStateQuery() *localstatequery.LocalStateQuery

+ func (o *Ouroboros) LocalTxMonitor() *localtxmonitor.LocalTxMonitor

+ func (o *Ouroboros) LocalTxSubmission() *localtxsubmission.LocalTxSubmission

+ func (o *Ouroboros) Muxer() *muxer.Muxer

+ func (o *Ouroboros) TxSubmission() *txsubmission.TxSubmission

+ type OuroborosOptionFunc func(*Ouroboros)

+ func WithBlockFetchConfig(cfg blockfetch.Config) OuroborosOptionFunc

+ func WithChainSyncConfig(cfg chainsync.Config) OuroborosOptionFunc

+ func WithConnection(conn net.Conn) OuroborosOptionFunc

+ func WithDelayMuxerStart(delayMuxerStart bool) OuroborosOptionFunc

+ func WithErrorChan(errorChan chan error) OuroborosOptionFunc

+ func WithFullDuplex(fullDuplex bool) OuroborosOptionFunc

+ func WithKeepAlive(keepAlive bool) OuroborosOptionFunc

+ func WithKeepAliveConfig(cfg keepalive.Config) OuroborosOptionFunc

+ func WithLocalStateQueryConfig(cfg localstatequery.Config) OuroborosOptionFunc

+ func WithLocalTxSubmissionConfig(cfg localtxsubmission.Config) OuroborosOptionFunc

+ func WithNetwork(network Network) OuroborosOptionFunc

+ func WithNetworkMagic(networkMagic uint32) OuroborosOptionFunc

+ func WithNodeToNode(nodeToNode bool) OuroborosOptionFunc

+ func WithServer(server bool) OuroborosOptionFunc

+ func WithTxSubmissionConfig(cfg txsubmission.Config) OuroborosOptionFunc