mocks

package
v2.0.0-alpha+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 9, 2019 License: Apache-2.0 Imports: 15 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

MockRecv mock for the Recv function

Types

type MockAtomicBroadcastClient

type MockAtomicBroadcastClient struct {
	BD *MockBlocksDeliverer
}

func (*MockAtomicBroadcastClient) Broadcast

func (*MockAtomicBroadcastClient) Deliver

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

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

Gossip message to the all peers

func (*MockGossipServiceAdapter) PeersOfChannel

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) ConnCount

func (o *Orderer) ConnCount() int

func (*Orderer) Deliver

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()

type SignerSerializer

type SignerSerializer struct {
	SerializeStub func() ([]byte, error)

	SignStub func([]byte) ([]byte, error)
	// contains filtered or unexported fields
}

func (*SignerSerializer) Invocations

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

func (*SignerSerializer) Serialize

func (fake *SignerSerializer) Serialize() ([]byte, error)

func (*SignerSerializer) SerializeCallCount

func (fake *SignerSerializer) SerializeCallCount() int

func (*SignerSerializer) SerializeCalls

func (fake *SignerSerializer) SerializeCalls(stub func() ([]byte, error))

func (*SignerSerializer) SerializeReturns

func (fake *SignerSerializer) SerializeReturns(result1 []byte, result2 error)

func (*SignerSerializer) SerializeReturnsOnCall

func (fake *SignerSerializer) SerializeReturnsOnCall(i int, result1 []byte, result2 error)

func (*SignerSerializer) Sign

func (fake *SignerSerializer) Sign(arg1 []byte) ([]byte, error)

func (*SignerSerializer) SignArgsForCall

func (fake *SignerSerializer) SignArgsForCall(i int) []byte

func (*SignerSerializer) SignCallCount

func (fake *SignerSerializer) SignCallCount() int

func (*SignerSerializer) SignCalls

func (fake *SignerSerializer) SignCalls(stub func([]byte) ([]byte, error))

func (*SignerSerializer) SignReturns

func (fake *SignerSerializer) SignReturns(result1 []byte, result2 error)

func (*SignerSerializer) SignReturnsOnCall

func (fake *SignerSerializer) SignReturnsOnCall(i int, result1 []byte, result2 error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL