Code generated by counterfeiter.

BlockToString returns a string representation of this block.

CachePublicKeyComparisons creates CertificateComparator that caches invocations based on input arguments.

DERtoPEM returns a PEM representation of the DER encoded certificate.

EndpointconfigFromConfigBlock retrieves TLS CA certificates and endpoints from a config block.

LastConfigBlock returns the last config block relative to the given block.

NewConnectionStore creates a new ConnectionStore with the given SecureDialer.

NewImpatientStream returns a ImpatientStreamCreator that creates impatientStreams.

NewMetrics initializes new metrics for the cluster infrastructure.

NewStreamsByType returns a mapping of operation type to a mapping of destination to stream.

PullLastConfigBlock pulls the last configuration block, or returns an error on failure.

VerifyBlockHash verifies the hash chain of the block with the given index among the blocks of the given block buffer.

VerifyBlocksBFT verifies the given consecutive sequence of blocks is valid, always verifies signature, and returns nil if it's valid, else an error.

VerifyBlockSignature verifies the signature on the block with the given BlockVerifier and the given config.

Lable used for TLS Export Keying Material call.

MinimumExpirationWarningInterval is the default minimum time interval between consecutive warnings about certificate expiration.

ErrForbidden denotes that an ordering node refuses sending blocks due to access control.

ErrNotInChannel denotes that an ordering node is not in the channel.

ErrServiceUnavailable denotes that an ordering node is not servicing at the moment.

AuthCommMgr implements the Communicator It manages the client side connections and streams established with the Cluster GRPC server and new Cluster service.

BlockPuller pulls blocks from remote ordering nodes.

BlockValidationPolicyVerifier verifies signatures based on the block validation policy.

ClusterService implements the server API for ClusterNodeService service.

Comm implements Communicator.

ComparisonMemoizer speeds up comparison computations by caching past invocations of a stateless function.

ConnectionStore stores connections to remote nodes.

EndpointCriteria defines criteria of how to connect to a remote orderer node.

ImpatientStream aborts the stream if it waits for too long for a message.

MemberMapping defines NetworkMembers by their ID and enables to lookup stubs by a certificate.

Metrics defines the metrics for the cluster.

PredicateDialer creates gRPC connections that are only established if the given predicate is fulfilled.

RemoteContext interacts with remote cluster nodes.

RemoteNode represents a cluster member.

RPC performs remote procedure calls to remote cluster nodes.

Service defines the raft Service.

StandardDialer wraps an ClientConfig, and provides a means to connect according to given EndpointCriteria.

Stream is used to send/receive messages to/from the remote cluster member.

StreamCountReporter reports the number of streams currently connected to this node.

Stub holds all information about the remote node, including the RemoteContext for it, and serializes some operations on it.

BlockRetriever retrieves blocks.

ChainPuller pulls blocks from a chain.

ChannelExtractor extracts the channel of a given message, or returns an empty string if that's not possible.

ClusterClient creates streams that point to a remote cluster member.

ClusterStepStream defines the gRPC stream for sending transactions, and receiving corresponding responses.

Communicator defines communication for a consenter.

ConnectionMapper maps certificates to connections.

Dialer creates a gRPC connection to a remote address.

Dispatcher dispatches requests.

Handler handles Step() and Submit() requests and returns a corresponding response.

A MetricsProvider is an abstraction for a metrics provider.

SecureDialer connects to a remote address.

StepClient defines a client that sends and receives Step requests and responses.

StepClientStream go:generate mockery --dir .

StepStream defines the gRPC stream for sending transactions, and receiving corresponding responses.

VerifierFactory creates BlockVerifiers.

BlockCommitFunc signals a block commit.

BlockSequenceVerifier verifies that the given consecutive sequence of blocks is valid.

CertificateComparator returns whether some relation holds for two given certificates.

ConnByCertMap maps certificates represented as strings to gRPC connections.

ImpatientStreamCreator creates an ImpatientStream.

MembersByChannel is a mapping from channel name to MemberMapping.

OperationType denotes a type of operation that the RPC can perform such as sending a transaction, or a consensus related message.

RemoteVerifier verifies the connection to the remote host.

StreamOperation denotes an operation done by a stream, such a Send or Receive.

StringSet is a set of strings.