mock

Documentation

Index

• Constants
• func NewBlock(seqNum uint64, previousHash []byte) *common.Block
• type Orderer
  • 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(srv orderer.AtomicBroadcast_DeliverServer) error
  • func (o *Orderer) Start()
  • func (o *Orderer) Stop()
• type Peer
  • 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
  • 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()

Constants

const MockTxSize = 1000

this is the channel size for mock server, peer and orderer when use or send tx to mock server/peer/orderer try not over this size to avoid hang up or over size

Functions

func NewBlock

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

NewBlock constructs a block with no data and no metadata.

Types

type Orderer

type Orderer struct {
	Listener   net.Listener
	GrpcServer *grpc.Server

	TxCs  []chan struct{}
	SelfC chan struct{}
	// contains filtered or unexported fields
}

func NewOrderer

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

func (*Orderer) Addrs

func (o *Orderer) Addrs() string

func (*Orderer) Broadcast

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

func (*Orderer) Deliver

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

func (*Orderer) Start

func (o *Orderer) Start()

func (*Orderer) Stop

func (o *Orderer) Stop()

type Peer

type Peer struct {
	Listener   net.Listener
	GrpcServer *grpc.Server
	BlkSize    uint64
	TxC        chan struct{}
	// contains filtered or unexported fields
}

func NewPeer

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

func (*Peer) Addrs

func (p *Peer) Addrs() string

func (*Peer) Deliver

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

func (*Peer) DeliverFiltered

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

func (*Peer) DeliverWithPrivateData

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

func (*Peer) Pause

func (p *Peer) Pause()

func (*Peer) ProcessProposal

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

func (*Peer) Start

func (p *Peer) Start()

func (*Peer) Stop

func (p *Peer) Stop()

func (*Peer) Unpause

func (p *Peer) Unpause()

type Server

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

func NewServer

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

func (*Server) Addresses

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

func (*Server) OrderAddr

func (s *Server) OrderAddr() string

func (*Server) PeersAddresses

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

func (*Server) Start

func (s *Server) Start()

func (*Server) Stop

func (s *Server) Stop()