mocks

package
v0.0.0-...-95b87ed Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockRetriever 

type BlockRetriever struct {
	mock.Mock
}

func (*BlockRetriever) Block 

func (_m *BlockRetriever) Block(number uint64) *common.Block

type BlockVerifier 

type BlockVerifier struct {
	mock.Mock
}

func (*BlockVerifier) VerifyBlockSignature 

func (_m *BlockVerifier) VerifyBlockSignature(sd []*protoutil.SignedData, config *common.ConfigEnvelope) error

type ChainPuller 

type ChainPuller struct {
	mock.Mock
}

func (*ChainPuller) Close 

func (_m *ChainPuller) Close()

func (*ChainPuller) HeightsByEndpoints 

func (_m *ChainPuller) HeightsByEndpoints() (map[string]uint64, error)

func (*ChainPuller) PullBlock 

func (_m *ChainPuller) PullBlock(seq uint64) *common.Block

type ChannelLister 

type ChannelLister struct {
	mock.Mock
}

func (*ChannelLister) Channels 

func (_m *ChannelLister) Channels() []cluster.ChannelGenesisBlock

func (*ChannelLister) Close 

func (_m *ChannelLister) Close()

type ClusterClient 

type ClusterClient struct {
	mock.Mock
}

func (*ClusterClient) Step 

func (_m *ClusterClient) Step(ctx context.Context, opts ...grpc.CallOption) (orderer.Cluster_StepClient, error)

type Communicator 

type Communicator struct {
	mock.Mock
}

func (*Communicator) Configure 

func (_m *Communicator) Configure(channel string, members []cluster.RemoteNode)

func (*Communicator) Remote 

func (_m *Communicator) Remote(channel string, id uint64) (*cluster.RemoteContext, error)

func (*Communicator) Shutdown 

func (_m *Communicator) Shutdown()

type Dispatcher 

type Dispatcher struct {
	mock.Mock
}

func (*Dispatcher) DispatchConsensus 

func (_m *Dispatcher) DispatchConsensus(ctx context.Context, request *orderer.ConsensusRequest) error

func (*Dispatcher) DispatchSubmit 

func (_m *Dispatcher) DispatchSubmit(ctx context.Context, request *orderer.SubmitRequest) error

type Handler 

type Handler struct {
	mock.Mock
}

func (*Handler) OnConsensus 

func (_m *Handler) OnConsensus(channel string, sender uint64, req *orderer.ConsensusRequest) error

func (*Handler) OnSubmit 

func (_m *Handler) OnSubmit(channel string, sender uint64, req *orderer.SubmitRequest) error

type LedgerFactory 

type LedgerFactory struct {
	mock.Mock
}

func (*LedgerFactory) GetOrCreate 

func (_m *LedgerFactory) GetOrCreate(chainID string) (cluster.LedgerWriter, error)

type LedgerWriter 

type LedgerWriter struct {
	mock.Mock
}

func (*LedgerWriter) Append 

func (_m *LedgerWriter) Append(block *common.Block) error

func (*LedgerWriter) Height 

func (_m *LedgerWriter) Height() uint64

type MetricsProvider 

type MetricsProvider struct {
	mock.Mock
}

func (*MetricsProvider) NewCounter 

func (_m *MetricsProvider) NewCounter(opts metrics.CounterOpts) metrics.Counter

func (*MetricsProvider) NewGauge 

func (_m *MetricsProvider) NewGauge(opts metrics.GaugeOpts) metrics.Gauge

func (*MetricsProvider) NewHistogram 

func (_m *MetricsProvider) NewHistogram(opts metrics.HistogramOpts) metrics.Histogram

type Policy 

type Policy struct {
	EvaluateStub func([]*protoutil.SignedData) error
	// contains filtered or unexported fields
}

func (*Policy) Evaluate 

func (fake *Policy) Evaluate(arg1 []*protoutil.SignedData) error

func (*Policy) EvaluateArgsForCall 

func (fake *Policy) EvaluateArgsForCall(i int) []*protoutil.SignedData

func (*Policy) EvaluateCallCount 

func (fake *Policy) EvaluateCallCount() int

func (*Policy) EvaluateCalls 

func (fake *Policy) EvaluateCalls(stub func([]*protoutil.SignedData) error)

func (*Policy) EvaluateReturns 

func (fake *Policy) EvaluateReturns(result1 error)

func (*Policy) EvaluateReturnsOnCall 

func (fake *Policy) EvaluateReturnsOnCall(i int, result1 error)

func (*Policy) Invocations 

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

type PolicyManager 

type PolicyManager struct {
	GetPolicyStub func(string) (policies.Policy, bool)

	ManagerStub func([]string) (policies.Manager, bool)
	// contains filtered or unexported fields
}

func (*PolicyManager) GetPolicy 

func (fake *PolicyManager) GetPolicy(arg1 string) (policies.Policy, bool)

func (*PolicyManager) GetPolicyArgsForCall 

func (fake *PolicyManager) GetPolicyArgsForCall(i int) string

func (*PolicyManager) GetPolicyCallCount 

func (fake *PolicyManager) GetPolicyCallCount() int

func (*PolicyManager) GetPolicyCalls 

func (fake *PolicyManager) GetPolicyCalls(stub func(string) (policies.Policy, bool))

func (*PolicyManager) GetPolicyReturns 

func (fake *PolicyManager) GetPolicyReturns(result1 policies.Policy, result2 bool)

func (*PolicyManager) GetPolicyReturnsOnCall 

func (fake *PolicyManager) GetPolicyReturnsOnCall(i int, result1 policies.Policy, result2 bool)

func (*PolicyManager) Invocations 

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

func (*PolicyManager) Manager 

func (fake *PolicyManager) Manager(arg1 []string) (policies.Manager, bool)

func (*PolicyManager) ManagerArgsForCall 

func (fake *PolicyManager) ManagerArgsForCall(i int) []string

func (*PolicyManager) ManagerCallCount 

func (fake *PolicyManager) ManagerCallCount() int

func (*PolicyManager) ManagerCalls 

func (fake *PolicyManager) ManagerCalls(stub func([]string) (policies.Manager, bool))

func (*PolicyManager) ManagerReturns 

func (fake *PolicyManager) ManagerReturns(result1 policies.Manager, result2 bool)

func (*PolicyManager) ManagerReturnsOnCall 

func (fake *PolicyManager) ManagerReturnsOnCall(i int, result1 policies.Manager, result2 bool)

type RemoteCommunicator 

type RemoteCommunicator struct {
	mock.Mock
}

func (*RemoteCommunicator) Remote 

func (_m *RemoteCommunicator) Remote(channel string, id uint64) (*cluster.RemoteContext, error)

type SecureDialer 

type SecureDialer struct {
	mock.Mock
}

func (*SecureDialer) Dial 

func (_m *SecureDialer) Dial(address string, verifyFunc cluster.RemoteVerifier) (*grpc.ClientConn, error)

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)

type StepClient 

type StepClient struct {
	mock.Mock
}

func (*StepClient) CloseSend 

func (_m *StepClient) CloseSend() error

func (*StepClient) Context 

func (_m *StepClient) Context() context.Context

func (*StepClient) Header 

func (_m *StepClient) Header() (metadata.MD, error)

func (*StepClient) Recv 

func (_m *StepClient) Recv() (*orderer.StepResponse, error)

func (*StepClient) RecvMsg 

func (_m *StepClient) RecvMsg(m interface{}) error

func (*StepClient) Send 

func (_m *StepClient) Send(_a0 *orderer.StepRequest) error

func (*StepClient) SendMsg 

func (_m *StepClient) SendMsg(m interface{}) error

func (*StepClient) Trailer 

func (_m *StepClient) Trailer() metadata.MD

type StepStream 

type StepStream struct {
	mock.Mock
}

func (*StepStream) Context 

func (_m *StepStream) Context() context.Context

func (*StepStream) Recv 

func (_m *StepStream) Recv() (*orderer.StepRequest, error)

func (*StepStream) RecvMsg 

func (_m *StepStream) RecvMsg(m interface{}) error

func (*StepStream) Send 

func (_m *StepStream) Send(response *orderer.StepResponse) error

func (*StepStream) SendHeader 

func (_m *StepStream) SendHeader(_a0 metadata.MD) error

func (*StepStream) SendMsg 

func (_m *StepStream) SendMsg(m interface{}) error

func (*StepStream) SetHeader 

func (_m *StepStream) SetHeader(_a0 metadata.MD) error

func (*StepStream) SetTrailer 

func (_m *StepStream) SetTrailer(_a0 metadata.MD)

type SubmitClient 

type SubmitClient struct {
	mock.Mock
}

func (*SubmitClient) CloseSend 

func (_m *SubmitClient) CloseSend() error

func (*SubmitClient) Context 

func (_m *SubmitClient) Context() context.Context

func (*SubmitClient) Header 

func (_m *SubmitClient) Header() (metadata.MD, error)

func (*SubmitClient) Recv 

func (_m *SubmitClient) Recv() (*orderer.SubmitResponse, error)

func (*SubmitClient) RecvMsg 

func (_m *SubmitClient) RecvMsg(m interface{}) error

func (*SubmitClient) Send 

func (_m *SubmitClient) Send(request *orderer.SubmitRequest) error

func (*SubmitClient) SendMsg 

func (_m *SubmitClient) SendMsg(m interface{}) error

func (*SubmitClient) Trailer 

func (_m *SubmitClient) Trailer() metadata.MD

type SubmitStream 

type SubmitStream struct {
	mock.Mock
}

func (*SubmitStream) Context 

func (_m *SubmitStream) Context() context.Context

func (*SubmitStream) Recv 

func (_m *SubmitStream) Recv() (*orderer.SubmitRequest, error)

func (*SubmitStream) RecvMsg 

func (_m *SubmitStream) RecvMsg(m interface{}) error

func (*SubmitStream) Send 

func (_m *SubmitStream) Send(response *orderer.SubmitResponse) error

func (*SubmitStream) SendHeader 

func (_m *SubmitStream) SendHeader(_a0 metadata.MD) error

func (*SubmitStream) SendMsg 

func (_m *SubmitStream) SendMsg(m interface{}) error

func (*SubmitStream) SetHeader 

func (_m *SubmitStream) SetHeader(_a0 metadata.MD) error

func (*SubmitStream) SetTrailer 

func (_m *SubmitStream) SetTrailer(_a0 metadata.MD)

type VerifierFactory 

type VerifierFactory struct {
	mock.Mock
}

func (*VerifierFactory) VerifierFromConfig 

func (_m *VerifierFactory) VerifierFromConfig(configuration *common.ConfigEnvelope, channel string) (cluster.BlockVerifier, error)

type VerifierRetriever 

type VerifierRetriever struct {
	mock.Mock
}

func (*VerifierRetriever) RetrieveVerifier 

func (_m *VerifierRetriever) RetrieveVerifier(channel string) cluster.BlockVerifier

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.