...

Package mocks

import "github.com/hyperledger/fabric/orderer/common/cluster/mocks"
Overview
Index

Overview ▾

Index ▾

type BlockRetriever
    func (_m *BlockRetriever) Block(number uint64) *common.Block
type BlockVerifier
    func (_m *BlockVerifier) VerifyBlockSignature(sd []*common.SignedData, config *common.ConfigEnvelope) error
type ChainPuller
    func (_m *ChainPuller) Close()
    func (_m *ChainPuller) HeightsByEndpoints() (map[string]uint64, error)
    func (_m *ChainPuller) PullBlock(seq uint64) *common.Block
type ChannelLister
    func (_m *ChannelLister) Channels() []cluster.ChannelGenesisBlock
    func (_m *ChannelLister) Close()
type ClusterClient
    func (_m *ClusterClient) Step(ctx context.Context, opts ...grpc.CallOption) (orderer.Cluster_StepClient, error)
type Communicator
    func (_m *Communicator) Configure(channel string, members []cluster.RemoteNode)
    func (_m *Communicator) Remote(channel string, id uint64) (*cluster.RemoteContext, error)
    func (_m *Communicator) Shutdown()
type Dispatcher
    func (_m *Dispatcher) DispatchConsensus(ctx context.Context, request *orderer.ConsensusRequest) error
    func (_m *Dispatcher) DispatchSubmit(ctx context.Context, request *orderer.SubmitRequest) error
type Handler
    func (_m *Handler) OnConsensus(channel string, sender uint64, req *orderer.ConsensusRequest) error
    func (_m *Handler) OnSubmit(channel string, sender uint64, req *orderer.SubmitRequest) error
type LedgerFactory
    func (_m *LedgerFactory) GetOrCreate(chainID string) (cluster.LedgerWriter, error)
type LedgerWriter
    func (_m *LedgerWriter) Append(block *common.Block) error
    func (_m *LedgerWriter) Height() uint64
type MetricsProvider
    func (_m *MetricsProvider) NewCounter(opts metrics.CounterOpts) metrics.Counter
    func (_m *MetricsProvider) NewGauge(opts metrics.GaugeOpts) metrics.Gauge
    func (_m *MetricsProvider) NewHistogram(opts metrics.HistogramOpts) metrics.Histogram
type SecureDialer
    func (_m *SecureDialer) Dial(address string, verifyFunc cluster.RemoteVerifier) (*grpc.ClientConn, error)
type StepClient
    func (_m *StepClient) CloseSend() error
    func (_m *StepClient) Context() context.Context
    func (_m *StepClient) Header() (metadata.MD, error)
    func (_m *StepClient) Recv() (*orderer.StepResponse, error)
    func (_m *StepClient) RecvMsg(m interface{}) error
    func (_m *StepClient) Send(_a0 *orderer.StepRequest) error
    func (_m *StepClient) SendMsg(m interface{}) error
    func (_m *StepClient) Trailer() metadata.MD
type StepStream
    func (_m *StepStream) Context() context.Context
    func (_m *StepStream) Recv() (*orderer.StepRequest, error)
    func (_m *StepStream) RecvMsg(m interface{}) error
    func (_m *StepStream) Send(response *orderer.StepResponse) error
    func (_m *StepStream) SendHeader(_a0 metadata.MD) error
    func (_m *StepStream) SendMsg(m interface{}) error
    func (_m *StepStream) SetHeader(_a0 metadata.MD) error
    func (_m *StepStream) SetTrailer(_a0 metadata.MD)
type VerifierFactory
    func (_m *VerifierFactory) VerifierFromConfig(configuration *common.ConfigEnvelope, channel string) (cluster.BlockVerifier, error)
type VerifierRetriever
    func (_m *VerifierRetriever) RetrieveVerifier(channel string) cluster.BlockVerifier

Package files

block_retriever.go block_verifier.go chain_puller.go channel_lister.go cluster_client.go communicator.go dispatcher.go handler.go ledger_factory.go ledger_writer.go metrics_provider.go secure_dialer.go step_client.go step_stream.go verifier_factory.go verifier_retriever.go

type BlockRetriever

BlockRetriever is an autogenerated mock type for the BlockRetriever type

type BlockRetriever struct {
    mock.Mock
}

func (*BlockRetriever) Block

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

Block provides a mock function with given fields: number

type BlockVerifier

BlockVerifier is an autogenerated mock type for the BlockVerifier type

type BlockVerifier struct {
    mock.Mock
}

func (*BlockVerifier) VerifyBlockSignature

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

VerifyBlockSignature provides a mock function with given fields: sd, config

type ChainPuller

ChainPuller is an autogenerated mock type for the ChainPuller type

type ChainPuller struct {
    mock.Mock
}

func (*ChainPuller) Close

func (_m *ChainPuller) Close()

Close provides a mock function with given fields:

func (*ChainPuller) HeightsByEndpoints

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

HeightsByEndpoints provides a mock function with given fields:

func (*ChainPuller) PullBlock

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

PullBlock provides a mock function with given fields: seq

type ChannelLister

ChannelLister is an autogenerated mock type for the ChannelLister type

type ChannelLister struct {
    mock.Mock
}

func (*ChannelLister) Channels

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

Channels provides a mock function with given fields:

func (*ChannelLister) Close

func (_m *ChannelLister) Close()

Close provides a mock function with given fields:

type ClusterClient

ClusterClient is an autogenerated mock type for the ClusterClient type

type ClusterClient struct {
    mock.Mock
}

func (*ClusterClient) Step

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

Step provides a mock function with given fields: ctx, opts

type Communicator

Communicator is an autogenerated mock type for the Communicator type

type Communicator struct {
    mock.Mock
}

func (*Communicator) Configure

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

Configure provides a mock function with given fields: channel, members

func (*Communicator) Remote

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

Remote provides a mock function with given fields: channel, id

func (*Communicator) Shutdown

func (_m *Communicator) Shutdown()

Shutdown provides a mock function with given fields:

type Dispatcher

Dispatcher is an autogenerated mock type for the Dispatcher type

type Dispatcher struct {
    mock.Mock
}

func (*Dispatcher) DispatchConsensus

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

DispatchConsensus provides a mock function with given fields: ctx, request

func (*Dispatcher) DispatchSubmit

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

DispatchSubmit provides a mock function with given fields: ctx, request

type Handler

Handler is an autogenerated mock type for the Handler type

type Handler struct {
    mock.Mock
}

func (*Handler) OnConsensus

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

OnConsensus provides a mock function with given fields: channel, sender, req

func (*Handler) OnSubmit

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

OnSubmit provides a mock function with given fields: channel, sender, req

type LedgerFactory

LedgerFactory is an autogenerated mock type for the LedgerFactory type

type LedgerFactory struct {
    mock.Mock
}

func (*LedgerFactory) GetOrCreate

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

GetOrCreate provides a mock function with given fields: chainID

type LedgerWriter

LedgerWriter is an autogenerated mock type for the LedgerWriter type

type LedgerWriter struct {
    mock.Mock
}

func (*LedgerWriter) Append

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

Append provides a mock function with given fields: block

func (*LedgerWriter) Height

func (_m *LedgerWriter) Height() uint64

Height provides a mock function with given fields:

type MetricsProvider

MetricsProvider is an autogenerated mock type for the MetricsProvider type

type MetricsProvider struct {
    mock.Mock
}

func (*MetricsProvider) NewCounter

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

NewCounter provides a mock function with given fields: opts

func (*MetricsProvider) NewGauge

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

NewGauge provides a mock function with given fields: opts

func (*MetricsProvider) NewHistogram

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

NewHistogram provides a mock function with given fields: opts

type SecureDialer

SecureDialer is an autogenerated mock type for the SecureDialer type

type SecureDialer struct {
    mock.Mock
}

func (*SecureDialer) Dial

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

Dial provides a mock function with given fields: address, verifyFunc

type StepClient

StepClient is an autogenerated mock type for the StepClient type

type StepClient struct {
    mock.Mock
}

func (*StepClient) CloseSend

func (_m *StepClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*StepClient) Context

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

Context provides a mock function with given fields:

func (*StepClient) Header

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

Header provides a mock function with given fields:

func (*StepClient) Recv

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

Recv provides a mock function with given fields:

func (*StepClient) RecvMsg

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

RecvMsg provides a mock function with given fields: m

func (*StepClient) Send

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

Send provides a mock function with given fields: _a0

func (*StepClient) SendMsg

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

SendMsg provides a mock function with given fields: m

func (*StepClient) Trailer

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

Trailer provides a mock function with given fields:

type StepStream

StepStream is an autogenerated mock type for the StepStream type

type StepStream struct {
    mock.Mock
}

func (*StepStream) Context

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

Context provides a mock function with given fields:

func (*StepStream) Recv

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

Recv provides a mock function with given fields:

func (*StepStream) RecvMsg

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

RecvMsg provides a mock function with given fields: m

func (*StepStream) Send

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

Send provides a mock function with given fields: response

func (*StepStream) SendHeader

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

SendHeader provides a mock function with given fields: _a0

func (*StepStream) SendMsg

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

SendMsg provides a mock function with given fields: m

func (*StepStream) SetHeader

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

SetHeader provides a mock function with given fields: _a0

func (*StepStream) SetTrailer

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

SetTrailer provides a mock function with given fields: _a0

type VerifierFactory

VerifierFactory is an autogenerated mock type for the VerifierFactory type

type VerifierFactory struct {
    mock.Mock
}

func (*VerifierFactory) VerifierFromConfig

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

VerifierFromConfig provides a mock function with given fields: configuration, channel

type VerifierRetriever

VerifierRetriever is an autogenerated mock type for the VerifierRetriever type

type VerifierRetriever struct {
    mock.Mock
}

func (*VerifierRetriever) RetrieveVerifier

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

RetrieveVerifier provides a mock function with given fields: channel