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

bmmc

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 12, 2024

Changes in this version

+ const GossipRoute

+ const SolicitationRoute

+ const SynchronizationRoute

type BMMC

+ func (b *BMMC) GossipHandler(body []byte)

+ func (b *BMMC) SolicitationHandler(body []byte)

+ func (b *BMMC) SynchronizationHandler(body []byte)

type Config

+ Host peer.Peer

+ type Gossip struct

+ Digest []string

+ Host string

+ RoundNumber *GossipRound

+ type Solicitation struct

+ Digest []string

+ Host string

+ RoundNumber *GossipRound

+ type Synchronization struct

+ Elements []buffer.Element

+ Host string

v0.6.4

Feb 17, 2024

v0.6.3

May 29, 2023

v0.6.2

May 28, 2023

v0.6.1

Aug 30, 2022

v0.6.0

Aug 10, 2022

Changes in this version

type Config

+ ReadHeaderTimeout time.Duration

v0.5.2

May 12, 2021

v0.5.1

Jun 25, 2020

v0.5.0

Mar 3, 2020

v0.4.0

Nov 7, 2019

Changes in this version

type BMMC

+ func (b *BMMC) Add(msg interface{}, callbackType string) error

type Config

+ BufferSize int

type HTTPGossip

+ Digest []string

type HTTPSolicitation

+ Digest []string

type HTTPSynchronization

+ Elements []buffer.Element

v0.3.0

Oct 17, 2019

Changes in this version

+ type BMMC struct

+ func (b *BMMC) AddMessage(msg interface{}, callbackType string) error

+ func (b *BMMC) AddPeer(addr, port string) error

+ func (b *BMMC) GetMessages() []interface{}

+ func (b *BMMC) GetPeers() []string

+ func (b *BMMC) RemovePeer(addr, port string) error

+ func (b *BMMC) Start() error

+ func (b *BMMC) Stop()

+ type GossipRound struct

+ Mux *sync.Mutex

+ Number int64

+ func NewGossipRound() *GossipRound

+ func (r *GossipRound) GetNumber() int64

+ func (r *GossipRound) Increment()

+ type HTTPGossip struct

+ Addr string

+ Digests buffer.DigestBuffer

+ Port string

+ RoundNumber *GossipRound

+ type HTTPSolicitation struct

+ Addr string

+ Digests buffer.DigestBuffer

+ Port string

+ RoundNumber *GossipRound

+ type HTTPSynchronization struct

+ Addr string

+ Messages buffer.MessageBuffer

+ Port string

v0.2.6

Jun 10, 2019

v0.2.5

Jun 9, 2019

v0.2.4

Jun 8, 2019

v0.2.3

Jun 8, 2019

v0.2.2

Jun 7, 2019

Changes in this version

type Config

+ RoundDuration time.Duration

v0.2.1

Jun 1, 2019

v0.2.0

May 21, 2019

v0.1.8

May 21, 2019

Changes in this version

+ const NOCALLBACK

v0.1.7

May 19, 2019

v0.1.6

May 18, 2019

Changes in this version

type Bmmc

+ func (b *Bmmc) AddPeer(addr, port string)

+ func (b *Bmmc) RemovePeer(addr, port string)

+ type Peer struct

+ Addr string

+ Port string

v0.1.5

May 12, 2019

v0.1.4

May 11, 2019

Changes in this version

type Config

+ Callbacks *callback.Registry

v0.1.3

May 7, 2019

Changes in this version

+ func RunWithSpec(retries int, noPeers int, loss float64, beta float64, timeout time.Duration) error

type Config

+ Logger *log.Logger

v0.1.2

Apr 13, 2019

Changes in this version

+ type Bmmc struct

+ func (b *Bmmc) AddMessage(msg string)

+ func (b *Bmmc) GetMessages() []string

+ func (b *Bmmc) Start() error

+ func (b *Bmmc) Stop()

type Config

+ Addr string

+ Port string

v0.1.1

Apr 11, 2019

Changes in this version

+ type Config struct

+ Beta float64

+ GossipAddr string

+ GossipPort string

+ HTTPAddr string

+ HTTPPort string

+ Peers []peer.Peer

+ type Protocol struct

+ func New(cfg Config) *Protocol

+ func (p *Protocol) AddMessage(msg string)

+ func (p *Protocol) GetMessages() []string

+ func (p *Protocol) Start() error

+ func (p *Protocol) Stop()