Versions in this module Expand all Collapse all v1 v1.0.0 Jul 11, 2017 Changes in this version + func MockRecv(mock *MockBlocksDeliverer) (*orderer.DeliverResponse, error) + type MockAtomicBroadcastClient struct + BD *MockBlocksDeliverer + func (mabc *MockAtomicBroadcastClient) Broadcast(ctx context.Context, opts ...grpc.CallOption) (orderer.AtomicBroadcast_BroadcastClient, error) + func (mabc *MockAtomicBroadcastClient) Deliver(ctx context.Context, opts ...grpc.CallOption) (orderer.AtomicBroadcast_DeliverClient, error) + type MockBlocksDeliverer struct + CloseCalled chan struct{} + DisconnectCalled chan struct{} + MockRecv func(mock *MockBlocksDeliverer) (*orderer.DeliverResponse, error) + Pos uint64 + RecvCnt int32 + func (mock *MockBlocksDeliverer) Close() + func (mock *MockBlocksDeliverer) Disconnect() + func (mock *MockBlocksDeliverer) Recv() (*orderer.DeliverResponse, error) + func (mock *MockBlocksDeliverer) Send(env *common.Envelope) error + type MockGossipServiceAdapter struct + AddPayloadsCnt int32 + GossipBlockDisseminations chan uint64 + func (*MockGossipServiceAdapter) PeersOfChannel(gossip_common.ChainID) []discovery.NetworkMember + func (mock *MockGossipServiceAdapter) AddPayload(chainID string, payload *gossip_proto.Payload) error + func (mock *MockGossipServiceAdapter) Gossip(msg *gossip_proto.GossipMessage) + type MockLedgerInfo struct + Height uint64 + func (li *MockLedgerInfo) LedgerHeight() (uint64, error) + type Orderer struct + func NewOrderer(port int, t *testing.T) *Orderer + func (*Orderer) Broadcast(orderer.AtomicBroadcast_BroadcastServer) error + func (o *Orderer) ConnCount() int + func (o *Orderer) Deliver(stream orderer.AtomicBroadcast_DeliverServer) error + func (o *Orderer) Fail() + func (o *Orderer) SendBlock(seq uint64) + func (o *Orderer) SetNextExpectedSeek(seq uint64) + func (o *Orderer) Shutdown()
Go to main page