Versions in this module Expand all Collapse all v2 v2.3.2 Nov 21, 2021 Changes in this version + type BlockRetriever struct + func (_m *BlockRetriever) Block(number uint64) *common.Block + type BlockVerifier struct + func (_m *BlockVerifier) VerifyBlockSignature(sd []*protoutil.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 Policy struct + EvaluateIdentitiesStub func([]msp.Identity) error + EvaluateSignedDataStub func([]*protoutil.SignedData) error + func (fake *Policy) EvaluateIdentities(arg1 []msp.Identity) error + func (fake *Policy) EvaluateIdentitiesArgsForCall(i int) []msp.Identity + func (fake *Policy) EvaluateIdentitiesCallCount() int + func (fake *Policy) EvaluateIdentitiesCalls(stub func([]msp.Identity) error) + func (fake *Policy) EvaluateIdentitiesReturns(result1 error) + func (fake *Policy) EvaluateIdentitiesReturnsOnCall(i int, result1 error) + func (fake *Policy) EvaluateSignedData(arg1 []*protoutil.SignedData) error + func (fake *Policy) EvaluateSignedDataArgsForCall(i int) []*protoutil.SignedData + func (fake *Policy) EvaluateSignedDataCallCount() int + func (fake *Policy) EvaluateSignedDataCalls(stub func([]*protoutil.SignedData) error) + func (fake *Policy) EvaluateSignedDataReturns(result1 error) + func (fake *Policy) EvaluateSignedDataReturnsOnCall(i int, result1 error) + func (fake *Policy) Invocations() map[string][][]interface{} + type PolicyManager struct + GetPolicyStub func(string) (policies.Policy, bool) + ManagerStub func([]string) (policies.Manager, bool) + func (fake *PolicyManager) GetPolicy(arg1 string) (policies.Policy, bool) + func (fake *PolicyManager) GetPolicyArgsForCall(i int) string + func (fake *PolicyManager) GetPolicyCallCount() int + func (fake *PolicyManager) GetPolicyCalls(stub func(string) (policies.Policy, bool)) + func (fake *PolicyManager) GetPolicyReturns(result1 policies.Policy, result2 bool) + func (fake *PolicyManager) GetPolicyReturnsOnCall(i int, result1 policies.Policy, result2 bool) + func (fake *PolicyManager) Invocations() map[string][][]interface{} + func (fake *PolicyManager) Manager(arg1 []string) (policies.Manager, bool) + func (fake *PolicyManager) ManagerArgsForCall(i int) []string + func (fake *PolicyManager) ManagerCallCount() int + func (fake *PolicyManager) ManagerCalls(stub func([]string) (policies.Manager, bool)) + func (fake *PolicyManager) ManagerReturns(result1 policies.Manager, result2 bool) + func (fake *PolicyManager) ManagerReturnsOnCall(i int, result1 policies.Manager, result2 bool) + type SecureDialer struct + func (_m *SecureDialer) Dial(address string, verifyFunc cluster.RemoteVerifier) (*grpc.ClientConn, error) + type SignerSerializer struct + SerializeStub func() ([]byte, error) + SignStub func([]byte) ([]byte, error) + func (fake *SignerSerializer) Invocations() map[string][][]interface{} + func (fake *SignerSerializer) Serialize() ([]byte, error) + func (fake *SignerSerializer) SerializeCallCount() int + func (fake *SignerSerializer) SerializeCalls(stub func() ([]byte, error)) + func (fake *SignerSerializer) SerializeReturns(result1 []byte, result2 error) + func (fake *SignerSerializer) SerializeReturnsOnCall(i int, result1 []byte, result2 error) + func (fake *SignerSerializer) Sign(arg1 []byte) ([]byte, error) + func (fake *SignerSerializer) SignArgsForCall(i int) []byte + func (fake *SignerSerializer) SignCallCount() int + func (fake *SignerSerializer) SignCalls(stub func([]byte) ([]byte, error)) + func (fake *SignerSerializer) SignReturns(result1 []byte, result2 error) + func (fake *SignerSerializer) SignReturnsOnCall(i int, result1 []byte, result2 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 Other modules containing this package github.com/waszqt/fabric
Go to main page