mocks

package
v1.4.12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MockRecv 

func MockRecv(mock *MockBlocksDeliverer) (*orderer.DeliverResponse, error)

MockRecv mock for the Recv function

Types

type ConnectionProducer added in v1.4.4 

type ConnectionProducer struct {
	GetEndpointsStub func() []comm.EndpointCriteria

	NewConnectionStub func() (*grpc.ClientConn, string, error)

	UpdateEndpointsStub func([]comm.EndpointCriteria)
	// contains filtered or unexported fields
}

func (*ConnectionProducer) GetEndpoints added in v1.4.4 

func (fake *ConnectionProducer) GetEndpoints() []comm.EndpointCriteria

func (*ConnectionProducer) GetEndpointsCallCount added in v1.4.4 

func (fake *ConnectionProducer) GetEndpointsCallCount() int

func (*ConnectionProducer) GetEndpointsCalls added in v1.4.4 

func (fake *ConnectionProducer) GetEndpointsCalls(stub func() []comm.EndpointCriteria)

func (*ConnectionProducer) GetEndpointsReturns added in v1.4.4 

func (fake *ConnectionProducer) GetEndpointsReturns(result1 []comm.EndpointCriteria)

func (*ConnectionProducer) GetEndpointsReturnsOnCall added in v1.4.4 

func (fake *ConnectionProducer) GetEndpointsReturnsOnCall(i int, result1 []comm.EndpointCriteria)

func (*ConnectionProducer) Invocations added in v1.4.4 

func (fake *ConnectionProducer) Invocations() map[string][][]interface{}

func (*ConnectionProducer) NewConnection added in v1.4.4 

func (fake *ConnectionProducer) NewConnection() (*grpc.ClientConn, string, error)

func (*ConnectionProducer) NewConnectionCallCount added in v1.4.4 

func (fake *ConnectionProducer) NewConnectionCallCount() int

func (*ConnectionProducer) NewConnectionCalls added in v1.4.4 

func (fake *ConnectionProducer) NewConnectionCalls(stub func() (*grpc.ClientConn, string, error))

func (*ConnectionProducer) NewConnectionReturns added in v1.4.4 

func (fake *ConnectionProducer) NewConnectionReturns(result1 *grpc.ClientConn, result2 string, result3 error)

func (*ConnectionProducer) NewConnectionReturnsOnCall added in v1.4.4 

func (fake *ConnectionProducer) NewConnectionReturnsOnCall(i int, result1 *grpc.ClientConn, result2 string, result3 error)

func (*ConnectionProducer) UpdateEndpoints added in v1.4.4 

func (fake *ConnectionProducer) UpdateEndpoints(arg1 []comm.EndpointCriteria)

func (*ConnectionProducer) UpdateEndpointsArgsForCall added in v1.4.4 

func (fake *ConnectionProducer) UpdateEndpointsArgsForCall(i int) []comm.EndpointCriteria

func (*ConnectionProducer) UpdateEndpointsCallCount added in v1.4.4 

func (fake *ConnectionProducer) UpdateEndpointsCallCount() int

func (*ConnectionProducer) UpdateEndpointsCalls added in v1.4.4 

func (fake *ConnectionProducer) UpdateEndpointsCalls(stub func([]comm.EndpointCriteria))

type MockAtomicBroadcastClient 

type MockAtomicBroadcastClient struct {
	BD *MockBlocksDeliverer
}

func (*MockAtomicBroadcastClient) Broadcast 

func (mabc *MockAtomicBroadcastClient) Broadcast(ctx context.Context, opts ...grpc.CallOption) (orderer.AtomicBroadcast_BroadcastClient, error)

func (*MockAtomicBroadcastClient) Deliver 

func (mabc *MockAtomicBroadcastClient) Deliver(ctx context.Context, opts ...grpc.CallOption) (orderer.AtomicBroadcast_DeliverClient, error)

type MockBlocksDeliverer 

type MockBlocksDeliverer struct {
	DisconnectCalled chan struct{}
	CloseCalled      chan struct{}
	Pos              uint64
	grpc.ClientStream

	MockRecv func(mock *MockBlocksDeliverer) (*orderer.DeliverResponse, error)
	// contains filtered or unexported fields
}

MockBlocksDeliverer mocking structure of BlocksDeliverer interface to initialize the blocks provider implementation

func (*MockBlocksDeliverer) Close 

func (mock *MockBlocksDeliverer) Close()

func (*MockBlocksDeliverer) Disconnect 

func (mock *MockBlocksDeliverer) Disconnect()

func (*MockBlocksDeliverer) GetEndpoints added in v1.1.0 

func (mock *MockBlocksDeliverer) GetEndpoints() []string

func (*MockBlocksDeliverer) Recv 

func (mock *MockBlocksDeliverer) Recv() (*orderer.DeliverResponse, error)

Recv gets responses from the ordering service, currently mocked to return only one response with empty block.

func (*MockBlocksDeliverer) RecvCount added in v1.4.0 

func (mock *MockBlocksDeliverer) RecvCount() int32

RecvCount returns the number of times Recv has been called.

func (*MockBlocksDeliverer) Send 

func (mock *MockBlocksDeliverer) Send(env *common.Envelope) error

Send sends the envelope with request for the blocks for ordering service currently mocked and not doing anything

func (*MockBlocksDeliverer) UpdateEndpoints added in v1.1.0 

func (mock *MockBlocksDeliverer) UpdateEndpoints(endpoints []string)

type MockGossipServiceAdapter 

type MockGossipServiceAdapter struct {
	GossipBlockDisseminations chan uint64
	// contains filtered or unexported fields
}

MockGossipServiceAdapter mocking structure for gossip service, used to initialize the blocks providers implementation and asserts the number of function calls used.

func (*MockGossipServiceAdapter) AddPayload 

func (mock *MockGossipServiceAdapter) AddPayload(chainID string, payload *gossip_proto.Payload) error

AddPayload adds gossip payload to the local state transfer buffer

func (*MockGossipServiceAdapter) AddPayloadCount added in v1.4.0 

func (mock *MockGossipServiceAdapter) AddPayloadCount() int32

AddPayloadCount returns the number of times Recv has been called.

func (*MockGossipServiceAdapter) Gossip 

func (mock *MockGossipServiceAdapter) Gossip(msg *gossip_proto.GossipMessage)

Gossip message to the all peers

func (*MockGossipServiceAdapter) PeersOfChannel 

func (*MockGossipServiceAdapter) PeersOfChannel(gossip_common.ChainID) []discovery.NetworkMember

PeersOfChannel returns the slice with peers participating in given channel

type MockLedgerInfo 

type MockLedgerInfo struct {
	Height uint64
}

MockLedgerInfo mocking implementation of LedgerInfo interface, needed for test initialization purposes

func (*MockLedgerInfo) LedgerHeight 

func (li *MockLedgerInfo) LedgerHeight() (uint64, error)

LedgerHeight returns mocked value to the ledger height

type Orderer 

type Orderer struct {
	net.Listener
	*grpc.Server
	// contains filtered or unexported fields
}

func NewOrderer 

func NewOrderer(port int, t *testing.T) *Orderer

func (*Orderer) Broadcast 

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

func (*Orderer) ConnCount 

func (o *Orderer) ConnCount() int

func (*Orderer) Deliver 

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

func (*Orderer) Fail 

func (o *Orderer) Fail()

func (*Orderer) Resurrect added in v1.1.0 

func (o *Orderer) Resurrect()

func (*Orderer) SendBlock 

func (o *Orderer) SendBlock(seq uint64)

func (*Orderer) SetNextExpectedSeek 

func (o *Orderer) SetNextExpectedSeek(seq uint64)

func (*Orderer) Shutdown 

func (o *Orderer) Shutdown()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.