network

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

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.
	KeyPair        *PeerKeyPair    // keypair for the peer.
	BootstrapPeers []peer.AddrInfo // a list of seed peers to connect to.
	Validators     []peer.ID       // a list of known peers (in case of partition node this list must contain all validators).
}

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

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

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
}