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

discovery

package

Go to main page

Versions in this module

v2

v2.1.1

Jun 1, 2020

v2.1.0

Apr 15, 2020

Changes in this version

type NetworkMember

+ func (n NetworkMember) Clone() NetworkMember

v2.0.1

Feb 26, 2020

v2.0.0

Jan 29, 2020

Changes in this version

+ const DefAliveExpirationCheckInterval

+ const DefAliveExpirationTimeout

+ const DefAliveTimeInterval

+ const DefReconnectInterval

+ func HasExternalEndpoint(member NetworkMember) bool

+ func SetMaxConnAttempts(attempts int)

+ type CommService interface

+ Accept func() <-chan protoext.ReceivedMessage

+ CloseConn func(peer *NetworkMember)

+ Forward func(msg protoext.ReceivedMessage)

+ Gossip func(msg *protoext.SignedGossipMessage)

+ IdentitySwitch func() <-chan common.PKIidType

+ Ping func(peer *NetworkMember) bool

+ PresumedDead func() <-chan common.PKIidType

+ SendToPeer func(peer *NetworkMember, msg *protoext.SignedGossipMessage)

+ type CryptoService interface

+ SignMessage func(m *proto.GossipMessage, internalEndpoint string) *proto.Envelope

+ ValidateAliveMsg func(message *protoext.SignedGossipMessage) bool

+ type DisclosurePolicy func(remotePeer *NetworkMember) (Sieve, EnvelopeFilter)

+ type Discovery interface

+ Connect func(member NetworkMember, id identifier)

+ GetMembership func() []NetworkMember

+ InitiateSync func(peerNum int)

+ Lookup func(PKIID common.PKIidType) *NetworkMember

+ Self func() NetworkMember

+ Stop func()

+ UpdateEndpoint func(string)

+ UpdateMetadata func([]byte)

+ func NewDiscoveryService(self NetworkMember, comm CommService, crypt CryptoService, ...) Discovery

+ type DiscoveryConfig struct

+ AliveExpirationCheckInterval time.Duration

+ AliveExpirationTimeout time.Duration

+ AliveTimeInterval time.Duration

+ BootstrapPeers []string

+ ReconnectInterval time.Duration

+ type EnvelopeFilter func(message *protoext.SignedGossipMessage) *proto.Envelope

+ type Members []NetworkMember

+ func (members Members) ByID() map[string]NetworkMember

+ func (members Members) Filter(filter func(member NetworkMember) bool) Members

+ func (members Members) Intersect(otherMembers Members) Members

+ func (members Members) Map(f func(member NetworkMember) NetworkMember) Members

+ type NetworkMember struct

+ Endpoint string

+ InternalEndpoint string

+ Metadata []byte

+ PKIid common.PKIidType

+ Properties *proto.Properties

+ func (n NetworkMember) PreferredEndpoint() string

+ func (n NetworkMember) String() string

+ type PeerIdentification struct

+ ID common.PKIidType

+ SelfOrg bool

+ type Sieve func(message *protoext.SignedGossipMessage) bool

v2.0.0-beta

Dec 12, 2019

v2.0.0-alpha

Apr 9, 2019

Other modules containing this package

gopkg.in/hyperledger/fabric.v1