network

type BootstrapConnectRetry struct {
	Count int // number of times to retry connecting to bootstrap peers
	Delay int // delay in seconds
}

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

type MsgQueue interface {
	// Len - returns message queue len
	Len() int
	// PopFront - remove and return first message from queue (queue len is reduced by 1)
	PopFront() any
}

type Observability interface {
	Tracer(name string, options ...trace.TracerOption) trace.Tracer
	Meter(name string, opts ...metric.MeterOption) metric.Meter
	Logger() *slog.Logger
}

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

type PeerConfiguration struct {
	ID                    peer.ID         // peer identifier derived from the KeyPair.PublicKey.
	Address               string          // address to listen for incoming connections. Uses libp2p multiaddress format.
	AnnounceAddrs         []ma.Multiaddr  // callback addresses to announce to other peers, if specified then overwrites any and all default listen addresses
	KeyPair               *PeerKeyPair    // keypair for the peer.
	BootstrapPeers        []peer.AddrInfo // a list of seed peers to connect to.
	BootstrapConnectRetry *BootstrapConnectRetry
}

type PeerKeyPair struct {
	PublicKey  []byte
	PrivateKey []byte
}

type TxProcessor func(ctx context.Context, tx *types.TransactionOrder) error

type TxReceiver func() peer.ID

type ValidatorNetworkOptions struct {
	// How many messages will be buffered (ReceivedChannel) in case of slow consumer.
	// Once buffer is full messages will be dropped (ie not processed)
	// until consumer catches up.
	ReceivedChannelCapacity uint
	TxBufferSize            uint
	TxBufferHashAlgorithm   crypto.Hash

	BlockCertificationTimeout        time.Duration
	BlockProposalTimeout             time.Duration
	LedgerReplicationRequestTimeout  time.Duration
	LedgerReplicationResponseTimeout time.Duration
	HandshakeTimeout                 time.Duration
}