mocks

Apr 11, 2019

Changes in this version

+ type BlockRetriever struct

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

type Dispatcher

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

type Handler

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

+ type MetricsProvider struct

+ 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 StepClient struct

+ 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 struct

+ 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 struct

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

+ type VerifierRetriever struct

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

Jan 9, 2019

Changes in this version

+ type BlockVerifier struct

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

+ type ChainPuller struct

+ func (_m *ChainPuller) Close()

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

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

+ type ChannelLister struct

+ func (_m *ChannelLister) Channels() []string

+ func (_m *ChannelLister) Close()

+ type Communicator struct

+ 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 LedgerFactory struct

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

+ type LedgerWriter struct

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

+ func (_m *LedgerWriter) Height() uint64

Oct 10, 2018

Changes in this version

+ type ClusterClient struct

+ func (_m *ClusterClient) Step(ctx context.Context, in *orderer.StepRequest, opts ...grpc.CallOption) (*orderer.StepResponse, error)

+ func (_m *ClusterClient) Submit(ctx context.Context, opts ...grpc.CallOption) (orderer.Cluster_SubmitClient, error)

+ type Dispatcher struct

+ func (_m *Dispatcher) DispatchStep(ctx context.Context, request *orderer.StepRequest) (*orderer.StepResponse, error)

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

+ type Handler struct

+ func (_m *Handler) OnStep(channel string, sender uint64, req *orderer.StepRequest) (*orderer.StepResponse, error)

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

+ type RemoteCommunicator struct

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

+ type SecureDialer struct

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

+ type SubmitClient struct

+ func (_m *SubmitClient) CloseSend() error

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

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

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

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

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

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

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

+ type SubmitStream struct

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

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

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

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

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

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

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

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