Documentation
¶
Overview ¶
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
Index ¶
- type Config
- type ConfigProcessor
- type DataStoreSupport
- type DeliveryServiceFactory
- type GossipService
- func (g *GossipService) AddPayload(channelID string, payload *gproto.Payload) error
- func (g *GossipService) DistributePrivateData(channelID string, txID string, ...) error
- func (g *GossipService) InitializeChannel(channelID string, endpoints []string, support Support)
- func (g *GossipService) NewConfigEventer() ConfigProcessor
- func (g *GossipService) Stop()
- type GossipServiceAdapter
- type ServiceConfig
- type Support
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config interface {
ChannelID() string
Organizations() map[string]channelconfig.ApplicationOrg
Sequence() uint64
OrdererAddresses() []string
}
type ConfigProcessor ¶
type ConfigProcessor interface {
ProcessConfigUpdate(config Config)
}
type DataStoreSupport ¶
type DataStoreSupport struct {
committer.Committer
gossipprivdata.TransientStore
}
type DeliveryServiceFactory ¶
type DeliveryServiceFactory interface {
Service(g GossipServiceAdapter, endpoints []string, msc api.MessageCryptoService) (deliverservice.DeliverService, error)
}
type GossipService ¶
type GossipService struct {
// contains filtered or unexported fields
}
func New ¶
func New( peerIdentity identity.SignerSerializer, gossipMetrics *gossipmetrics.GossipMetrics, endpoint string, s *grpc.Server, mcs api.MessageCryptoService, secAdv api.SecurityAdvisor, secureDialOpts api.PeerSecureDialOpts, credSupport *corecomm.CredentialSupport, deliverClientDialOpts []grpc.DialOption, gossipConfig *gossip.Config, serviceConfig *ServiceConfig, deliverServiceConfig *deliverservice.DeliverServiceConfig, ) (*GossipService, error)
func (*GossipService) AddPayload ¶
func (g *GossipService) AddPayload(channelID string, payload *gproto.Payload) error
func (*GossipService) DistributePrivateData ¶
func (g *GossipService) DistributePrivateData(channelID string, txID string, privData *transientstore.TxPvtReadWriteSetWithConfigInfo, blkHt uint64) error
func (*GossipService) InitializeChannel ¶
func (g *GossipService) InitializeChannel(channelID string, endpoints []string, support Support)
func (*GossipService) NewConfigEventer ¶
func (g *GossipService) NewConfigEventer() ConfigProcessor
func (*GossipService) Stop ¶
func (g *GossipService) Stop()
type GossipServiceAdapter ¶
type GossipServiceAdapter interface {
PeersOfChannel(gossipcommon.ChannelID) []discovery.NetworkMember
AddPayload(channelID string, payload *gproto.Payload) error
Gossip(msg *gproto.GossipMessage)
}
type ServiceConfig ¶
type ServiceConfig struct {
PeerTLSEnabled bool
Endpoint string
NonBlockingCommitMode bool
UseLeaderElection bool
OrgLeader bool
ElectionStartupGracePeriod time.Duration
ElectionMembershipSampleInterval time.Duration
ElectionLeaderAliveThreshold time.Duration
ElectionLeaderElectionDuration time.Duration
PvtDataPullRetryThreshold time.Duration
PvtDataPushAckTimeout time.Duration
BtlPullMargin uint64
TransientstoreMaxBlockRetention uint64
SkipPullingInvalidTransactionsDuringCommit bool
}
func GlobalConfig ¶
func GlobalConfig() *ServiceConfig
type Support ¶
type Support struct {
Validator txvalidator.Validator
Committer committer.Committer
Store gossipprivdata.TransientStore
CollectionStore privdata.CollectionStore
IdDeserializeFactory gossipprivdata.IdentityDeserializerFactory
CapabilityProvider gossipprivdata.CapabilityProvider
}
Click to show internal directories.
Click to hide internal directories.