mock

Nov 27, 2022

Changes in this version

+ func NewBlock(seqNum uint64, previousHash []byte) *common.Block

Apr 8, 2022

Changes in this version

type Orderer

+ SelfC chan struct{}

Feb 27, 2022

Changes in this version

+ const MockTxSize

+ type Orderer struct

+ GrpcServer *grpc.Server

+ Listener net.Listener

+ TxCs []chan struct{}

+ func NewOrderer(txCs []chan struct{}, credentials credentials.TransportCredentials) (*Orderer, error)

+ func (o *Orderer) Addrs() string

+ func (o *Orderer) Broadcast(srv orderer.AtomicBroadcast_BroadcastServer) error

+ func (o *Orderer) Deliver(orderer.AtomicBroadcast_DeliverServer) error

+ func (o *Orderer) Start()

+ func (o *Orderer) Stop()

+ type Peer struct

+ BlkSize uint64

+ GrpcServer *grpc.Server

+ Listener net.Listener

+ TxC chan struct{}

+ func NewPeer(TxC chan struct{}, credentials credentials.TransportCredentials) (*Peer, error)

+ func (p *Peer) Addrs() string

+ func (p *Peer) Deliver(peer.Deliver_DeliverServer) error

+ func (p *Peer) DeliverFiltered(srv peer.Deliver_DeliverFilteredServer) error

+ func (p *Peer) DeliverWithPrivateData(peer.Deliver_DeliverWithPrivateDataServer) error

+ func (p *Peer) Pause()

+ func (p *Peer) ProcessProposal(context.Context, *peer.SignedProposal) (*peer.ProposalResponse, error)

+ func (p *Peer) Start()

+ func (p *Peer) Stop()

+ func (p *Peer) Unpause()

+ type Server struct

+ func NewServer(peerN int, credentials credentials.TransportCredentials) (*Server, error)

+ func (s *Server) Addresses() ([]string, string)

+ func (s *Server) OrderAddr() string

+ func (s *Server) PeersAddresses() (peersAddrs []string)

+ func (s *Server) Start()

+ func (s *Server) Stop()