Versions in this module Expand all Collapse all v1 v1.4.9 Jul 22, 2021 Changes in this version + type BlockRetriever struct + func (_m *BlockRetriever) Block(number uint64) *common.Block + 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, error) + func (_m *ChainPuller) PullBlock(seq uint64) *common.Block + type ChannelLister struct + func (_m *ChannelLister) Channels() []cluster.ChannelGenesisBlock + func (_m *ChannelLister) Close() + type ClusterClient struct + func (_m *ClusterClient) Step(ctx context.Context, opts ...grpc.CallOption) (orderer.Cluster_StepClient, error) + 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 Dispatcher struct + func (_m *Dispatcher) DispatchConsensus(ctx context.Context, request *orderer.ConsensusRequest) error + func (_m *Dispatcher) DispatchSubmit(ctx context.Context, request *orderer.SubmitRequest) error + type Handler struct + 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 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 + 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 SecureDialer struct + func (_m *SecureDialer) Dial(address string, verifyFunc cluster.RemoteVerifier) (*grpc.ClientConn, error) + 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