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

multipeer

package

Go to main page

Versions in this module

v1

v1.7.9

Dec 18, 2024

Changes in this version

type MultiPeerReconcilerConfig

+ SyncIntervalSpread float64

+ func (cfg *MultiPeerReconcilerConfig) Validate(logger *zap.Logger) bool

type SetSyncBase

+ func (ssb *SetSyncBase) Serve(ctx context.Context, p p2p.Peer, stream io.ReadWriter) error

+ func (ssb *SetSyncBase) Sync(ctx context.Context, p p2p.Peer, x, y rangesync.KeyBytes) error

type SyncBase

+ Serve func(ctx context.Context, p p2p.Peer, stream io.ReadWriter) error

+ Sync func(ctx context.Context, p p2p.Peer, x, y rangesync.KeyBytes) error

v1.7.8

Nov 28, 2024

Changes in this version

+ const Protocol

v1.7.7

Nov 19, 2024

Changes in this version

+ type MultiPeerReconciler struct

+ func NewMultiPeerReconciler(logger *zap.Logger, cfg MultiPeerReconcilerConfig, syncBase SyncBase, ...) *MultiPeerReconciler

+ func (mpr *MultiPeerReconciler) Run(ctx context.Context) error

+ func (mpr *MultiPeerReconciler) Synced() bool

+ type MultiPeerReconcilerConfig struct

+ FullSyncednessPeriod time.Duration

+ MaxFullDiff int

+ MaxSyncDiff int

+ MinCompleteFraction float64

+ MinFullSyncednessCount int

+ MinSplitSyncCount int

+ MinSplitSyncPeers int

+ NoPeersRecheckInterval time.Duration

+ RetryInterval time.Duration

+ SplitSyncGracePeriod time.Duration

+ SyncInterval time.Duration

+ SyncPeerCount int

+ func DefaultConfig() MultiPeerReconcilerConfig

+ type PairwiseSyncer interface

+ Probe func(ctx context.Context, peer p2p.Peer, os rangesync.OrderedSet, ...) (rangesync.ProbeResult, error)

+ Serve func(context context.Context, stream io.ReadWriter, os rangesync.OrderedSet) error

+ Sync func(ctx context.Context, peer p2p.Peer, os rangesync.OrderedSet, ...) error

+ type PeerSyncer interface

+ Peer func() p2p.Peer

+ Release func() error

+ Serve func(ctx context.Context, stream io.ReadWriter) error

+ Sync func(ctx context.Context, x, y rangesync.KeyBytes) error

+ type SetSyncBase struct

+ func NewSetSyncBase(logger *zap.Logger, ps PairwiseSyncer, os rangesync.OrderedSet, ...) *SetSyncBase

+ func (ssb *SetSyncBase) Count() (int, error)

+ func (ssb *SetSyncBase) Derive(p p2p.Peer) PeerSyncer

+ func (ssb *SetSyncBase) Probe(ctx context.Context, p p2p.Peer) (rangesync.ProbeResult, error)

+ func (ssb *SetSyncBase) Wait() error

+ type SyncBase interface

+ Count func() (int, error)

+ Derive func(p p2p.Peer) PeerSyncer

+ Probe func(ctx context.Context, p p2p.Peer) (rangesync.ProbeResult, error)

+ Wait func() error

+ type SyncKeyHandler interface

+ Commit func(peer p2p.Peer, base, new rangesync.OrderedSet) error

+ Receive func(k rangesync.KeyBytes, peer p2p.Peer) (bool, error)