service

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 New(peerIdentity identity.SignerSerializer, ...) (*GossipService, error)
  • 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
  • func GlobalConfig() *ServiceConfig
• type Support

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
}