dissemination

Documentation

Index

• func ComputeDisseminationPlan(channelID, ns string, rwSet *rwset.CollectionPvtReadWriteSet, ...) ([]*dissemination.Plan, bool, error)
• type Disseminator
  • func New(channelID, namespace, collection string, ...) *Disseminator
  • func (d *Disseminator) ResolveAllEndorsers(excludePeers ...*discovery.Member) (discovery.PeerGroup, error)
  • func (d *Disseminator) ResolveAllEndorsersInOrgsForKey(key string, excludePeers ...*discovery.Member) (discovery.PeerGroup, error)
  • func (d *Disseminator) ResolveEndorsers(key string) (discovery.PeerGroup, error)

Functions

func ComputeDisseminationPlan

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

ComputeDisseminationPlan returns the dissemination plan for transient data

Types

type Disseminator

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

Disseminator disseminates transient data to a deterministic set of endorsers

func New

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

New returns a new transient data disseminator

func (*Disseminator) ResolveAllEndorsers

func (d *Disseminator) ResolveAllEndorsers(excludePeers ...*discovery.Member) (discovery.PeerGroup, error)

ResolveAllEndorsers resolves all endorsers that are eligible for the transient data, excluding the peers in the given exclude list.

func (*Disseminator) ResolveAllEndorsersInOrgsForKey

func (d *Disseminator) ResolveAllEndorsersInOrgsForKey(key string, excludePeers ...*discovery.Member) (discovery.PeerGroup, error)

ResolveAllEndorsersInOrgsForKey resolves all endorsers from within the orgs to which transient data should be disseminated, excluding the peers in the given exclude list.

func (*Disseminator) ResolveEndorsers

func (d *Disseminator) ResolveEndorsers(key string) (discovery.PeerGroup, error)

ResolveEndorsers resolves to a set of endorsers to which transient data should be disseminated