Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + func MockRecv(mock *MockBlocksDeliverer) (*orderer.DeliverResponse, error) + type ConnectionProducer struct + GetEndpointsStub func() []comm.EndpointCriteria + NewConnectionStub func() (*grpc.ClientConn, string, error) + UpdateEndpointsStub func([]comm.EndpointCriteria) + func (fake *ConnectionProducer) GetEndpoints() []comm.EndpointCriteria + func (fake *ConnectionProducer) GetEndpointsCallCount() int + func (fake *ConnectionProducer) GetEndpointsCalls(stub func() []comm.EndpointCriteria) + func (fake *ConnectionProducer) GetEndpointsReturns(result1 []comm.EndpointCriteria) + func (fake *ConnectionProducer) GetEndpointsReturnsOnCall(i int, result1 []comm.EndpointCriteria) + func (fake *ConnectionProducer) Invocations() map[string][][]interface{} + func (fake *ConnectionProducer) NewConnection() (*grpc.ClientConn, string, error) + func (fake *ConnectionProducer) NewConnectionCallCount() int + func (fake *ConnectionProducer) NewConnectionCalls(stub func() (*grpc.ClientConn, string, error)) + func (fake *ConnectionProducer) NewConnectionReturns(result1 *grpc.ClientConn, result2 string, result3 error) + func (fake *ConnectionProducer) NewConnectionReturnsOnCall(i int, result1 *grpc.ClientConn, result2 string, result3 error) + func (fake *ConnectionProducer) UpdateEndpoints(arg1 []comm.EndpointCriteria) + func (fake *ConnectionProducer) UpdateEndpointsArgsForCall(i int) []comm.EndpointCriteria + func (fake *ConnectionProducer) UpdateEndpointsCallCount() int + func (fake *ConnectionProducer) UpdateEndpointsCalls(stub func([]comm.EndpointCriteria)) + 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 + func (mock *MockBlocksDeliverer) Close() + func (mock *MockBlocksDeliverer) Disconnect() + func (mock *MockBlocksDeliverer) GetEndpoints() []string + func (mock *MockBlocksDeliverer) Recv() (*orderer.DeliverResponse, error) + func (mock *MockBlocksDeliverer) RecvCount() int32 + func (mock *MockBlocksDeliverer) Send(env *common.Envelope) error + func (mock *MockBlocksDeliverer) UpdateEndpoints(endpoints []string) + type MockGossipServiceAdapter struct + 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) AddPayloadCount() int32 + 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) Resurrect() + func (o *Orderer) SendBlock(seq uint64) + func (o *Orderer) SetNextExpectedSeek(seq uint64) + func (o *Orderer) Shutdown()
Go to main page