dissemination

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 4, 2021 License: Apache-2.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var LocalMSPProvider = &localMSPProvider{}

LocalMSPProvider provides the local peer's MSP ID

Functions

func ComputeDisseminationPlan

func ComputeDisseminationPlan(
	channelID, ns string,
	rwSet *rwset.CollectionPvtReadWriteSet,
	collConfig *pb.StaticCollectionConfig,
	colAP privdata.CollectionAccessPolicy,
	pvtDataMsg *protoext.SignedGossipMessage,
	gossipAdapter gossipAdapter) ([]*dissemination.Plan, bool, error)

ComputeDisseminationPlan returns the dissemination plan for off ledger data

Types

type Disseminator

type Disseminator struct {
	*discovery.Discovery
	// contains filtered or unexported fields
}

Disseminator disseminates collection data to other endorsers

func New

func New(channelID, namespace, collection string, policy privdata.CollectionAccessPolicy, gossip gossipAdapter) *Disseminator

New returns a new disseminator

func (*Disseminator) ResolvePeersForRetrieval

func (d *Disseminator) ResolvePeersForRetrieval(includePeer PeerFilter) discovery.PeerGroup

ResolvePeersForRetrieval resolves to a set of peers from which data should may be retrieved

type PeerFilter added in v0.1.4

type PeerFilter func(*discovery.Member) bool

PeerFilter returns true if the given member should be included

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL