Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cluster

package

Go to main page

Versions in this module

v1

v1.4.0

Jan 9, 2019

Changes in this version

+ const RetryTimeout

+ var ErrNotInChannel = errors.New("not in the channel")

+ func ConfigFromBlock(block *common.Block) (*common.ConfigEnvelope, error)

+ func IsNewChannelBlock(block *common.Block) (string, error)

+ func Participant(puller ChainPuller, analyzeLastConfBlock selfMembershipPredicate) error

+ func SignatureSetFromBlock(block *common.Block) ([]*common.SignedData, error)

+ func VerifyBlockHash(indexInBuffer int, blockBuff []*common.Block) error

+ func VerifyBlockSignature(block *common.Block, verifier BlockVerifier, config *common.ConfigEnvelope) error

+ func VerifyBlocks(blockBuff []*common.Block, signatureVerifier BlockVerifier) error

+ type BlockPuller struct

+ Channel string

+ Dialer Dialer

+ Endpoints []string

+ FetchTimeout time.Duration

+ Logger *flogging.FabricLogger

+ MaxTotalBufferBytes int

+ RetryTimeout time.Duration

+ Signer crypto.LocalSigner

+ TLSCert []byte

+ VerifyBlockSequence BlockSequenceVerifier

+ func BlockPullerFromConfigBlock(conf PullerConfig, block *common.Block) (*BlockPuller, error)

+ func (p *BlockPuller) Clone() *BlockPuller

+ func (p *BlockPuller) Close()

+ func (p *BlockPuller) HeightsByEndpoints() map[string]uint64

+ func (p *BlockPuller) PullBlock(seq uint64) *common.Block

+ type BlockSequenceVerifier func([]*common.Block) error

+ type BlockVerifier interface

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

+ type ChainInspector struct

+ LastConfigBlock *common.Block

+ Logger *flogging.FabricLogger

+ Puller ChainPuller

+ func (ci *ChainInspector) Channels() []string

+ func (ci *ChainInspector) Close()

+ type ChainPuller interface

+ Close func()

+ HeightsByEndpoints func() map[string]uint64

+ PullBlock func(seq uint64) *common.Block

+ type ChannelLister interface

+ Channels func() []string

+ Close func()

+ type Dialer interface

+ Dial func(address string) (*grpc.ClientConn, error)

+ type EndpointConfig struct

+ Endpoints []string

+ TLSRootCAs [][]byte

+ func EndpointconfigFromConfigBlock(block *common.Block) (*EndpointConfig, error)

+ type ImpatientStream struct

+ func (stream *ImpatientStream) Recv() (*orderer.DeliverResponse, error)

+ type ImpatientStreamCreator func() (*ImpatientStream, error)

+ func NewImpatientStream(conn *grpc.ClientConn, waitTimeout time.Duration) ImpatientStreamCreator

+ type LedgerFactory interface

+ GetOrCreate func(chainID string) (LedgerWriter, error)

+ type LedgerWriter interface

+ Append func(block *common.Block) error

+ Height func() uint64

+ type NoopBlockVerifier struct

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

type PredicateDialer

+ func (dialer *PredicateDialer) ClientConfig() (comm.ClientConfig, error)

+ type PullerConfig struct

+ Channel string

+ MaxTotalBufferBytes int

+ Signer crypto.LocalSigner

+ TLSCert []byte

+ TLSKey []byte

+ Timeout time.Duration

+ func PullerConfigFromTopLevelConfig(systemChannel string, conf *localconfig.TopLevel, tlsKey, tlsCert []byte, ...) PullerConfig

type RPC

+ DestinationToStream map[uint64]orderer.Cluster_SubmitClient

+ type Replicator struct

+ AmIPartOfChannel selfMembershipPredicate

+ BootBlock *common.Block

+ ChannelLister ChannelLister

+ LedgerFactory LedgerFactory

+ Logger *flogging.FabricLogger

+ Puller *BlockPuller

+ SystemChannel string

+ func (r *Replicator) IsReplicationNeeded() (bool, error)

+ func (r *Replicator) PullChannel(channel string) error

+ func (r *Replicator) ReplicateChains()

type Service

+ StepLogger *flogging.FabricLogger

+ type StandardDialer struct

+ Dialer *PredicateDialer

+ func (bdp *StandardDialer) Dial(address string) (*grpc.ClientConn, error)

v1.4.0-rc2

Dec 20, 2018

v1.4.0-rc1

Dec 10, 2018

v1.3.0

Oct 10, 2018

Changes in this version

+ const DefaultRPCTimeout

+ func DERtoPEM(der []byte) string

+ type ChannelExtractor interface

+ TargetChannel func(message proto.Message) string

+ type Client interface

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

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

+ type Comm struct

+ Chan2Members MembersByChannel

+ ChanExt ChannelExtractor

+ Connections *ConnectionStore

+ H Handler

+ Lock sync.RWMutex

+ Logger *logging.Logger

+ RPCTimeout time.Duration

+ func (c *Comm) Configure(channel string, newNodes []RemoteNode)

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

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

+ func (c *Comm) Remote(channel string, id uint64) (*RemoteContext, error)

+ func (c *Comm) Shutdown()

+ type Communicator interface

+ Configure func(channel string, members []*RemoteNode)

+ Remote func(channel string, id uint64) (*RemoteContext, error)

+ Shutdown func()

+ type ConnByCertMap map[string]*grpc.ClientConn

+ func (cbc ConnByCertMap) Lookup(cert []byte) (*grpc.ClientConn, bool)

+ func (cbc ConnByCertMap) Put(cert []byte, conn *grpc.ClientConn)

+ func (cbc ConnByCertMap) Remove(cert []byte)

+ type ConnectionMapper interface

+ Lookup func(cert []byte) (*grpc.ClientConn, bool)

+ Put func(cert []byte, conn *grpc.ClientConn)

+ Remove func(cert []byte)

+ type ConnectionStore struct

+ Connections ConnectionMapper

+ func NewConnectionStore(dialer SecureDialer) *ConnectionStore

+ func (c *ConnectionStore) Connection(endpoint string, expectedServerCert []byte) (*grpc.ClientConn, error)

+ func (c *ConnectionStore) Disconnect(expectedServerCert []byte)

+ type Dispatcher interface

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

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

+ type Handler interface

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

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

+ type MemberMapping map[uint64]*Stub

+ func (mp MemberMapping) ByID(ID uint64) *Stub

+ func (mp MemberMapping) LookupByClientCert(cert []byte) *Stub

+ func (mp MemberMapping) Put(stub *Stub)

+ func (mp MemberMapping) ServerCertificates() StringSet

+ type MembersByChannel map[string]MemberMapping

+ type PredicateDialer struct

+ Config atomic.Value

+ func NewTLSPinningDialer(config comm.ClientConfig) *PredicateDialer

+ func (dialer *PredicateDialer) Dial(address string, verifyFunc RemoteVerifier) (*grpc.ClientConn, error)

+ func (dialer *PredicateDialer) SetConfig(config comm.ClientConfig)

+ type RPC struct

+ Channel string

+ Comm RemoteCommunicator

+ func (s *RPC) ReceiveSubmitResponse(destination uint64) (*orderer.SubmitResponse, error)

+ func (s *RPC) SendSubmit(destination uint64, request *orderer.SubmitRequest) error

+ func (s *RPC) Step(destination uint64, msg *orderer.StepRequest) (*orderer.StepResponse, error)

+ type RemoteCommunicator interface

+ Remote func(channel string, id uint64) (*RemoteContext, error)

+ type RemoteContext struct

+ Client orderer.ClusterClient

+ RPCTimeout time.Duration

+ func (rc *RemoteContext) Abort()

+ func (rc *RemoteContext) Step(req *orderer.StepRequest) (*orderer.StepResponse, error)

+ func (rc *RemoteContext) SubmitStream() (orderer.Cluster_SubmitClient, error)

+ type RemoteNode struct

+ ClientTLSCert []byte

+ Endpoint string

+ ID uint64

+ ServerTLSCert []byte

+ func (rm RemoteNode) String() string

+ type RemoteVerifier func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error

+ type SecureDialer interface

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

+ type Service struct

+ Dispatcher Dispatcher

+ Logger logging.Logger

+ func (s *Service) Step(ctx context.Context, request *orderer.StepRequest) (*orderer.StepResponse, error)

+ func (s *Service) Submit(stream orderer.Cluster_SubmitServer) error

+ type StringSet map[string]struct

+ type Stub struct

+ func (stub *Stub) Activate(createRemoteContext func() (*RemoteContext, error)) error

+ func (stub *Stub) Active() bool

+ func (stub *Stub) Deactivate()

+ type SubmitClient interface

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

+ Send func(request *orderer.SubmitRequest) error

+ type SubmitStream interface

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

+ Send func(response *orderer.SubmitResponse) error

v1.3.0-rc1

Sep 25, 2018